釋出訂閱

 

      /// <summary>
        /// Redis釋出訂閱  釋出
        /// </summary>
        /// <typeparam name="T">資料項型別</typeparam>
        /// <param name="channel"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public long Publish<T>(string
 
 channel, T msg)
        {
            ISubscriber sub = _conn.GetSubscriber();
            return sub.Publish(channel, ConvertJson(msg));
        }

訂閱

        /// <summary>
        /// Redis釋出訂閱  訂閱
        /// </summary>
        /// <param name="subChannel"></param>
        /// <param name="handler"></param>
 

        public void Subscribe(string subChannel, Action<RedisChannel, RedisValue> handler = null)
        {
            ISubscriber sub = _conn.GetSubscriber();
            sub.Subscribe(subChannel,
                (channel, message) =>
                {
                    if (handler == null
 
)
                    {
                        Console.WriteLine(subChannel + @" 訂閱收到訊息：" + message);
                    }
                    else
                    {
                        handler(channel, message);
                    }
                });
        }