Java实现Redis发布订阅
因为项目需求,要实现redis的发布订阅功能,百度了下,然后把自己的经验总结了下
具体的jedis配置就不再说了,可以看上一篇内容
简介
Redis提供了基于“发布/订阅”模式的消息机制,此种模式下,消息发布者和订阅者不进行直接通信,发布者客户端向指定的频道(channel)发布消息,订阅该频道的每个客户端都可以收到该消息(频道没有”创建“的概念,可以直接订阅、亦可直接发布消息)。
下图展示了频道 channel1 , 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系:
当有新消息通过 PUBLISH 命令发送给频道 channel1 时, 这个消息就会被发送给订阅它的三个客户端:
实例
以下实例演示了发布订阅是如何工作的。首先在我们封装的JedisUtils中加入发布和订阅操作的方法:
/** * 发布一个消息 * * @param channel * @param message */ public void publishMsg(String channel, String message) { try { jedis.publish(channel, message); } catch (Exception e) { } }
参数channel是消息的频道,message是消息的内容。在Junit测试或者其他的地方,使用工具类的此方法即可发布一个消息。
接收消息代码稍微复杂一些。首先定义一个类继承JedisPubSub,然后实现其中未实现的方法,最后在工具类JedisUtils中定义一个操作的方法即可。代码如下:
public class RedisMsgSubListener extends JedisPubSub { // 取得订阅的消息后的处理 public void onMessage(String channel, String message) { System.out.println(channel + "=" + message); } // 初始化订阅时候的处理 public void onSubscribe(String channel, int subscribedChannels) { // System.out.println(channel + "=" + subscribedChannels); } // 取消订阅时候的处理 public void onUnsubscribe(String channel, int subscribedChannels) { // System.out.println(channel + "=" + subscribedChannels); } // 初始化按表达式的方式订阅时候的处理 public void onPSubscribe(String pattern, int subscribedChannels) { // System.out.println(pattern + "=" + subscribedChannels); } // 取消按表达式的方式订阅时候的处理 public void onPUnsubscribe(String pattern, int subscribedChannels) { // System.out.println(pattern + "=" + subscribedChannels); } // 取得按表达式的方式订阅的消息后的处理 public void onPMessage(String pattern, String channel, String message) { System.out.println(pattern + "=" + channel + "=" + message); } }
在工具类JedisUtils中定义一个操作的方法
/** * 接收消息。在main方法调用后,会一直执行下去。当有发布对应消息时,就会在jedisPubSub中接收到! * * @param jedisPubSub * @param channels */ public void subscribeMsg(JedisPubSub jedisPubSub, String channels) { try { jedis.subscribe(jedisPubSub, channels); } catch (Exception e) { } }
下面写个方法测试下吧:
public class PubTest { JedisUtil4 jedisUtil; public void publishMsg(){ jedisUtil= JedisUtil4.getInstance(); jedisUtil.publishMsg("test","hello world!"); } public static void main(String[] args) { PubTest pubTest=new PubTest(); pubTest.publishMsg(); } } public class SubTest { JedisUtil4 jedisUtil; public void subscribeMsg(){ jedisUtil=JedisUtil4.getInstance(); RedisMsgSubListener pubsub = new RedisMsgSubListener(); jedisUtil.subscribeMsg(pubsub, "test"); } public static void main(String[] args) { new SubTest().subscribeMsg(); } }
建议测试时,分开方法进行测试。其中publishMsg()方法是用来测试发布消息的,subscribeMsg()是用来测试接收订阅消息的。这里只是使用了普通订阅,大家还可以使用模式订阅。执行subscribeMsg()方法后,客户端会一直开启着,不会关闭。另外,在其他的redis客户端中发布一条消息,控制台就会立刻输出该消息。
参考:
http://blog.csdn.net/abcd898989/article/details/51697596
http://www.runoob.com/redis/redis-pub-sub.html
https://my.oschina.net/u/1444945/blog/648797
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
线程中断以及线程中断引发的那些问题
什么是线程中断? 在我们的Java程序中其实有不止一条执行线程,只有当所有的线程都运行结束的时候,这个Java程序才算运行结束。 官方的话给你描述一下:当所有的非守护线程运行结束时,或者其中一个线程调用了System.exit()方法时,这个Java程序才能运行结束。 线程中断的应用场景 我们先来举一个例子,比如我们现在在下载一个500多M的大片,我们点击开始下载,那个这个时候就等于开启了一个线程去下载我们的文件,然而这个时候我们的网速不是很给力,几十KB的在这跑,作为一个年轻人我是等不了了,我不下来,那么这个时候我们第一个操作就是结束掉这个下载文件的操作,其实更接近程序的来说,这个时候我们就需要把这个线程给中断了。 我们接下来写一下这个下载的代码,看一下如何中断一个线程,这里我已经默认你们已经掌握了如何创建一个线程了,这段程序我们模拟下载,最开始获取系统时间,然后进入循环每次获取系统时间,如果时间超过10秒我们就中断线程,不在继续下载,下载速度时每秒1M: public void run() { int number = 0; // 记录程序开始的时间 Long start = Sy...
- 下一篇
Python Flask学习知识点(二)
使用Flask写简单的API 所有API都一样,不限于编程语言,API的难点在于路由(URL)的设计,能否精准的找到资源,而不是在于如何用技术实现。 在上一篇Python Flask学习知识点(一)文章中,记录了如何在试图函数中返回数据。上篇文章说到Flask返回的本质是字符串,通过content-type来控制返回的字符串转换为需要值,那么我们在写API的时候,API一般返回的都是JSON格式的数据,所以在视图函数中要指定content-type为JSON。 @app.route() def search(): result = {"key1": "a", "key2": "b"} return json.dumps(result), 200, {"content-type": "application/json"} 解释上图代码片段: 我们一般通过视图函数中做处理后拿到数据类型为python内置数据类型dict,而Flask要求,返回的结果必须是字符串,所以我们用json.dumps(result)做处理后再返回。 后边指定返回状态码200,和,返回的content-type为JS...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS6,CentOS7官方镜像安装Oracle11G
- CentOS关闭SELinux安全模块
- CentOS7设置SWAP分区,小内存服务器的救世主
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- Windows10,CentOS7,CentOS8安装Nodejs环境
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- CentOS7,CentOS8安装Elasticsearch6.8.6
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长