怎么用redis发布订阅方式实现简易的消息系统
I. 基本使用1. 配置
我们使用 SpringBoot 2.2.1.RELEASE来搭建项目环境，直接在pom.xml中添加 redis 依赖
<dependency>
<
groupId>
org.springframework.boot<
/groupId>
<
artifactId>
spring-boot-starter-data-redis<
/artifactId>
<
/dependency>
如果我们的 redis 是默认配置，则可以不额外添加任何配置；也可以直接在application.yml配置中，如下
spring:redis:
host: 127.0.0.1
port: 6379
password: 2. 使用姿势
redis 的发布/订阅，主要就是利用两个命令publish/subscribe;
在 SpringBoot 中使用发布订阅模式比较简单，借助 RedisTemplate 可以很方便的实现
public class PubSubBean {
@Autowired
private StringRedisTemplate redisTemplate;
public void publish(String key, String value) {
redisTemplate.execute(new RedisCallback<
Object>
() {
@Override
public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
redisConnection.publish(key.getBytes(), value.getBytes());
return null;
}
});
}
} b. 订阅消息
消息订阅这里，需要注意我们借助org.springframework.data.redis.connection.MessageListener来实现消费逻辑
public void subscribe(MessageListener messageListener, String key) {redisTemplate.execute(new RedisCallback<
Object>
() {
@Override
public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
redisConnection.subscribe(messageListener, key.getBytes());
return null;
}
});
} c. 测试 case
写一个简单的测试 case，来验证一下上面的发布订阅，顺带理解一下这个MessageListener的使用姿势；我们创建一个简单的 WEB 工程，提供两个 rest 接口
@RestController@RequestMapping(path = "
rest"
)
public class DemoRest {
@Autowired
private PubSubBean pubSubBean;
// 发布消息
@GetMapping(path = "
pub"
)
public String pubTest(String key, String value) {
pubSubBean.publish(key, value);
return "
over"
;
}
// 新增消费者
@GetMapping(path = "
sub"
)
public String subscribe(String key, String uuid) {
pubSubBean.subscribe(new MessageListener() {
@Override
public void onMessage(Message message, byte[] bytes) {
System.out.println(uuid + "
==>
msg:"
+ message);
}
}, key);
return "
over"
;
}
}
我们先创建了两个消费者，然后发送消息时，两个都收到；再新增一个消费者，发送消息时，三个都能收到
3. 使用说明与应用场景redis 的发布订阅，只适用于比较简单的场景，从上面的使用说明也能看出，它就是一个简单的发布订阅模型，支持 1 对 N，而且发送的消息，只有在线的消费者才能 get 到（至于不在线的，那就只能说遗憾了）而且对于 redis 而言，消息推出去之后就完事了，至于消费者能不能正常消费，那就不 care 了
划重点：
只有在线的消费者能接收到消息
对于消费者一个消息只能拿到一次
接下来的问题就来了，什么样的场景下可以使用 redis 的发布订阅呢？
基于内存的缓存失效
利用 reids + 内存做二级缓存，可以说是比较常见的方式了，借助基于内存的缓存，可以有效的提高系统的负载，但是问题也很明显，内存中缓存数据失效是个问题，特别是当一个应用部署多台服务器时，如果我希望同时失效所有服务器的某个内存缓存，使用 redis 的发布/订阅就是一个比较好的选择
SpringCloud Config 配置刷新
使用 SpringCloud Config 做配置中心的小伙伴可能会经常遇到这个问题，配置修改之后的动态刷新是个问题（当然官方是支持通过 mq 走 bus 总线来同步，也可以通过 spring boot admin 来强刷）
借助 redis 发布/订阅，实现配置动态刷新也是一个不错的备选方案（后面给出一个具体的实现 demo，如有兴趣请持续关注一灰灰 Blog）
redis key 失效订阅
我们在使用 redis 做缓存时，通常会设置一个过期时间，redis 提供了一个过期的事件，当然默认是不开启的；我们也是可以通过 subscribe 来订阅缓存失效的事件
修改配置，开启 key 失效事件
notify-keyspace-events Ex重启 redis 之后，订阅失效事件即可
subscribe __keyevent@0__:expiredRedis是一款高性能的键值存储数据库，除了常规的get/set操作外，它还提供了许多高级功能，如发布订阅机制。这种机制可以让客户端通过订阅某个channel来接收指定消息。本文将带您了解如何用Redis实现简易的消息系统，包括如何发布消息和订阅消息。
一、发布消息
发布消息是指将消息发送到指定的channel，供订阅者接收。Redis提供了PUBLISH命令用于发布消息。下面是该命令的语法：
```
PUBLISH channel message
```
其中，channel是订阅的频道名，message是要发布的消息。例如：
```
PUBLISH news \"今日头条：xxx\"
```
这条命令会将\"今日头条：xxx\"消息发布到news频道上，所有订阅了news频道的客户端都会收到该消息。
二、订阅消息
订阅消息是指客户端在指定的频道上接收消息。Redis提供了SUBSCRIBE命令用于订阅频道。下面是该命令的语法：
```
SUBSCRIBE channel [channel ...]
```
其中，channel是要订阅的频道名，可以同时订阅多个频道。例如：
```
SUBSCRIBE news sports
```
这条命令会订阅news和sports两个频道，客户端将可以接收这两个频道上发布的消息。如果有新消息发布到了这两个频道上，客户端会收到以下形式的推送：
```
1) \"message\"
2) \"news\"
3) \"今日头条：xxx\"
```
这里的第一个元素是固定的，表示是新消息推送；第二个元素是频道名；第三个元素是消息内容。
三、退订频道
如果客户端不再需要接收某个频道上的消息，可以使用UNSUBSCRIBE命令将该频道从订阅列表中移除。下面是该命令的语法：
```
UNSUBSCRIBE [channel [channel ...]]
```
如果不指定频道名，则会将所有频道从订阅列表中移除。例如：
```
UNSUBSCRIBE news
```
这条命令会取消客户端对news频道的订阅。
本文简单介绍了如何用Redis发布订阅机制实现简易的消息系统。通过发布订阅机制，不同的客户端之间可以实时地传递信息，大大提高了系统的实时性。在实际应用中，还可以结合其他Redis功能，如事务和持久化，实现更加完善的消息系统。
