c 网站开发简单实例教程,丹寇服饰官方网站,建设中标查询网站,成都专业建站推广公司为处理生产者生产者将消息推送到交换机中#xff0c;交换机按照消息中的路由键即自身策略无法将消息投递到指定队列中造成消息丢失的问题#xff0c;可以使用备份交换机。 为处理在消息队列中到达TTL的过期消息#xff0c;可采用死信交换机进行消息转存。 通过上述描述可知交换机按照消息中的路由键即自身策略无法将消息投递到指定队列中造成消息丢失的问题可以使用备份交换机。 为处理在消息队列中到达TTL的过期消息可采用死信交换机进行消息转存。 通过上述描述可知备份交换机和死信交换机处理的场景不同。备份交换机是处理未被路由的消息死信交换机是处理队列中过期的消息。但是它们都是为了避免消息丢失提供的一种手段。 备份交换机
生产者发送消息的过程中会指明交换机名称和路由键RabbitMQ接收到消息后根据交换机名称将消息投递到指定交换机中交换机再根据自身类型以及消息携带的路由键将消息投递到队列中。当无法路由到队列时并且该交换机存在备份交换机则该交换机将该消息投递给其备份交换机进行处理。 备份交换机接收到消息后依旧根据其自身类型和消息路由键进行消息投递如果依旧无法匹配到队列中则该消息被丢失。该过程中的具体流程如下图所示。
备份交换机的实现
备份交换机的实现方式包括生命交换机时通过参数配置和通过策略进行配置。申明交换机时配置备份交换机如下所示。 MapString, 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队列达到最大长度。
根据上述描述队列中的消息变成死信后将转发给死信交换机因此死信交换机的设置是在声明队列的过程中完成的。死信交换机和备份交换机类似其自身并不知道自己是死信交换机仅指定其为死信交换机的队列知道其死信交换机身份的存在本质上死信交换机和正常交换机并不存在区别。 死信交换机的设置存在声明队列时设置和通过策略设置。声明队列时设置如下所示
MapString, 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都不会有异常出现。
