8.2.3 发送消息 结果分析
测试地址::8080///你好
发送消息内容:你好交换机已经收到 id 为:1的消息消息你好key2, 被交换机confirm.exchange退回 ，退回原因:NO_ROUTE, 路由key:key2交换机已经收到 id 为:2的消息接受到队列 confirm.queue 消息:你好key1
8.3. 备份交换机
有了参数和回退消息，我们获得了对无法投递消息的感知能力，有机会在生产者的消息无法被投递时发现并处理 。但有时候，我们并不知道该如何处理这些无法路由的消息，最多打个日志，然后触发报警，再来手动处理 。而通过日志来处理这些无法路由的消息是很不优雅的做法，特别是当生产者所在的服务有多台机器的时候，手动复制日志会更加麻烦而且容易出错 。而且设置参数会增加生产者的复杂性，需要添加处理这些被退回的消息的逻辑 。如果既不想丢失消息，又不想增加生产者的复杂性，该怎么做呢？前面在设置死信队列的文章中，我们提到，可以为队列设置死信交换机来存储那些处理失败的消息，可是这些不可路由消息根本没有机会进入到队列，因此无法使用死信队列来保存消息 。在中，有一种备份交换机的机制存在，可以很好的应对这个问题 。
什么是备份交换机呢？ 备份交换机可以理解为中交换机的“备胎”，当我们为某一个交换机声明一个对应的备份交换机时，就是为它创建一个备胎，当交换机接收到一条不可路由消息时，将会把这条消息转发到备份交换机中，由备份交换机来进行转发和处理，通常备份交换机的类型为，这样就能把所有消息都投递到与其绑定的队列中，然后我们在备份交换机下绑定一个队列，这样所有那些原交换机无法被路由的消息，就会都进入这个队列了 。当然，我们还可以建立一个报警队列，用独立的消费者来进行监测和报警 。
8.3.1. 代码架构图
8.3.2. 修改配置类
package com.bcl.mq.config;import org.springframework.amqp.core.*;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;/*** 配置类 发布确认（高级）** @author bcl* @date 2021/9/6*/@Configurationpublic class ConfirmConfig {public static final String CONFIRM_EXCHANGE_NAME = "confirm.exchange"; //交换机public static final String CONFIRM_QUEUE_NAME = "confirm.queue";//队列public static final String CONFIRM_ROUTING_KEY = "key1";//routingKeypublic static final String BACKUP_EXCHANGE_NAME = "backup.exchange"; //备份交换机public static final String BACKUP_QUEUE_NAME = "backup.queue";//备份队列public static final String WARNING_QUEUE_NAME = "warning.queue"; //报警队列//声明业务 Exchange@Bean("confirmExchange")public DirectExchange confirmExchange() {ExchangeBuilder exchangeBuilder = ExchangeBuilder.directExchange(CONFIRM_EXCHANGE_NAME).durable(true).withArgument("alternate-exchange", BACKUP_EXCHANGE_NAME);//设置该交换机的备份交换机return (DirectExchange) exchangeBuilder.build();}// 声明确认队列@Bean("confirmQueue")public Queue confirmQueue() {return QueueBuilder.durable(CONFIRM_QUEUE_NAME).build();}// 声明确认队列绑定关系@Beanpublic Binding queueBinding(@Qualifier("confirmQueue") Queue queue,@Qualifier("confirmExchange") DirectExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with(CONFIRM_ROUTING_KEY);}// 声明警告队列@Bean("warningQueue")public Queue warningQueue() {return QueueBuilder.durable(WARNING_QUEUE_NAME).build();}// 声明备份队列@Bean("backQueue")public Queue backQueue() {return QueueBuilder.durable(BACKUP_QUEUE_NAME).build();}//声明备份 Exchange@Bean("backupExchange")public FanoutExchange backupExchange() {return new FanoutExchange(BACKUP_EXCHANGE_NAME);}// 声明报警队列绑定关系@Beanpublic Binding warningBinding(@Qualifier("warningQueue") Queue queue,@Qualifier("backupExchange") FanoutExchange backupExchange) {return BindingBuilder.bind(queue).to(backupExchange);}// 声明备份队列绑定关系@Beanpublic Binding backupBinding(@Qualifier("backQueue") Queue queue,@Qualifier("backupExchange") FanoutExchange backupExchange) {return BindingBuilder.bind(queue).to(backupExchange);}}