第3章 订阅及发布

王朝学院·作者佚名  2016-08-28
窄屏简体版  字體: 小  |  中  |  大  |  超大  

第1章 安装在.NET平台使用Redis需要做如下准备工作:

创建一个新的Visual Studio应用或者打开一个已经存在的Visual Studio应用。

打开NuGet程序包

[flash=500,400]http://s1.knowsky.com/20160211/3rqeadiwodh22.png[/flash]

搜索并添加StackExchange.Redis程序包

[flash=500,400]http://s1.knowsky.com/20160211/eqflxf5vosn23.png[/flash]

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

}

 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
© 2005- 王朝網路 版權所有 導航