亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

PHP如何通過rabbitMQ死信隊列實現業務的延時/定時操作

標簽:
PHP ThinkPHP

前言:

之前也通过文章介绍过rabbitMQ的搭建以及在PHP开发场景下的一些使用。这个主要从rabbitMQ的web控制台介绍死信队列的操作,以及代码层面的小应用等。关于死信的原理,rabbitMQ的特性等可以在其他文章中找到,这里就不详细介绍了。

场景:

死信的场景主要是用于来实现延迟队列,比如之前介绍的redis订阅的过期事件。都是用于在未来某个时间段需要对某些数据进行操作(删除/更新),就比如某些订单创建成功后添加到一个队列中。程序消费掉一部分已经支付过的订单,而那些未支付状态并且超过30分钟(举例的超时时间)就将其放入到延迟队列进行批量处理。

死信队列概述:

可以把死信队列理解为过滤后的水池,前面的队列就像负责接水的大水池,只有当大水池满了或者过滤筛选过的水才会流入小水池。最后小水池的水再进行饮用或者使用。

流程:

  1. 创建1个死信交换机(正常创建即可)和一个死信队列(正常创建),二者通过路由键绑定。

  2. 创建1个业务交换机, 创建一个业务队列,队列关联一个死信交换机及与交换机绑定的一个死信队列路由键。

  3. 最后将业务交换机与业务队列绑定。

  4. 代码只需要对生产消息到业务队列,消费死信队列的消息就可以。

步骤:

  1. 通过搭建的地址xxx.xxx.xxx.xxx:15672进入rabbitMQ的web控制台,新建虚拟机并进入。

  1. 新建死信交换机和死信队列,如下的ex_dlx,queue_dlx。

  1. 新建业务交换机,和业务队列,队列关联死信交换机。

  1. 用代码生产一条消息,然后查看业务队列是否有新消息。

  1. 两分钟后(创建队列时设置)查看死信队列是否有消息进来,以下表示死信队列已经有新消息。

  1. 最后对死信队列的消息用代码进行消费了,表示已经过期的数据。
點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
PHP開發工程師
手記
粉絲
3
獲贊與收藏
11

關注作者,訂閱最新文章

閱讀免費教程

  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消