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