介绍//创建连接
时间=using (ConnectionMultiplexer redis ConnectionMultiplexer.Connect (“127.0.0.1:6379"))
{
ISubscriber 才能;sub =, redis.GetSubscriber ();//才能订阅名为,messages 的通道
sub.Subscribe才能(“messages",,(频道,消息),=祝辞,{
,,,//输出收到的消息
,,,Console.WriteLine(“美元[{DateTime.Now: HH: mm: ss}),{消息}“);
,,});
Console.WriteLine才能(“已订阅,messages");
Console.ReadKey才能();
} //创建连接
时间=using (ConnectionMultiplexer redis ConnectionMultiplexer.Connect (“127.0.0.1:6379"))
{
ISubscriber 才能;sub =, redis.GetSubscriber ();
Console.WriteLine才能(“请输入任意字符,输入出口退出“);
string 才能;输入;
,做的
{才能
,,,input =, Console.ReadLine ();
,,,sub.Publish (“messages",,输入);
,,},while (input !=,“exit");
}
这篇文章主要介绍了。net核心如何使用复述,发布订阅方法,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获、下面让小编带着大家一起了解一下。
<强>复述,发布订阅
复述,发布订阅(pub/sub)是一种消息通信模式:发送者(酒吧)发送消息,订阅者(子)接收消息。
复述,客户端可以订阅任意数量的通道。
下图展示了频道channel1,以及订阅这个频道的三个客户端——client2 client5和client1之间的关系:
当有新消息通过发布命令发送给频道channel1时,这个消息就会被发送给订阅它的三个客户端:
<强>使用复述,命令
首先,通过订阅redismessage命令使两个客户端订阅redismessage通道:
然后再打开一个复述,客户端,使用命令发布redismessage“消息内容“发布消息
<强>使用。net核心实现
这里我选择的连接驱动为课件。复述,这里需要注意的是ServiceStack.Redis连接驱动已经逐渐商业化,4.0及以上版本都具有限制,所以选择的免费且好用的课件。复述,使用nuget安装即可。
建立订阅客户端
建立发布客户端
感谢你能够认真阅读完这篇文章,希望小编分享的“。net核心如何使用复述,发布订阅方法”这篇文章对大家有帮助,同时也希望大家多多支持,关注行业资讯频道,更多相关知识等着你来学习!
