精美网站设计欣赏,网站建设淘宝详情页,chatgpt app,wordpress 扁擔在RabbitMQ中#xff0c;延迟队列是一种特殊的队列类型。当消息被发送到此类队列后#xff0c;不会立即投递给消费者#xff0c;而是会等待预设的一段时间#xff0c;待延迟期满后才进行投递。这种队列在多种场景下都极具价值#xff0c;比如可用于处理需要在特定时间触发…在RabbitMQ中延迟队列是一种特殊的队列类型。当消息被发送到此类队列后不会立即投递给消费者而是会等待预设的一段时间待延迟期满后才进行投递。这种队列在多种场景下都极具价值比如可用于处理需要在特定时间触发的任务实现对消息处理的限流或者在消息发送失败后设置延迟重试等。
使用场景
定时任务: 例如发送提醒邮件或通知确保在特定时间后再执行。限流: 控制请求速率防止瞬时高并发导致的系统崩溃。重试机制: 在处理失败时可以将消息延迟后重试避免立即重试造成的负担。
第一步下载延迟插件
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
注意需要根据你自己的 RabbitMQ 服务器端版本选择相同版本的延迟插件可以在 RabbitMQ 控制台查看
https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases 我这里mq是3.9.1的所以延迟队列插件选择3.9.0
第二步将插件拷贝至容器中
复制到rabbitmq plugins目录下,linux查询rabbitmq安装包路径命令whereis rabbitmq
复制到 /usr/lib/rabbitmq/lib/rabbitmq_server-3.9.1/plugins 的目录下这里着重说一下我们下载的是.ez文件如下图所示直接复制进去就好 第三步执行安装命令 rabbitmq-plugins enable rabbitmq_delayed_message_exchange 这里着重强调一下我们复制进去的是 rabbitmq_delayed_message_exchange-3.9.0.ez 但是命令执行是不带-3.9.0.ez的 第四步启动插件并重启容器 rabbitmq-plugins enable rabbitmq_delayed_message_exchange 启动成功
第五步在容器重启完成
我们可以登录RabbitMQ的Web端管理界面在Exchanges选项卡下点击Add a new exchange在Type里面看是否出现了x-delayed-message选项如下图所示: 表示插件已经安装成功 结尾样例小程序二维码自己做的一个免费好用的排班小程序
