第1章 安装
在.NET平台使用Redis需要做如下准备工作:
创建一个新的Visual Studio应用或者打开一个已经存在的Visual Studio应用。
打开NuGet程序包
搜索并添加StackExchange.Redis程序包
第2章 数据缓存
使用redis做为数据缓存服务
string host = "192.168.200.131";
//取连接对象 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host); //取得DB对象 IDatabase db = redis.GetDatabase(); //设置数据对象 db.StringSet("User", "{Name:\"TOM\"}"); //添加数据对象 db.StringAppend("User", ",{Name:\"JACK\"}");//取得数据对象
string user = db.StringGet("User"); Console.WriteLine(user);第3章 订阅及发布
发布消息
static void Main(string[] args)
{ string host = "192.168.28.106"; //取连接对象 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host); //设置数据对象 //取得订阅对象 ISubscriber sub = redis.GetSubscriber(); //发布消息到channel:c1 sub.Publish("c1", "123"); //发送100万个字符的消息 sub.Publish("c1", "zx".PadRight(1000000, 'x')); string reader = "start send"; while(reader!="exit") { reader = Console.ReadLine(); sub.Publish("c1", reader); } Console.ReadLine(); }订阅消息
static void Main(string[] args)
{string host = "192.168.28.106";
//取连接对象 ConnectionMultiplexer redis = ConnectionMultiplexer.Connect(host); //设置数据对象 //取得订阅对象 ISubscriber sub = redis.GetSubscriber(); //设置订阅事件 sub.Subscribe("c1", new Action<RedisChannel, RedisValue>(GetMessage));Console.Read();
Console.ReadLine(); } /// <summary> /// 获取消息 /// </summary> /// <param name="channel"></param> /// <param name="message"></param> static void GetMessage(RedisChannel channel, RedisValue message) { Console.WriteLine(channel); Console.WriteLine(message); }