RabbitMQ安装延迟队列插件和php的使用

安装延迟队列插件

• 这里使用3.7.18版本为例&＃xff0c;下载rabbitmq_delayed_message_exchange-3.8.0.ez

• 把.ez文件放在插件目录&＃xff0c;我的rabbitmq是用yum安装的&＃xff0c;目录在/usr/lib/rabbitmq/lib/rabbitmq_server-3.7.18/plugins

• Enabling the Plugin

rabbitmq-plugins enable rabbitmq_delayed_message_exchange


• 查看rabbitmq 所有插件

rabbitmq-plugins list


安装完成&＃xff0c;在管理界面可以看到新的exchange类型

延迟exchange指定type

php程序中使用延迟队列

• 在程序中定义延迟队列&＃xff0c;我们上面使用管理界面定义&＃xff0c;可以不用在程序里定义

• 延迟队列publish, 这里的$delayTS为秒&＃xff0c;延迟队列支持毫秒精度的延迟

$exchange->publish(json_encode($message), null, AMQP_NOPARAM, [&＃39;headers&＃39; &＃61;> [&＃39;x-delay&＃39;&＃61;> 1000 * $delayTS]]);