利用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

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部