【Redis】浅谈Redis的发布(Push)和订阅(sub)

本文介绍: 在日常开发中我们很多时候会用到发布/订阅这种模式，例如常用的一些消息中间件就会有这种模式，redis中也提供了这种模式，让我们来看下吧。redis 发布订阅（push/su b）是一种消息通信模式：发布者（push）发布消息，订阅者（su b）接收消息。客户端可以订阅任意数量的频道。

在日常开发中我们很多时候会用到发布/订阅这种模式，例如常用的一些消息中间件就会有这种模式，redis中也提供了这种模式，让我们来看下吧。

redis 发布订阅（push/su b）是一种消息通信模式：发布者（push）发布消息，订阅者（su b）接收消息。

客户端可以订阅任意数量的频道。

1、发布订阅流程

1、客户端订阅消息频道

2、发布者将消息发布到频道

3、频道将消息发送给订阅的客户端

2、发布/订阅命令

2.1 订阅

订阅命令：subscribe/psubscribe

less

复制代码

//订阅一个活多个频道 subscribe channel1 channel2 ... //订阅一个或多个符合给定模式的频道，以"*"作为匹配符，如：it*则表示匹配以it开头的所有频道 psubscribe pattern [pattern ...]

2.2 发布

发布命令：publish

shell

复制代码

//将msg发送到指定的频道 publish channel1 msg

切换订阅窗口，可看到接收到的信息

3、Spr in gBo o t 实现 r edi s发布订阅

Spr in gBo o t是我们常用的开发框架，也会经常用到 r edi s做各种数据的缓存，而r edi s的发布订阅也在日常开发中常用到。

3.1 引入 r edi s包

xml

复制代码

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>

3.2 配置消息监听类

3.2.1 实现Me ssa g eLi stene r 接口

less

复制代码

/** * @author: jiangjs * @description: redis消息监听类 * @date: 2023/4/7 11:10 **/ @Slf4j @Component public class RedisMessageListener implements MessageListener { @Override public void onMessage(Message message, byte[] pattern) { byte[] body = message.getBody(); byte[] channel = message.getChannel(); log.info("------频道名称------："+new String(channel)); log.info("------消息内容------："+new String(body)); } }

redis的start 类中提供的MessageListener接口中的onMessage方法可以接收到用户发布的信息，我们获取到信息后就可以编写自己的业务。

3.2.2 创建MessageListenerAdapter适配的类

typescript

复制代码

/** * @author: jiangjs * @description: * @date: 2023/4/7 14:32 **/ @Slf4j @Component public class MessageReceiver { public void receive(String message,String channel) { log.info("------频道名称------："+ channel); log.info("------消息内容------："+ message); } }

3.3 redis配置类，并监听渠道

配置文件配置订阅渠道信息：

yaml

复制代码

#redis订阅频道 redis: channel: jiashn,lovejiashn

3.3.1 监听MessageListener

typescript

复制代码

@Configuration public class RedisConfig { @Value("${redis.channel}") private String channel; @Bean public RedisMessageListenerContainer container(RedisConnectionFactory factory, RedisMessageListener listener){ List<String> channels = Arrays.asList(StringUtils.split(channel, ",")); List<ChannelTopic> topics = new ArrayList<>(channels.size()); channels.forEach(cha -> topics.add(new ChannelTopic(cha))); RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(factory); //订阅频道 container.addMessageListener(listener,topics); return container; } }

channel在配置文件中配置的渠道，创建 container方法的参数中包含了第二步中的监听器，将监听器与频道进行绑定。RedisMessageListenerContainer redis消息监听容器可以将监听器与频道进行绑定，完成订阅频道。

3.3.2 监听MessageListenerAd pater

typescript

复制代码

/** * @author: jiangjs * @description: redis配置类 * @date: 2023/4/7 11:16 **/ @Configuration public class RedisConfig { @Value("${redis.channel}") private String channel; @Bean public MessageListenerAdapter adapter(MessageReceiver receiver){ return new MessageListenerAdapter(receiver, "receive"); } @Bean public RedisMessageListenerContainer container(RedisConnectionFactory factory, MessageListenerAdapter adapter){ List<String> channels = Arrays.asList(StringUtils.split(channel, ",")); List<ChannelTopic> topics = new ArrayList<>(channels.size()); channels.forEach(cha -> topics.add(new ChannelTopic(cha))); RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(factory); //订阅频道 container.addMessageListener(adapter,topics); return container; } }

在redis配置里面中创建MessageListenerAdapter，通过该构造函数创建时需要绑定监听类（如：MessageReceiver）及监听的方法（如：MessageReceiver中的receive方法），然后再通过RedisMessageListenerContainer进行频道订阅。

3.4 发布信息

less

复制代码

@Autowired private RedisTemplate<String,String> template; @GetMapping("/send/{channel}/{msg}") public ResultUtil<String> sendMessage(@PathVariable("channel") String channel, @PathVariable("msg") String msg){ template.convertAndSend(channel,msg); return ResultUtil.success(); }