Redis连接方式

  ConfigurationOptions op = new ConfigurationOptions();
            op.EndPoints.Add("192.168.1.202", 6379);
            op.Password = "mdsd";
            op.AbortOnConnectFail = false;

 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(op);

 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("192.168.1.202:6379,password=mdsd");

            IDatabase db = redis.GetDatabase();

 //设置数据对象
            //db.StringSet("User", "{Name:\"TOM\"}");
            //添加数据对象
            //db.StringAppend("User", ",{Name:\"JACK\"}");
            //取得数据对象
            //string user = db.StringGet("User");
            //Console.WriteLine(user);

            db.StringSet("User", "{Name:\"TOM\"}", new TimeSpan(1, 0, 0));

            db.ListLeftPush("userinfo", "{Name:\"LALI\"}");
            db.ListSetByIndex("userinfo", 0, "{Name:\"TOM\"}");
            db.ListLeftPush("userinfo", "{Name:\"LALI\"}");
            db.ListRightPush("userinfo", "{Name:\"JACK\"}");

            var len = db.ListLength("userinfo");
            Console.WriteLine("data leng:" + len.ToString());

            for (int i = 0; i < len; i++)
            {
                Console.WriteLine(i.ToString() + ":" + db.ListGetByIndex("userinfo", i));
            }
            db.KeyDelete("userinfo");

 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(op);
            ISubscriber sub = redis.GetSubscriber();

            sub.Subscribe("*", (channel, message) =>
            {

                Console.WriteLine(DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss fff    ") + (string)message);
            });

            sub.Publish("messages", "hello");

            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");
            //sub.PublishAsync("messages", "hello");