博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RedisRepository封装—Redis发布订阅以及StackExchange.Redis中的使用
阅读量:5858 次
发布时间:2019-06-19

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

本文版权归博客园和作者本人吴双共同所有,转载请注明本Redis系列分享地址。

Redis Pub/Sub模式 基本介绍

Redis发布订阅—Pub/Sub模式或者说是观察者模式。我想大家即使没有使用过,也已经耳熟能详了。

先简单举例说明下应用场景,在场景中我们可以分析到其优势在哪。

比如你的线上应用应用,你想设置一个日志报警系统,当应用出现异常的时候,立马发送通知给你,可能是短信的形式,也可能是邮件的形式。当然如果只将报警通知给你一个人,实现起来很简单,在报警系统中将你的手机号和短信写死在程序中。但是如果你的项目庞大,每个模块有各自的负责人,并且负责人也经常会变更,那么咱们就不能总修改代码了吧?

或者说你的个人博客可以让读者订阅,读者这么多,咱们根本控制不过来呀。

现在发布订阅模式,就可以解决你的问题。在某一点发生改变的时候,其他客户端立即得到通知。也可以说订阅服务器得到应用发布消息,由服务器立即通知给你手中的客户端。这样的好处就是一种松耦合的模式,你不再需要修改发布端和订阅端的任何代码,你只要提供好发布和订阅的操作接口,今后调用就可以了。

首先看一下Redis在控制台中的发布订阅操作。

我开启两个redis命令客户端对相同的一个redis服务进行操作。

首先我们在第一个客户端我们对message01进行订阅,channel名称是我们自定义的,订阅哪个就是哪个。

其次,我们在第二个客户端对message01这个channel进行发布消息。返回值表示有几个客户端订阅。

发布消息后,订阅的客户端立即受收到消息。

StackExchange.Redis操作发布订阅

毕竟我们不可能只将其用在Redis命令控制台哈,最后来看一下在.NET中的使用。我们依然借助StackExchange.

基础配置,本系列第一篇分享已经包含。还记得静态构造函数中,下面这段代码吗?

1 _redis.PreserveAsyncOrder = RedisClientConfigurations.PreserveAsyncOrder;//并行

配置中,定义了使用并行的方式来执行命令,大大提高了效率(在你无所谓消息传递的顺序时,可以这样使用)。

在接口中定义如下方法:

1  #region Redis发布订阅 2         ///  3         /// Redis发布订阅  订阅 4         ///  5         ///  6         void RedisSub(string subChannel); 7         ///  8         /// Redis发布订阅  发布 9         /// 10         /// 
11 /// 12 /// 13 ///
14 long RedisPub
(string channel, T msg);15 ///
16 /// Redis发布订阅 取消订阅17 /// 18 ///
19 void Unsubscribe(string channel);20 ///
21 /// Redis发布订阅 取消全部订阅22 /// 23 void UnsubscribeAll();24 25 #endregion

实现如下:

1  #region Redis发布订阅 2         ///  3         /// Redis发布订阅  订阅 4         ///  5         ///  6         public void RedisSub(string subChannel) 7         { 8             sub.Subscribe(subChannel, (channel, message) => 9             {10                 Console.WriteLine((string)message);11             });12         }13         /// 14         /// Redis发布订阅  发布15         /// 16         /// 
17 /// 18 /// 19 ///
20 public long RedisPub
(string channel, T msg)21 {22 23 return sub.Publish(channel, SerializeContent(msg));24 }25 ///
26 /// Redis发布订阅 取消订阅27 /// 28 ///
29 public void Unsubscribe(string channel)30 {31 sub.Unsubscribe(channel);32 }33 ///
34 /// Redis发布订阅 取消全部订阅35 /// 36 public void UnsubscribeAll()37 {38 sub.UnsubscribeAll();39 }40 #endregion

客户端测试,我将建立一个ConsoleApp和一个Winform程序,并在其中定义两个按钮。代码如下:

在ConsoleApp中我们作为订阅

1      static void Main(string[] args)2         {3             IRedisClient client = new RedisClient();4 5             client.RedisSub("myFirstChannel");6             client.RedisSub("mySecondChannel");7          }

在Winform程序中进行发布

1  IRedisClient client = new RedisClient(); 2         private void button1_Click(object sender, EventArgs e) 3         { 4             client.RedisPub("myFirstChannel", "first"); 5         } 6  7         private void button2_Click(object sender, EventArgs e) 8         { 9             client.RedisPub("mySecondChannel", "second");10         }

将两个应用运行起来,操作以及结果如下:

下面操作两个按钮,得到结果。

 

订阅成功。

 

如果我的点滴分享,对您能有一点帮助,欢迎点赞支持,也欢迎大牛们持续关注和给予指导建议。

 

你可能感兴趣的文章
spring里头各种获取ApplicationContext的方法
查看>>
编程开发之--Oracle数据库--存储过程使用动态参数绑定(3)
查看>>
移动端的复杂手势
查看>>
SDWebImage在UITableView部分CELL图片无法加载的解决办法
查看>>
个人作业3--------个人总结(Alpha版本)
查看>>
敏捷开发之我所见
查看>>
Linux系统启动过程
查看>>
sort实现vector的多级排序
查看>>
TEST
查看>>
2、Oracle内存结构
查看>>
gulp 用法 小结
查看>>
GCC
查看>>
Oracle 好书 02 ( 安装oracle 10g软件及创建数据库 )
查看>>
CDN技术原理
查看>>
对Navicat Mac 模型进行偏好设置的教程
查看>>
白盒测试:为什么要做白盒测试
查看>>
HPU1460: 杨八方的表面兄弟
查看>>
第八届蓝桥杯第二题:等差素数列
查看>>
新浪微博信息站外同步的完整实现-转自 superfeeling
查看>>
Django注册页面配置设计
查看>>