springboot + rabitmq 实现延时消息

我的服务器为 Centos 7.3

安装rabbit 插件  rabbitmq_delayed_message_exchange

查看rabbit可以安装插件的版本

rabbit-plugin list

3.7.18版本

标红的是我已经装好了的插件

下载插件

 地址: https://www.rabbitmq.com/community-plugins.html

打开直接 ctrl+f 搜索

点击下载

不知道为啥我的网就不行

因为我的是云服务器  使用 wget下载应该会好点

如果 wget not fond

安装 wget

yum install wget

然后下载

wget https://dl.bintray.com/rabbitmq/community-plugins/3.7.x/rabbitmq_delayed_message_exchange/rabbitmq_delayed_message_exchange-20171201-3.7.x.zip

下载完是.zip

用unzip解压文件

安装命令：yum install unzip #提示输入时，请输入y；

upzip  rabbitmq_delayed_message_exchange-20171201-3.7.x.zip

将.ez文件移动到 rabbitmq 安装目录 plugins 文件夹下

我用的docker  不是docker 直接移动过去

docker cp rabbitmq_delayed_message_exchange-20171201-3.7.x.ez b3fe5735bf89:plugins 

b3fe5735bf89为容器id 

plugins 文件夹名

安装插件 

到rabbitmq plugins 文件夹下

rabbitmq-plugins  enabler  abbitmq_delayed_message_exchange

集成springboot

POM yml

定义消息队列

定义消息队列

创建生产者

消费者

消费者

@Autowired 注入生产者 直接调发送

发送延时消息

简书 不能写代码块 很烦

附上效果图

发送者

消费者