RabbitMQ延迟队列实现方式:
- 通过消息设置的TTL过期后进入死信交换机,再由交换机转发到延迟消费队列,实现延迟功能;
- 使用rabbitmq-delayed-message-exchange插件实现延迟功能
本文介绍rabbitmq-delayed-message-exchange插件
需要安装插件:https://github.com/rabbitmq/rabbitmq-delayed-message-exchange
你可以尝试查找一下你RabbitMQ安装在哪里的
代码语言:javascript复制whereis rabbitmq
一般会提示在 /usr/lib/rabbitmq /etc/rabbitmq
实际是在/usr/lib/rabbitmq/lib/RabbitMQ的XX版本/plugins
将下载好的文件 放入到
代码语言:javascript复制/usr/lib/rabbitmq/lib/RabbitMQ的XX版本/plugins
在RabbitMQ运行的时候开启插件
代码语言:javascript复制rabbitmq-plugins enable rabbitmq_delayed_message_exchange
在RabbitMQ运行的时候关闭插件
代码语言:javascript复制rabbitmq-plugins disable rabbitmq_delayed_message_exchange
使用
特殊说明: 以上文章,均是我实际操作,写出来的笔记资料,不会盗用别人文章!烦请各位,请勿直接盗用!转载记得标注来源!