Redis实现发布订阅模式
2019-09-17 15:58
1751 查看
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/zzti_erlie/article/details/100740335
介绍
发布订阅(又称pub/sub)的特点是是订阅者(listener)负责订阅频道(channel),发送者(publisher)负责向频道发送二进制字符串消息。每当有消息被发送至给定频道时,频道的所有订阅者都会收到消息。
订阅者可以同时订阅多个频道,发送者可以再多个频道发送消息。
相关的命令如下:
命令 | 用例和描述 |
---|---|
PUBLISH | PUBLISH channel message,向给定频道发送消息 |
SUBSCRIBE | SUBSCRIBE channel [channel …],订阅给定的一个或多个频道 |
UNSUBSCRIBE | UNSUBSCRIBE [channel [channel …]],退订给定的一个或多个频道,如果执行时没有给定任何频道,那么退订所有频道 |
PSUBSCRIBE | PSUBSCRIBE pattern [pattern …],订阅与给定模式相匹配的所有频道 |
PUNSUBSCRIBE | PUNSUBSCRIBE [pattern [pattern …]],退订给定的模式,如果执行时没有给定任何模式,那么退订所有模式 |
PUBSUB | PUBSUB subcommand [argument [argument …]], |
PUBLISH,SUBSCRIBE ,UNSUBSCRIBE命令应该都比较好理解。
PSUBSCRIBE ,PUNSUBSCRIBE是用了类似正则表达式的方式
# it*匹配所有以it开头的频道,如it.news,it.blog PUNSUBSCRIBE it.*
命令演示
打开第一个客户端,订阅一个channel
SUBSCRIBE container
打开第二个客户端,往channel中发送消息
PUBLISH container msg1 PUBLISH container msg2
此时第一个客户端输出第二个客户端发送的文字
第一个客户端
127.0.0.1:6379> SUBSCRIBE containerReading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "container" 3) (integer) 1 1) "message" 2) "container" 3) "msg1" 1) "message" 2) "container" 3) "msg2"
第二个客户端
127.0.0.1:6379> PUBLISH container msg1 (integer) 1 127.0.0.1:6379> PUBLISH container msg2 (integer) 1 127.0.0.1:6379>
代码实现
JedisUtil工具类
public class JedisUtil { private static volatile JedisUtil jedisUtil; private JedisPool jedisPool = this.initConfig(); public JedisPool initConfig() { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxIdle(20); config.setMaxTotal(256); return new JedisPool(config,"127.0.0.1", 6379); } public Jedis getRedisClient() { return jedisPool.getResource(); } public static JedisUtil getInstance() { if (jedisUtil == null) { synchronized (JedisUtil.class) { if (jedisUtil == null) { jedisUtil = new JedisUtil(); 3ff7 } } } return jedisUtil; } }
发布者
public class Publisher { public void publishMsg(String channel, String msg) { Jedis jedis = JedisUtil.getInstance().getRedisClient(); jedis.publish(channel, msg); } }
订阅者
public class Listener extends JedisPubSub { @Override public void onMessage(String channel, String message) { // 在这里输出channel名字和message名字 System.out.println(channel + " " + message); } public void subscribe(String channel) { Jedis jedis = JedisUtil.getInstance().getRedisClient(); new Thread(() -> { // 这是一个阻塞方法,所以在线程内订阅 jedis.subscribe(this, channel); }).start(); } }
测试类
public class Main { public static final String CHANNEL_NAME = "demo_channel"; public static void main(String[] args) { Listener listener = new Listener(); listener.subscribe(CHANNEL_NAME); Publisher publisher = new Publisher(); publisher.publishMsg(CHANNEL_NAME, "hello world"); } }
参考博客
有代码
[1]https://juejin.im/post/5b35ff8ae51d455886494af6
6个命令
[2]https://blog.csdn.net/w05980598/article/details/80444717
相关文章推荐
- 使用redis的发布订阅模式实现消息队列
- redis之mq实现发布订阅模式
- 【并发】9、借助redis 实现生产消费,消息订阅发布模式队列
- redis实现消息队列(发布/订阅模式)
- 基于spring-redis发布订阅模式的实现
- 【转】redis 消息队列发布订阅模式spring boot实现
- redis实现消息队列&发布/订阅模式使用
- spring-boot集成redis实现消息发布订阅模式,以及多个订阅模式的实现
- redis 消息队列发布订阅模式spring boot实现
- springboot结合redis实现redis订阅发布模式
- 基于订阅/发布模式的简易聊天室实现(java+redis)
- Spring Boot 与Redis 集成实现消息发布/订阅模式
- Spring Data Redis实现消息队列——发布/订阅模式
- redis订阅发布模式
- redis事务及锁应用、发布订阅模式
- 用 JavaScript 实现发布/订阅模式
- Redis实现消息的发布/订阅
- Java实现Redis发布/订阅
- Java实现Redis发布/订阅
- Redis 设计与实现 (六)--发布订阅