1、死信队列
DLX，全称为 Dead-Letter-Exchange，可以称之为死信交换器。当消息在一个队列中变成死信(dead message)之后，它能被发送到另一个交换器中，这个交换器就是DLX，绑定DLX的队列就称之为死信队列。
DLX 也是一个正常的交换器，和一般的交换器没有区别，它能在任何的队列上被指定，实际上就是设置某个队列的属性。当这个队列中存在死信时，RabbitMQ就会自动地将这个消息重新发布到设置的DLX上去，进而被路由到另一个队列，即死信队列。然后可以监听这个死信队列中的消息进行相应的处理。
2、消息变成死信的情况
消息被拒绝
消息过期
队列达到最大长度
3、死信队列设置
可以通过为队列设置x-dead-letter-exchange 参数设置 DLX，也可以通过设置x-dead-letter-routing-key 参数为这个DLX指定路由键，如果没有特殊指定，则使用原队列的路由键。
4、死信队列测试
4.1 测试过程
整个过程如下图：
第一步：创建两个交换器exchange.normal和exchange.dlx,分别绑定两个队列queue.normal和queue.dlx
第二步：把queue.normal队列里面的消息配置过期时间，然后通过x-dead-letter-exchange指定死信交换器为exchange.dlx
第三步：发送消息到queue.normal中，消息过期之后流入exchange.dlx，然后路由到queue.dlx队列中，然后进行消费
4.2 生产者代码
require __DIR__ . '/../../../../vendor/autoload.php';
use PhpAmqpLib\Wire\AMQPTable;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Exchange\AMQPExchangeType;
use PhpAmqpLib\Connection\AMQPStreamConnection;
/**
* 死信队列测试
* 1、创建两个交换器 exchange.normal 和 exchange.dlx, 分别绑定两个队列 queue.normal 和 queue.dlx
* 2、把 queue.normal 队列里面的消息配置过期时间，然后通过 x-dead-letter-exchange 指定死信交换器为 exchange.dlx
* 3、发送消息到 queue.normal 中，消息过期之后流入 exchange.dlx，然后路由到 queue.dlx 队列中，进行消费
*/
// todo 更改配置
$connection = new AMQPStreamConnection('192.168.33.1', 5672, 'zhangcs', 'zhangcs', '/');
$channel = $connection->channel();
$channel->exchange_declare('exchange.dlx', AMQPExchangeType::DIRECT, false, true);
$channel->exchange_declare('exchange.normal', AMQPExchangeType::FANOUT, false, true);
// 设置 queue.normal 队列中的消息10s之后过期
$args = new AMQPTable();
$args->set('x-message-ttl', 10000);
$args->set('x-dead-letter-exchange', 'exchange.dlx');
$args->set('x-dead-letter-routing-key', 'routingkey');
$channel->queue_declare('queue.normal', false, true, false, false, false, $args);
$channel->queue_declare('queue.dlx', false, true, false, false);
$channel->queue_bind('queue.normal', 'exchange.normal');
$channel->queue_bind('queue.dlx', 'exchange.dlx', 'routingkey');
$message = new AMQPMessage('Hello DLX Message');
$channel->basic_publish($message, 'exchange.normal', 'rk');
$channel->close();
$connection->close();
运行生成者代码之后，queue.normal 队列会有一条消息，如下图：
10秒之后，消息会过期，然后被进入 exchange.dlx, 进而路由到 queue.dlx 队列中：
4.3、消费者代码
require __DIR__ . '/../../../../vendor/autoload.php';
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Exchange\AMQPExchangeType;
use PhpAmqpLib\Connection\AMQPStreamConnection;
// todo 更改配置
$connection = new AMQPStreamConnection('192.168.33.1', 5672, 'zhangcs', 'zhangcs', '/');
$channel = $connection->channel();
$channel->exchange_declare('exchange.dlx', AMQPExchangeType::DIRECT, false, true);
$channel->queue_declare('queue.dlx', false, true, false, false);
$channel->queue_bind('queue.dlx', 'exchange.dlx', 'routingkey');
function process_message($message)
{
echo "\n--------\n";
echo $message->body;
echo "\n--------\n";
$message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
}
$channel->basic_consume('queue.dlx', 'consumer_tag', false, false, false, false, 'process_message');
function shutdown($channel, $connection)
{
$channel->close();
$connection->close();
}
register_shutdown_function('shutdown', $channel, $connection);
while ($channel ->is_consuming()) {
$channel->wait();
}
运行消费者代码之后，消费会从 queue.dlx 中消费掉：
关于找一找教程网
本站文章仅代表作者观点，不代表本站立场，所有文章非营利性免费分享。
本站提供了软件编程、网站开发技术、服务器运维、人工智能等等IT技术文章，希望广大程序员努力学习，让我们用科技改变世界。
[【RabbitMQ 实战指南】一 死信队列]/tech/detail-93565.html
