Redis的使用（三）—— .NET 使用 Redis

一、安装 ServiceStack.Redis Nuget程序包

 通过Nuget添加ServiceStack.Redis程序包，添加成功后，即可进行程序的开发。

二、Redis的写入读取、订阅发布

 public class RedisClient
    {
        private ServiceStack.Redis.RedisClient client = null;

        // 发布消息的客户端
        private ServiceStack.Redis.RedisClient client_pub = null;

        public RedisClient(string ip,int port,string password=null,int db=0)
        {
            client     = new ServiceStack.Redis.RedisClient(ip, port, password, db);
            client_pub = new ServiceStack.Redis.RedisClient(ip, port, password, db);
            Console.WriteLine($"redis启动成功！");
        }

        /// <summary>
        /// 读取
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <returns></returns>
        public T GetKeyValue<T>(string key)
        {

            return client.Get<T>(key);
        }

        /// <summary>
        /// 存储
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <param name="value"></param>
        /// <returns></returns>
        public bool SetKeyValue<T>(string key,T value)
        {
           return  client.Set<T>(key,value);
        }


        /// <summary>
        /// 订阅
        /// </summary>
        public void Subscribe()
        {
            //创建订阅
            IRedisSubscription subscription = client.CreateSubscription();

            //接受到消息时
            subscription.OnMessage += (channel,cmd)=>
            {
                Console.WriteLine($"接受到消息时：消息通道：{channel}，消息内容：{cmd}");
            };

            //订阅频道时
            subscription.OnSubscribe = (channel) =>
            {
                Console.WriteLine($"订阅客户端：开始订阅消息通道：{channel}");
            };

            //取消订阅频道时
            subscription.OnUnSubscribe = (channel) => 
            { 
                Console.WriteLine($"订阅客户端：取消订阅消息通道：{channel}");
            };

            //订阅频道
            subscription.SubscribeToChannels("channel1", "channel2");
        }

        public void Publish()
        {
            client_pub.PublishMessage("channel1", $"{DateTime.Now.ToShortTimeString()} 通道 channel1 的消息");
            client_pub.PublishMessage("channel2", $"{DateTime.Now.ToShortTimeString()} 通道 channel1 的消息");
        }
    }

 static void Main(string[] args)
        {
            var redis = new RedisClient("127.0.0.1", 6379);

            // 写入
            redis.SetKeyValue<string>("name", "dwayne");
            redis.SetKeyValue<int>("age", 26);

            // 读取
            Console.WriteLine($"name的数值：{redis.GetKeyValue<string>("name")}");
            Console.WriteLine($"age的数值：{redis.GetKeyValue<string>("age")}");



            // 订阅
            Task.Run(() =>
            {
                redis.Subscribe();
            });

            // 发布
            Console.WriteLine("是否启动Redis发布：Y（启动），N（不启动）");
            if (Console.ReadLine() == "Y")
            {
                redis.Publish();
            }

            Console.ReadKey();
        }

具体运行结果如下图所示：

示例代码：https://github.com/Dwayne112401/RedisDemo

 注意：发布和订阅不能是同一个Redis连接，发布和订阅必须各自启动Redis连接，否则会报错 “only (P)SUBSCRIBE / (P)UNSUBSCRIBE / PING / QUIT allowed in this context”。