java 阅发布模式_redis发布订阅模式

一 前言

虽然有消息队列,我们还是要了解一下redis发布订阅模式哟!!!!!

二发布订阅模式

651969fa2abdbeccf20e994f3bba29a0.pngPUBLISH 命令向通道发送信息,此客户端称为publisher 发布者;

SUBSCRIBE 向命令通道订阅信息,此客户端称为subscriber 订阅者;

redis 中 发布订阅模块的名字叫着 PubSub,也就是 PublisherSubscriber;

一个发布者向一个通道发送消息,订阅者可以向多个通道订阅消息;当发布者向通道发布消息后,如果有订阅者订阅该通道,订阅者就会收到消息;这有点像电台,我收听了一个电台的频道,当频道发送消息后,我就能收到消息;

三PUBSub模块命令subscribe: 订阅一个或者多个频道;

unsubscribe: 退订一个或者多个频道;

publish: 向通道发送消息;

psubscribe: 订阅给定模式相匹配的所有频道;

punsubscribe: 退订 给定模式所有的频道,若未指定模式,退订所有频道;

具体的命令使用方式 可以使用 help 命令 ;示例如下:

help subscribe

四客户端实现

通过指令SUBSCRIBE订阅一个频道,如果频道不存在时则新建一个频道;此时此客户端就是订阅者127.0.0.1:6379> subscribe zszxz

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "zszxz"

3) (integer) 1

通过指令publish向通道发送一个消息;此时客户端就是发布者127.0.0.1:6379> publish zszxz "l miss you"

(integer) 1

127.0.0.1:6379>

我们再看看 客户端就收到消息了127.0.0.1:6379> subscribe zszxz

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "zszxz"

3) (integer) 1

1) "message"

2) "zszxz"

3) "l miss you"

五java 实现

定义2个订阅者用于订阅频道的消息,在使用jedis 时 需要 继承 JedisPubSub 类, 并重写 onMessage 方法; 订阅者可以在该方法里面进行消息的业务逻辑处理;

订阅者 1/\*\*

\* @Author lsc

\*

订阅者1号

\*/

@Component

public class Sub1 extends JedisPubSub {

@Override

public void onMessage(String channel, String message) {

System.out.println("sub1 channel is :"+ channel+ " mesage is :"+message);

}

}

订阅者2/\*\*

\* @Author lsc

\*

订阅者2号

\*/

@Component

public class Sub2 extends JedisPubSub {

@Override

public void onMessage(String channel, String message) {

System.out.println("sub2 channel is :"+ channel+ " mesage is :"+message);

}

}

发布者/\*\*

\* @Author lsc

\*

\*/

@Component

public class Pub {

public void publishMessage(Jedis jedis, String channel, String msg) {

jedis.publish(channel,msg);

}

}

测试类、

注意redis 的 发布订阅模式 是阻塞模式 ,一个订阅者需要 重新起一个线程;@Autowired

Pub pub;

@Autowired

JedisUtil jedisUtil;

@Autowired

Sub1 sub1;

@Autowired

Sub1 sub2;

@Test

