RedisRepository封装—Redis发布订阅以及StackExchange.Redis中的使用
2016-08-31 21:50
537 查看
本文版权归博客园和作者本人吴双共同所有,转载请注明本Redis系列分享地址。http://www.cnblogs.com/tdws/tag/NoSql/
Redis Pub/Sub模式 基本介绍
Redis发布订阅—Pub/Sub模式或者说是观察者模式。我想大家即使没有使用过,也已经耳熟能详了。
先简单举例说明下应用场景,在场景中我们可以分析到其优势在哪。
比如你的线上应用应用,你想设置一个日志报警系统,当应用出现异常的时候,立马发送通知给你,可能是短信的形式,也可能是邮件的形式。当然如果只将报警通知给你一个人,实现起来很简单,在报警系统中将你的手机号和短信写死在程序中。但是如果你的项目庞大,每个模块有各自的负责人,并且负责人也经常会变更,那么咱们就不能总修改代码了吧?
或者说你的个人博客可以让读者订阅,读者这么多,咱们根本控制不过来呀。
现在发布订阅模式,就可以解决你的问题。在某一点发生改变的时候,其他客户端立即得到通知。也可以说订阅服务器得到应用发布消息,由服务器立即通知给你手中的客户端。这样的好处就是一种松耦合的模式,你不再需要修改发布端和订阅端的任何代码,你只要提供好发布和订阅的操作接口,今后调用就可以了。
首先看一下Redis在控制台中的发布订阅操作。
我开启两个redis命令客户端对相同的一个redis服务进行操作。
首先我们在第一个客户端我们对message01进行订阅,channel名称是我们自定义的,订阅哪个就是哪个。
其次,我们在第二个客户端对message01这个channel进行发布消息。返回值表示有几个客户端订阅。
发布消息后,订阅的客户端立即受收到消息。
StackExchange.Redis操作发布订阅
毕竟我们不可能只将其用在Redis命令控制台哈,最后来看一下在.NET中的使用。我们依然借助StackExchange.
基础配置,本系列第一篇分享已经包含。还记得静态构造函数中,下面这段代码吗?
配置中,定义了使用并行的方式来执行命令,大大提高了效率(在你无所谓消息传递的顺序时,可以这样使用)。
在接口中定义如下方法:
实现如下:
客户端测试,我将建立一个ConsoleApp和一个Winform程序,并在其中定义两个按钮。代码如下:
在ConsoleApp中我们作为订阅
在Winform程序中进行发布
将两个应用运行起来,操作以及结果如下:
下面操作两个按钮,得到结果。
订阅成功。
如果我的点滴分享,对您能有一点帮助,欢迎点赞支持,也欢迎大牛们持续关注和给予指导建议。
Redis Pub/Sub模式 基本介绍
Redis发布订阅—Pub/Sub模式或者说是观察者模式。我想大家即使没有使用过,也已经耳熟能详了。
先简单举例说明下应用场景,在场景中我们可以分析到其优势在哪。
比如你的线上应用应用,你想设置一个日志报警系统,当应用出现异常的时候,立马发送通知给你,可能是短信的形式,也可能是邮件的形式。当然如果只将报警通知给你一个人,实现起来很简单,在报警系统中将你的手机号和短信写死在程序中。但是如果你的项目庞大,每个模块有各自的负责人,并且负责人也经常会变更,那么咱们就不能总修改代码了吧?
或者说你的个人博客可以让读者订阅,读者这么多,咱们根本控制不过来呀。
现在发布订阅模式,就可以解决你的问题。在某一点发生改变的时候,其他客户端立即得到通知。也可以说订阅服务器得到应用发布消息,由服务器立即通知给你手中的客户端。这样的好处就是一种松耦合的模式,你不再需要修改发布端和订阅端的任何代码,你只要提供好发布和订阅的操作接口,今后调用就可以了。
首先看一下Redis在控制台中的发布订阅操作。
我开启两个redis命令客户端对相同的一个redis服务进行操作。
首先我们在第一个客户端我们对message01进行订阅,channel名称是我们自定义的,订阅哪个就是哪个。
其次,我们在第二个客户端对message01这个channel进行发布消息。返回值表示有几个客户端订阅。
发布消息后,订阅的客户端立即受收到消息。
StackExchange.Redis操作发布订阅
毕竟我们不可能只将其用在Redis命令控制台哈,最后来看一下在.NET中的使用。我们依然借助StackExchange.
基础配置,本系列第一篇分享已经包含。还记得静态构造函数中,下面这段代码吗?
_redis.PreserveAsyncOrder = RedisClientConfigurations.PreserveAsyncOrder;//并行
配置中,定义了使用并行的方式来执行命令,大大提高了效率(在你无所谓消息传递的顺序时,可以这样使用)。
在接口中定义如下方法:
#region Redis发布订阅 /// <summary> /// Redis发布订阅 订阅 /// </summary> /// <param name="subChannel"></param> void RedisSub(string subChannel); /// <summary> /// Redis发布订阅 发布 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="channel"></param> /// <param name="msg"></param> /// <returns></returns> long RedisPub<T>(string channel, T msg); /// <summary> /// Redis发布订阅 取消订阅 /// </summary> /// <param name="channel"></param> void Unsubscribe(string channel); /// <summary> /// Redis发布订阅 取消全部订阅 /// </summary> void UnsubscribeAll(); #endregion
实现如下:
#region Redis发布订阅 /// <summary> /// Redis发布订阅 订阅 /// </summary> /// <param name="subChannel"></param> public void RedisSub(string subChannel) { sub.Subscribe(subChannel, (channel, message) => { Console.WriteLine((string)message); }); } /// <summary> /// Redis发布订阅 发布 /// </summary> /// <typeparam name="T"></typeparam> /// <param name="channel"></param> /// <param name="msg"></param> /// <returns></returns> public long RedisPub<T>(string channel, T msg) { return sub.Publish(channel, SerializeContent(msg)); } /// <summary> /// Redis发布订阅 取消订阅 /// </summary> /// <param name="channel"></param> public void Unsubscribe(string channel) { sub.Unsubscribe(channel); } /// <summary> /// Redis发布订阅 取消全部订阅 /// </summary> public void UnsubscribeAll() { sub.UnsubscribeAll(); } #endregion
客户端测试,我将建立一个ConsoleApp和一个Winform程序,并在其中定义两个按钮。代码如下:
在ConsoleApp中我们作为订阅
static void Main(string[] args) { IRedisClient client = new RedisClient(); client.RedisSub("myFirstChannel"); client.RedisSub("mySecondChannel"); }
在Winform程序中进行发布
IRedisClient client = new RedisClient(); private void button1_Click(object sender, EventArgs e) { client.RedisPub("myFirstChannel", "first"); } private void button2_Click(object sender, EventArgs e) { client.RedisPub("mySecondChannel", "second"); }
将两个应用运行起来,操作以及结果如下:
下面操作两个按钮,得到结果。
订阅成功。
如果我的点滴分享,对您能有一点帮助,欢迎点赞支持,也欢迎大牛们持续关注和给予指导建议。
相关文章推荐
- Redis五大类型操作使用以及订阅发布功能
- Redis中的简单事物以及消息订阅发布
- Spring Boot使用Redis进行消息的发布订阅
- 使用Spring Data Redis 实现订阅/发布
- .net core如何使用Redis发布订阅
- 使用jedis操作redis之消息的发布和订阅
- StackExchange.Redis 使用-发布订阅 (二)
- Redis发布订阅使用方法
- 使用redis实现消息发布订阅
- redis命令详解与使用场景举例——Pub与Sub(发布订阅)
- .net core 使用Redis的发布订阅
- Redis订阅&发布以及python代码实现
- 使用redis的发布订阅模式实现消息队列
- 使用redis快速搭建发布-订阅系统(python3x)
- Redis发布与订阅以及日常存取源码分享
- 使用Redis构建消息队列和发布订阅系统
- StackExchange.Redis 使用-发布订阅 (二)
- .NET平台下Redis使用(六)【ServiceStack.Redis发布、订阅服务示例】
- 使用nodejs+socket.io+redis订阅发布完成竞拍的过程
- java使用redis发布和订阅消息