前言
发布订阅在设计模式中也可以说是观察者模式,针对这个模式是处理对象间一对多的依赖关系的,当一个对象发生变化,其它依赖他的对象都要得到通知并更新。
然而它也有自己的缺点,就是当主题发生一系列的变化时,观察者都要做批量的更新,如果这样的更新成本很高,那么解决方法就是根据种类需求通知,而不能盲目的通知所有的观察者。
那针对这个缺点,一般的情况下,你没有需求谁订阅一个跟自己无关的消息推送呢?这也正好说明推送的消息需要整理而不能一窝蜂的什么消息都往一个通道里面抛,要分而治之,合理的设计发布通道的用途,也合理的订阅通道。
那么如此一来,升级到系统项目级别,他别给我们又带来啦,莫大的好处,便是:剥离系统耦合,减少单线功能的依赖关系,又正迎合啦高内聚,松耦合的系统架构设计。
Redis中的发布/订阅功能
这一节参考官方文档:https://redis.io/topics/pubsub
首先我准备啦1个redis服务,3个客户端,如下图所示:
然后打开官方文档,首先可以看到以下6个命令,对,就只有这6个命令,只要你能掌握理解,发散思维灵活运用。吐纳,吐纳,那么道于此,生一,生二、生三,生万物,根本不在话下!!C,C,C,WC, 小伙,以后拯救世界就看你啦。
下面我们使用这几个命令,做一个演示,便于你理解。
1、2个客户端订阅order.create通道消息,如下:
2、最后一个客户端发布往order.create通道发布消息。如下:
3、你会立马发现订阅此通道的另外2个客户端有信息输出出来,如下:
简单不,一个发布订阅的基础功能以及完事啦。
那如果你对其他一些发布订阅管理系统比较了解的话,你立马会想到一个功能,类似rabbitmq中的topic类型的匹配功能。那redis中有吗,就这6个命令,答案是有的。使用的命令为psubscribe。
127.0.0.1:6379> psubscribe * ---订阅所有通道 127.0.0.1:6379> psubscribe order.* ---订阅通道名称以order.开头的所有通道消息
那又如何取消订阅过的通道呢?
127.0.0.1:6379> unsubscribe order.create ---取消订阅 127.0.0.1:6379> punsubscribe order.* ---取消订阅通道名称以order.开头的所有通道消息
如何查看订阅信息呢?
127.0.0.1:6379> pubsub channels ---查看当前服务器订阅的所有通道 127.0.0.1:6379> pubsub channels order.* ---查看订阅通道名称以order.开头的所有通道 127.0.0.1:6379> pubsub numsub order.create user ---查看订阅order.create 和user 通道的订阅者数量,支持查询多个通道
呀,到此为止,6个命令已经用完啦。就是这么任性,对,你潜心修炼10多分钟已经学会啦redis中最上层的发布订阅技能。你可以出关,打败天下无敌手啦。
StackExchange.Redis实现redis中的发布订阅功能
那这一节呢,我也实在说不出怎么讲更合理点,我就上一个示例,你自己把代码拷贝去,玩玩吧。上代码。
static void Main(string[] args) { Console.WriteLine("请输入发布订阅类型"); var type = Console.ReadLine(); if (type == "publish") { while (true) { Console.WriteLine("请输入要发布向哪个通道?"); var channel = Console.ReadLine(); Console.WriteLine("请输入要发布的消息内容."); var message = Console.ReadLine(); sub.Publish(channel, message); } } else { Console.WriteLine("请输入您要订阅哪个通道的信息?"); var channelKey = Console.ReadLine(); sub.Subscribe(channelKey, (channel, message) => { Console.WriteLine("接受到发布的内容为:" + message); }); Console.WriteLine("您订阅的通道为:<< "+ channelKey + " ! 一切就绪,等待发布消息!勿动,一动就没啦!!"); Console.ReadKey(); } }
运行起来几个实例,来玩一玩。如下,5个,1个发布信息,4个订阅信息,其中2个订阅zhanglonghao通道,2个订阅bokeyuan通道。
第一次我发布消息到zhanglonghao通道,发布的消息为:hello shuaige !!如下:
可以看出只有订阅zhanglonghao通道的才接受到啦消息。
那再往bokeyuan通道里面发送,hello bokeyuan !
到此为止,自己玩去吧。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 雨林唱片《赏》新曲+精选集SACD版[ISO][2.3G]
- 罗大佑与OK男女合唱团.1995-再会吧!素兰【音乐工厂】【WAV+CUE】
- 草蜢.1993-宝贝对不起(国)【宝丽金】【WAV+CUE】
- 杨培安.2009-抒·情(EP)【擎天娱乐】【WAV+CUE】
- 周慧敏《EndlessDream》[WAV+CUE]
- 彭芳《纯色角3》2007[WAV+CUE]
- 江志丰2008-今生为你[豪记][WAV+CUE]
- 罗大佑1994《恋曲2000》音乐工厂[WAV+CUE][1G]
- 群星《一首歌一个故事》赵英俊某些作品重唱企划[FLAC分轨][1G]
- 群星《网易云英文歌曲播放量TOP100》[MP3][1G]
- 方大同.2024-梦想家TheDreamer【赋音乐】【FLAC分轨】
- 李慧珍.2007-爱死了【华谊兄弟】【WAV+CUE】
- 王大文.2019-国际太空站【环球】【FLAC分轨】
- 群星《2022超好听的十倍音质网络歌曲(163)》U盘音乐[WAV分轨][1.1G]
- 童丽《啼笑姻缘》头版限量编号24K金碟[低速原抓WAV+CUE][1.1G]