SpringCloudStream使用StreamBridge实现延时队列

news2024/10/21 3:54:27

利用RabbitMQ实现消息的延迟队列

一、安装RabbitMQ

安装可以看https://blog.csdn.net/qq_38618691/article/details/118223851，进行安装。

安装完毕后，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
安装成功
验证

		<dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
		</dependency>

@Data
@AllArgsConstructor
@NoArgsConstructor
public class MessageInfo {
   

    private String name;
    private long sendTime;
}

import com.example

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2219765.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！