SpringCloudStream使用StreamBridge实现延时队列
利用RabbitMQ实现消息的延迟队列
一、安装RabbitMQ
1、安装rabbitmq
安装可以看https://blog.csdn.net/qq_38618691/article/details/118223851，进行安装。
2、安装插件
安装完毕后，exchange是不支持延迟类型的，需要手动安装插件，需要和安装的rabbitmq版本一致
https://download.csdn.net/download/qq_38618691/89896899?spm=1001.2014.3001.5503
如何想要下载其他版本，可以从github上下载：插件地址，下载文件后缀.ez
- 将下载的插件放入rabbitmq安装路径下的plugins
- 打开CMD窗口， 路径选择进入到sbin文件夹下，执行rabbitmq-plugins enable rabbitmq_delayed_message_exchange
- 安装成功
- 验证
二、代码开发
1、引入pom
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>
2、消息实体
@Data
@AllArgsConstructor
@NoArgsConstructor
public class MessageInfo {
private String name;
private long sendTime;
}
3、生产者
import com.example