「这是我参与11月更文挑战的第28天,活动详情查看:2021最后一次更文挑战」
发布订阅机制
发布订阅:消息发布者发布消息 和 消息订阅者接收消息,两者之间通过某种媒介联系起来
常见场景:1. 微博动态:在微博关注了小A,当小A发微博过后,小A的粉丝都会收到小A发的动态 2. APP站内消息,当有新消息的时候,都会类似消息框的模式通知用户
- 当一个客户端通过 PUBLISH 命令向订阅者发布消息的时候,称这个客户端为发布者publisher
- 当一个客户端通过subscribe 或者 PSUBSCRIBE 接收消息时,称这个客户端为 订阅者 subscriber
为了解耦发布者和订阅者之间的关系,Redis使用了频道channel(频道)作为两者之间的中介,发布者直接把消息发送给channel(频道),而channel负责把消息发送给订阅者,发布者和订阅者之间没有直接的联系,都不知道对方的存在
客户端发到频道的消息,将会被推送到所有订阅此频道的客户端
客户端不需要主动去获取消息,只需要订阅频道,这个频道的内容就会被推送过来
eg: 有订阅者1,2,3 订阅了频道channel,当有消息发布给频道时,这个消息就会被发送到三个订阅者客户端
实现步骤
- 引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
复制代码
- 添加配置文件
spring:
redis:
host: 127.0.0.1
database: 5
password:
port: 6379
复制代码
- 新建一个监听类,用于监听消息
@Component
public class ReceiveListener implements MessageListener {
@Override
public void onMessage(Message message, byte[] bytes) {
System.out.println("我是监听者小A,我监听到的消息是 " + message.toString());
}
}
复制代码
- 创建一个监听容器
@Configuration
public class ReceiveListenerConfig extends CachingConfigurerSupport {
/**
* 消息监听容器
*
* @param factory
* @return
*/
@Bean
RedisMessageListenerContainer container(RedisConnectionFactory factory){
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(factory);
//订阅一个通道 该处的通道名是发布消息时的名称
container.addMessageListener(catAdapter(),new PatternTopic("topic"));
return container;
}
/**
* 消息监听适配器,绑定消息处理器
*
* @return
*/
@Bean
MessageListenerAdapter catAdapter(){
return new MessageListenerAdapter(new ReceiveListener());
}
}
复制代码
一切就绪,新建一个测试类,测试发布订阅是否成
查看运行结果,成功监听到了发布者发布的消息
适用场景
redis 的发布订阅的消息是有缺点的无法实现持久化,所以存在丢失的风险,因此Redis的发布订阅适用于实时但是可靠性要求不高的场景
近期评论