php mq死信队列,【RabbitMQ 实战指南】一 死信队列
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 实战指南】一 死信队列]http://www.zyiz.net/tech/detail-93565.html
php mq死信队列,【RabbitMQ 实战指南】一 死信队列相关推荐
- 《RabbitMQ 实战指南》第五章 RabbitMQ 进阶(下)
<RabbitMQ 实战指南>第五章 RabbitMQ 进阶(下) 文章目录 <RabbitMQ 实战指南>第五章 RabbitMQ 进阶(下) 一.持久化 二.生产者确认 1 ...
- 《RabbitMQ 实战指南》第四章 RabbitMQ进阶(上)
<RabbitMQ 实战指南>第四章 RabbitMQ进阶(上) 文章目录 <RabbitMQ 实战指南>第四章 RabbitMQ进阶(上) 一.简介 二.消息何去何从 1.m ...
- 《RabbitMQ 实战指南》第三章 客户端开发向导
<RabbitMQ 实战指南> 文章目录 <RabbitMQ 实战指南> 一.简介 二.连接 RabbitMQ 三.使用交换器和队列 1.exchangeDeclare 方法详 ...
- 《RabbitMQ 实战指南》第一章 RabbitMQ 简介
<RabbitMQ 实战指南>第一章 RabbitMQ 简介 文章目录 <RabbitMQ 实战指南>第一章 RabbitMQ 简介 一.什么是消息中间件 二.消息中间件的作用 ...
- rabbitmq实战指南_RabbitMQ之脑裂
点击上方蓝色字体,选择"设为星标" 9 10 本文总结<RabbitMQ实战指南>网络分区章节,并亲自实践才有这篇文章,手动处理章节详细记录了操作过程中的注意事项.如果 ...
- 《RabbitMQ实战指南》笔误及改进记录
2017年12月上旬笔者的一本新书--<RabbitMQ实战指南>上架,里面的校稿都是自己独自完成的,一共进行了15遍,但还是会有漏网之鱼.本篇博文用来记录现在发现的一些笔误,一是给购书的 ...
- 《RabbitMQ 实战指南》第二章 RabbitMQ 入门
<RabbitMQ 实战指南> 文章目录 <RabbitMQ 实战指南> 一.相关概念介绍 1.生产者和消费者 2.队列 3.交换器.路由键.绑定 4.交换器类型 5.Rabb ...
- RabbitMQ实战指南之RabbitMQ架构及运转流程
相关概念 RabbitMQ 整体上是一个生产者与消费者模型,主要负责接收.存储和转发消息.可以把消息传递的过程想象成∶ 当你将一个包裹送到邮局,邮局会暂存并最终将邮件通过邮递员送到收件人的手上,Rab ...
- 《RabbitMQ实战指南》读书笔记
第一章 RabbitMQ简介 消息队列中间件:利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成.分为点对点和发布订阅的传递模式. 消息中间件的作用:解耦.冗余( ...
最新文章
- 关于chrome等浏览器不支持showModalDialog的解决方案
- mysql解决Value ‘0000-00-00 00:00:00’ can not be represented as java.sql.Timestamp
- pd.get_dummies
- js中!和!!的区别及用法
- python测试运行快捷键_Python基于unittest实现测试用例执行
- LinkedHashMap 源码详细分析(JDK1.8)
- 【转】如何调整一个 IFrame 到其内容的大小不显示滚动条[微软帮助]
- 在liferay strut2中如何使用session
- msp430入门学习35
- 二、Java面向对象(7)_封装思想——访问修饰符
- 我如何构建SiriWaveJS库:看一下数学和代码
- 终端编译opengl程序编译运行_ubuntu – 通过SSH编写opengl代码,通过机器显示运行程序...
- 摇号系统怎么做_雨水收集系统怎么做
- 夺命雷公狗----Git---2---基本用法
- 深挖那些隐藏在Linux中的炫酷主题
- STM32F107 资料
- 【转载】Unity3D导入FBX模型的相关属性介绍
- Android程序员英文介绍,安卓程序员面试英文自我介绍
- 微信小程序页面实现防抖
- 医疗常用信息化系统介绍
热门文章
- Markdown 学习——Typora入门之常见操作语法及其快捷键
- 通过移动目标防御阻止勒索软件和其他高级威胁
- 巧用CSS制作艺术字
- 写在宝宝周岁系列——取名
- Matlab制作表格
- 十个炫丽的表白模板源码,整合成一个完整系统可修改文字,可统计人数,经典的爱情告白,万能告白模板,胜过鲜花表白,程序员的特殊表白方式说——我爱你(520)——html、js、css、jQuery
- FFmpeg 开发记录---H264编码,avi封装,暴风影音,qq影音播放有声无画
- 海空神佛的虚伪[注意]
- fiddler 抓包详细教程
- BZOJ 2388--旅行规划(分块单调栈二分)