当前位置: 首页 > news >正文

珠海网站开发定制海外网站cdn加速

珠海网站开发定制,海外网站cdn加速,线上客服,nas 支持做网站为处理生产者生产者将消息推送到交换机中,交换机按照消息中的路由键即自身策略无法将消息投递到指定队列中造成消息丢失的问题,可以使用备份交换机。 为处理在消息队列中到达TTL的过期消息,可采用死信交换机进行消息转存。 通过上述描述可知&…

为处理生产者生产者将消息推送到交换机中,交换机按照消息中的路由键即自身策略无法将消息投递到指定队列中造成消息丢失的问题,可以使用备份交换机。
为处理在消息队列中到达TTL的过期消息,可采用死信交换机进行消息转存。
通过上述描述可知,备份交换机和死信交换机处理的场景不同。备份交换机是处理未被路由的消息,死信交换机是处理队列中过期的消息。但是,它们都是为了避免消息丢失提供的一种手段。

备份交换机

生产者发送消息的过程中会指明交换机名称和路由键,RabbitMQ接收到消息后,根据交换机名称将消息投递到指定交换机中,交换机再根据自身类型以及消息携带的路由键将消息投递到队列中。当无法路由到队列时,并且该交换机存在备份交换机,则该交换机将该消息投递给其备份交换机进行处理。
备份交换机接收到消息后依旧根据其自身类型和消息路由键进行消息投递,如果依旧无法匹配到队列中,则该消息被丢失。该过程中的具体流程如下图所示。
备份交换机

备份交换机的实现

备份交换机的实现方式包括:生命交换机时通过参数配置和通过策略进行配置。申明交换机时配置备份交换机如下所示。

 Map<String, Object> args = new HashMap<>();args.put("alternate-exchange","myAe");      channel.exchangeDeclare("normalExchange","direct",true,false,args);channel.exchangeDeclare("myAe","fanout",true,false,null);

通过上述代码即实现了声明两个交换机,其中交换机myAe是normalExchange的备份交换机。备份交换机可以理解为一个普通交换机,备份交换机自身并不知晓自己是备份交换机,当某个消息无法被路由到队列中时,该交换机会查找自己的备份交换机,如果存在则将消息交由备份交换机进行处理。
需要说明的时,备份交换机在消息入队的时候也会根据自身类型进行路由匹配,消息重发到备份交换机时路由键和从生产者发送时的路由键一致,如果时直接交换机或者主题交换机,则依旧可能会导致消息丢失,因此备份交换机建议采用扇形交换机。
备份交换机存在以下特殊情况

  • 如果备份交换机和mandatory参数一起使用,则mandatory参数无效。
  • 如果备份交换机不存在,则消息丢失且生产者和RabbitMQ都不会有异常出现。
  • 如果备份交换机没有绑定队列,则消息丢失且生产者和RabbitMQ都不会有异常出现。
  • 如果备份交换机依旧无法将消息路由到队列,则消息丢失且生产者和RabbitMQ都不会有异常出现。

死信交换机

当一个消息在一个队列中变成死信后,它能被重新发送到另一个交换机中,这个交换机就是DLX(死信交换机:Dead-Letter-Exchange),绑定DLX的队列就是死信队列
消息变成死信一般由以下几种情况:

  • 消息被消费者拒绝,并且设置不可重新入队
  • 消息过期(TTL)
  • 队列达到最大长度。

根据上述描述,队列中的消息变成死信后将转发给死信交换机,因此死信交换机的设置是在声明队列的过程中完成的。死信交换机和备份交换机类似,其自身并不知道自己是死信交换机,仅指定其为死信交换机的队列知道其死信交换机身份的存在,本质上死信交换机和正常交换机并不存在区别。
死信交换机的设置存在声明队列时设置和通过策略设置。声明队列时设置如下所示:

Map<String, Object> args = new HashMap<>();
// 声明该队列的死信交换机为”dlx_exchange“
args.put("x-dead-letter-exchange","dlx_exchange");
// 声明死信交由死信交换机处理时将路由键替换为dlx-routing-key
args.put("x-dead-letter-routing-key","dlx-routing-key");
channel.queueDeclare("queue",false,false,false,args);

死信交换机存在以下特殊情况

  • 如果死信交换机不存在,则消息丢失且RabbitMQ都不会有异常出现。
  • 如果死信交换机没有绑定队列,则消息丢失且RabbitMQ都不会有异常出现。
  • 如果死信交换机依旧无法将消息路由到队列,则消息丢失且RabbitMQ都不会有异常出现。
http://www.wangmingla.cn/news/52112.html

相关文章:

  • 闵行颛桥网站建设查询网 网站查询
  • 微信公众号授权给网站百度快速排名 搜
  • 做网站的叫云啥如何宣传推广自己的产品
  • 郑州网站建设讠汉狮网络进入百度知道首页
  • 免费游戏不用登录直接玩seo去哪里学
  • 网站代码seo优化seo推广优化工具
  • 海安做网站企业seo顾问
  • 网站建设合同 含维护费北京网络排名优化
  • 做网站好迷茫最有效的免费推广方法
  • 销售网站建设怎么做如何做企业网页
  • 安徽建设工程信息网新网站哪儿登陆快速优化关键词排名
  • 网站怎么做404 301seo优化培训课程
  • 网站建设策划书ol在百度如何发布作品
  • 国内免费视频素材无水印素材网站百度识图网页版在线
  • 钢材贸易网站建设百度网盘下载app
  • 在那个网站找模具做seo搜索
  • 查询做导员的网站广东seo
  • 网站开发毕业设计题目软文范例大全100
  • 1688做网站需要多少钱站长之家域名查询
  • 扫描网站特征dede好看的seo网站
  • 给企业做网站需要什么信息网站推广经验
  • 易语言可以做网站管理系统吗青岛seo关键字排名
  • 北京当地网站 点文库百度登录入口
  • 深圳建设局投标网站外贸营销网站怎么建站
  • 石景山网站建设谷歌浏览器入口
  • 网站图文混排怎么存放到数据库里合肥seo推广外包
  • 两题一做的网站手机百度问一问
  • 如何做搜索网站测试佛山seo优化外包
  • 农业网站开发的实验报告最佳磁力吧ciliba
  • 郑州做网站擎天快速优化seo