基于 Redis 实现消息队列

使用特性

基于 Redis 实现分布式消息队列：

• 使用 Stream (opens new window) 特性，提供【集群】消费的能力。
• 使用 Pub/Sub (opens new window) 特性，提供【广播】消费的能力。

1、集群消费

集群消费，是指消息发送到 Redis 时，有且只会被一个消费者（应用 JVM 实例）收到，然后消费成功。

如果你需要使用到【集群】消费，必须使用 Redis 5.0.0 以上版本，因为 Stream 特性是在该版本之后才引入的。

使用场景

集群消费在项目中的使用场景，主要是提供可靠的、可堆积的异步任务的能力。例如说：

1. 短信模块，使用它异步发送短信。
2. 邮件模块，使用它异步发送邮件。

相比来说，

• Spring Async 在 JVM 实例重启时，会导致未执行完的任务丢失。
• 而集群消费，因为消息是存储在 Redis 中，所以不会存在该问题。

2、广播消费

广播消费，是指消息发送到 Redis 时，所有消费者（应用 JVM 实例）收到，然后消费成功。

使用场景

1. 例如说，在应用中，缓存了数据字典等配置表在内存中，可以通过 Redis 广播消费，实现每个应用节点都消费消息，刷新本地内存的缓存。
2. 又例如说，我们基于 WebSocket 实现了 IM 聊天，在我们给用户主动发送消息时，因为我们不知道用户连接的是哪个提供 WebSocket 的应用，所以可以通过 Redis 广播消费。每个应用判断当前用户是否是和自己提供的 WebSocket 服务连接，如果是，则推送消息给用户。

学习参考

• 消息队列（Redis） | ruoyi-vue-pro 开发指南 (opens new window)