【发布时间】:2015-02-01 13:43:01
【问题描述】:
RabbitMQ 支持队列的过期时间(又名队列 TTL)。
As explained in RabbitMQ documentation,通过将 x-expires 参数设置为 queue_declare 方法,可以很容易地为给定队列设置到期时间。
为了发送消息,我声明了队列,然后使用basic_publish 方法推送消息。
但是,我的发送代码会“触及”队列到期时间 - 当发送消息时,到期时间会重置为其初始值(在我的示例中为 30 秒)。
这是我如何创建队列的一个简单示例:
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
// queueKey is given as first arg
$queueName = $argv[1];
// auto-delete the queue after x ms
$channel->queue_declare($queueName, false, true, false, false, false,
new AMQPTable(array("x-expires" => 30000 ))
);
这就是我发送消息的方式:
$channel->queue_declare($queueName, true, true, false, false, false,
new AMQPTable(array("x-expires" => 30000 ))); // auto-delete the queue after x ms
// mark messages as persistent
$msg = new AMQPMessage($data, array(
'delivery_mode' => 2
));
// pushing the message to the queue
$channel->basic_publish($msg, '', $queueName);
发送消息时有什么办法不触及过期时间吗?我希望仅在某人真正消费消息(即有消费者)而不是在发送时才触及到期时间。我的意思是,当“某人”发送消息时,我希望我的 30 秒计时器不会被重置。
谢谢!
【问题讨论】: