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 注入生产者 直接调发送

发送延时消息

简书 不能写代码块 很烦

附上效果图

发送者

消费者

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。