1. 程式人生 > >Redis連接方式

Redis連接方式

ann app 數據 times tle tel ole bsp 用例

  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");

Redis連接方式