博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Redis的发布订阅及.NET客户端实现
阅读量:5924 次
发布时间:2019-06-19

本文共 2659 字,大约阅读时间需要 8 分钟。

原文:

序言

发布订阅在设计模式中也可以说是观察者模式,针对这个模式是处理对象间一对多的依赖关系的,当一个对象发生变化,其它依赖他的对象都要得到通知并更新。

然而它也有自己的缺点,就是当主题发生一系列的变化时,观察者都要做批量的更新,如果这样的更新成本很高,那么解决方法就是根据种类需求通知,而不能盲目的通知所有的观察者。

那针对这个缺点,一般的情况下,你没有需求谁订阅一个跟自己无关的消息推送呢?这也正好说明推送的消息需要整理而不能一窝蜂的什么消息都往一个通道里面抛,要分而治之,合理的设计发布通道的用途,也合理的订阅通道。

那么如此一来,升级到系统项目级别,他别给我们又带来啦,莫大的好处,便是:剥离系统耦合,减少单线功能的依赖关系,又正迎合啦高内聚,松耦合的系统架构设计。

扯拉这么多,只当废话啦,因为我这一篇的序言里面也不知道写什么段子啦,就这样吧。

Redis中的发布/订阅功能

这一节参考官方文档:

首先我准备啦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 !

到此为止,自己玩去吧。

总结

接下来是大家最喜欢的总结内容啦,内容有二,如下:

1、希望能关注我其他的文章。

2、博客里面有没有很清楚的说明白,或者你有更好的方式,那么欢迎加入左上方的2个交流群,我们一起学习探讨。

转载地址:http://sxavx.baihongyu.com/

你可能感兴趣的文章
能源项目xml文件 -- app-context.xml
查看>>
P4 前端编译器p4c-bm、后端编译器bmv2命令安装 make error问题
查看>>
C#2.0 to 4.0
查看>>
mysql索引失效
查看>>
Windows下卸载软件时提示 等待先前的卸载完成? 终止 dllhost.exe 进程
查看>>
JAVA设计模式之门面模式(外观模式)
查看>>
java遇见的问题分析
查看>>
基于key/value+Hadoop HDFS 设计的存储系统的shell命令接口
查看>>
Log4Net的WebApplication使用
查看>>
路由器与交换机区别
查看>>
8-12 canvas专题-阶段练习一(上)
查看>>
keras系列︱Application中五款已训练模型、VGG16框架(Sequential式、Model式)解读(二)...
查看>>
Linux学习笔记之一————什么是Linux及其应用领域
查看>>
springcloud~Eureka实例搭建
查看>>
git工具 将源码clone到本地指定目录的三种方式
查看>>
dubbo源码解析-zookeeper创建节点
查看>>
【2018-11-15】中证1000指数的估值详情
查看>>
新的一年
查看>>
js数组去重,合集等操作
查看>>
BPM与Workflow的区别
查看>>