如何使用PHP的RabbitMQ延迟消息队列？_php教程

上一篇: cakephp – 如何用新生成的.pot文... 下一篇:基于PHP变量定义CSS属性值

如何使用PHP的RabbitMQ延迟消息队列？

发布时间：2022-04-30 发布网站：脚本宝典

脚本宝典收集整理的这篇文章主要介绍了如何使用PHP的RabbitMQ延迟消息队列？，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。

我正在尝试从 @L_126_0@使用 Delayed Message Queue for RabbITMQ,但我的消息正在消失.

我用以下代码声明交换：

$this->channel->exchange_declare(
    'delay','x-delayed-message',false,/* passive,create if exchange doesn't exist */
    true,/* durable,PErsist through server reboots */
    false,/* autodelete */
    false,/* internal */
    false,/* Nowait */
    ['x-delayed-type' => ['S','direct']]);

我用这段代码绑定队列：

$this->channel->queue_declare(
    $queueName,/* Passive */
    true,/* Durable */
    false,/* Exclusive */
    false   /* Auto Delete */
);
$this->channel->queue_bind($queueName,"delay",$queueName);

我正在使用以下代码发布消息：

$msg = new AMQPMessage(json_encode($msgData),[
    'delivery_mode' => 2,'x-delay' => 5000]);
$this->channel->basic_publish($msg,'delay',$queueName);

但消息不会延迟;它仍然立即交付.我错过了什么？

解决方法

从 here,

消息创建应该是

require_once __DIR__ . '/vendor/autoload.PHP';
use PHPAmqpLib\Message\AMQPMessage;
use PHPAmqpLib\Wire\AMQPTable;

$msg = new AMQPMessage($data,array(
                'delivery_mode' => 2,# make message persistent
                'application_headers' => new AMQPTable([
                    'x-delay' => 5000
                ])
            )
        );