public void test(){

new Thread(()\-> {

while (true){

jedisUtil.getJedis().subscribe(sub1,"zszxz");

try {

TimeUnit.SECONDS.sleep(1);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

//jedisUtil.getJedis().subscribe(sub2,"zszxz");

}).start();

pub.publishMessage(jedisUtil.getJedis(),"zszxz","l miss you");

}

六 缺点PubSub 的生产者来一个消息会直接传递给消费者。如果没有消费者,消息会直接丢弃。如果有多个消费者,一个消费者突然挂掉,生产者会继续发送消息,另外的消费者可以持续收到消息。但是挂掉的消费者重新连上后,断连期间的消息会彻底丢失;

如果 Redis 停机重启,PubSub 的消息是不会持久化

求关注

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/555252.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

把实体 转为json 数据格式---jackson 的详细用法_Jackson快速入门

首先介绍三个注解: JsonAutoDetect (method/field):作用于方法或字段,用来表明,当生成json的时候忽略有该annotation的方法或字段 JsonIgnore 过滤不需要转成json的属性 JsonIgnoreProperties 主要用于过滤掉一些不需要的属性 以上三个注…

python 猴子补丁_python面试题精讲——monkey patch(猴子补丁)

前言本次依然是选自python面试题系列,将一个比较偏的概念,可能很多人没怎么听说过——猴子补丁,其实所讲的内容很简单,它得益于python灵活的语法、一切皆对象的思想,一起来看看看看吧!目录一、什么是monkey…

java 类的加载顺序_Java 中类的加载顺序

这其实是去年校招时我遇到的一道阿里巴巴的笔试题(承认有点久远了-。-),嗯,如果我没记错的话,当时是作为Java方向的一道选做大题。当然题意没有这么直白,题目只要求你写出程序运行后所有System.out.println的输出结果,…

Jackson转换json大写_关于jackson转化json的原理_jackson序列化和反序列化Json

背景 web工程中,数据交互是不可避免的,相比xml,json是现在流行的数据交互。 在调试接口中,发现返回字段的大小写不是我所期望的,原本应该返回的nNum字段变成了nnum,这样就导致和前端约定的有出入了。 ja…

groovy+mysql数据库_使用Groovy连接到MySQL

我正在尝试使用MAC OS 10.10.5 Yosemite上的以下Groovy代码连接到MySQL数据库import groovy.sql.Sqltry{def dbURL jdbc:mysql://localhost:3306/sakiladef dbUserName rootdef dbPassword Orange27def dbDriver com.mysql.jdbc.Driverlog.info(Good)def db Sql.newInstan…

svn利用TortoiseSVN忽略文件或文件夹(目录)

忽略已经版本控制的文件 如果你不小心添加了一些应该被忽略的文件,你如何将它们从版本控制中去除而不会丢失它们?或许你有自己的IDE配置文件,不是项目的一部分,但将会花费很多时间使之按照自己的方式工作。 如果你还没有提交&am…

java打印两个小人_[原创]Java画小人与阶梯问题的解答

package test;/**#Python源代码:#By:Cat73 QQ 1901803382#2014年7月22日19:33:12#画图函数 width:台阶的宽度(至少为4) hight:台阶的高度(至少为4) count:台阶的数量(至少为3)def paint(width, hight, count):for i in range(1, count):other(width, hight, count, i)#画出最后…

SpringMVC 参数绑定详解

概述 记得之前跟前端同事联调接口的时候,后端SpringMVC需要接收数组类型的参数,然后跟前端说需要传数组类型过来。后来前端童鞋传了数组,但是后端接收不成功,联调失败。那时候由于时间关系没有仔细研究这块,当时想了个…

java httpcomponents_java – 如何使用Apache httpcomponents从NHttpRequ...

我正在使用Apache httpcomponents实现一个彗星式(延迟响应)http服务器.我的代码与http://hc.apache.org/httpcomponents-core-ga/examples.html的“基本非阻塞HTTP服务器”示例非常相似我使用DefaultServerIOEventDispatch和DefaultListeningIOReactor来分派请求,就像在示例代码…

java servlet是单例吗_关于java:为什么apache servlet是单例?

本问题已经有最佳答案,请猛点这里访问。HttpServletRequest request;HttpServletResponse response;public void doGet(HttpServletRequest request , HttpServlet response){this.request request;this.response response;}如果此servlet一次收到多个请求会发生什…

OkHttp的作用_为什么要使用OkHttp?(笔记)

OkHttp的作用 OkHttp is an HTTP client。 如果是HTTP的方式想得到数据,就需要我们在页面上输入网址,如果网址没有问题,就有可能返回对应的String字符串,如果这个地址是返回字符串的话。 OkHttp是在idea代码中,通过调…

java 连接远程服务器_java实现连接远程服务器并执行命令的基本原理

一、所需jar包需要借助Ganymed SSH的jar包: ganymed-ssh2-build210.jar二、实现原理Ganymed SSH-2 java在整个访问过程中担当SSH的客户端,由于Linux系统自带SSH服务,所以可以直接访问Linux系统并执行相关命令,而 Windows系统则需要首先安装S…

SpringMVC接收基本类型和包装类型

先看一个示例: 注意这两个参数都没有加RequestParam注解。 测试: 直接报错。即没有加RequestParam注解,基本数据类型参数是必填的。 再测试: 直接返回null,也就是说包装类型参数,没有加RequestParam注解&…

SpringMVC 【参数绑定详讲、默认支持参数类型、自定义参数绑定、RequestParam 注解】

SpringMVC 第四篇【参数绑定详讲、默认支持参数类型、自定义参数绑定、RequestParam 注解】 参数绑定 我们在 Controller 使用方法参数接收值,就是把 web 端的值给接收到 Controller 中处理,这个过程就叫做参数绑定… 默认支持的参数类型 从上面的用…

MySQL保留字不能作为字段名使用_Table字段不能设为关键字range,range在mysql中是分区,是mysql的关键字

mysql 中Table字段不能设为关键字range,range在mysql中是分区,是mysql的关键字 在设计MySQL字段的时候,无意中使用InOut这个名称作为字段名称,结果前端提交后就是没有写入数据库!但后端没有任何提示,跟踪mySQL日志&…

java+的数组分割符_Java:使用分隔符连接基元数组

小编典典这是我想出的。有几种方法可以执行此操作,它们取决于您使用的工具。使用StringUtils和ArrayUtils来自CommonLang:int[] arr new int[] {1, 2, 3, 4, 5, 6, 7};String result StringUtils.join(ArrayUtils.toObject(arr), " - ");您不…

MySQL中 IS NULL、IS NOT NULL、不等于, 能用上索引吗?

MySQL的WHERE子句中包含 IS NULL、IS NOT NULL、! 这些条件时便不能使用索引查询,只能使用全表扫描。 告诉大家结论: MySQL中决定使不使用某个索引执行查询的依据就是成本够不够小,如果null值很多,还是会用到索引的。 自己做了个…

Java EE 企业网站_基于jsp的企业网站系统-JavaEE实现企业网站系统 - java项目源码...

基于jspservletpojomysql实现一个javaee/javaweb的企业网站系统, 该项目可用各类java课程设计大作业中, 企业网站系统的系统架构分为前后台两部分, 最终实现在线上进行企业网站系统各项功能,实现了诸如用户管理, 登录注册, 权限管理等功能, 并实现对各类企业网站系统相关的实体…

MySQL创建联合索引,字段的先后顺序,对查询的影响分析

文章目录前言最左匹配原则为什么会有最左前缀呢?联合索引的存储结构联合索引字段的先后顺序b树可以存储的数据条数总结前言 ​ 对于联合索引我们知道,在使用的时候有一个最左前缀的原则,除了这些呢,比如字段放置的位置&#xff0…

php oracle 操作 sql语句中能不能添加数组_如何在PHP中使用Oracle数据库_php

在php3.0以上版本中,php内置了几乎目前所有的数据库处理函数,包括oracle;在本文中我们通过一个实例来介绍了如何使用这些函数来操作Oracle数据库。PHP提供了2大类API(应用程序接口)来操作Oracle数据库。一个是标准的Oracle处理函数(ORA) 另一个是Oracle …