前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >RabbitMQ高级特性-死信队列(DLX,Dead-Letter-Exchange)

RabbitMQ高级特性-死信队列(DLX,Dead-Letter-Exchange)

作者头像
JavaEdge
发布2021-02-22 16:07:25
2.1K0
发布2021-02-22 16:07:25
举报
文章被收录于专栏:JavaEdgeJavaEdge

1 什么是DLX?

利用DLX,当消息在一个队列中变成死信后,它能被重新发布到另一个Exchange中,这个Exchange就是DLX。 本质就是该消息不会再被任何消费端消费(但你可以自定义某消费者单独处理这些死信)。

2 DLX产生场景

  • 消息被拒绝(basic.reject/basic.nack),且requeue = false
  • 消息因TTL过期
  • 队列达到最大长度,先入队的消息会被删除

3 死信的处理过程

DLX亦为一个普通的Exchange,它能在任何队列上被指定,实际上就是设置某个队列的属性

  • 当某队列中有死信时,RabbitMQ会自动地将该消息重新发布到设置的Exchange,进而被路由到另一个队列
  • 可以监听这个队列中的消息做相应的处理。该特性可以弥补RabbitMQ 3.0以前支持的immediate参数的功能

4 DLX的配置

4.1 设置DLX的exchange和queue并绑定

  • Exchange:dlx.exchange
  • Queue: dlx.queue
  • RoutingKey:#

4.2 正常声明交换机、队列、绑定

只不过需要在队列加上一个参数:

代码语言:javascript
复制
arguments.put(" x-dead-letter-exchange","dlx.exchange");

这样消息在发生DLX产生条件时,消息即可直接路由到DLX。

5 代码实战

  • 自定义Con
  • Pro
  • Con
  • 启动Con,查看管控台
  • 现在,让我们停止Con,并启动Pro,由于没有Con,TTL为10s的消息将送往死信队列
  • 10s后

实际环境我们还需要对死信队列进行一个监听和处理,当然具体的处理逻辑和业务相关,这里只是简单演示死信队列是否生效。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020-08-05 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1 什么是DLX?
  • 2 DLX产生场景
  • 3 死信的处理过程
  • 4 DLX的配置
    • 4.1 设置DLX的exchange和queue并绑定
      • 4.2 正常声明交换机、队列、绑定
      • 5 代码实战
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档