RabbitMQ系列【14】备份交换机

心已赠人 2023-10-09 15:09 16阅读 0赞

> **有道无术，术尚可求，有术无道，止于术。**

#### 文章目录 ####

*   *  前言
     *  代码实现
     *  测试

### 前言 ###

在之前，我们分析了[消息可靠性之发布确认、退回机制][Link 1]。当消息到达交换机后，但是没有找到匹配的队列时，`退回模式（return）`将消息回退给生产者。

使用`RabbitTemplate`发送消息，实际调用的还是底层`RabbitMQ`的`Channel`完成，例如`退回模式（return）`开启时，调用`channel.basicPublish`方法，并设置了一个重要参数`mandatory`为`true`。  
![在这里插入图片描述][0492ffab2d2f449ba9a3d8f3c2c9bf6c.png]  
`mandatory`为`true`时，如果交换机根据自身类型和消息路由键无法找到一个符合条件的队列时，那么会调用`return`方法将消息返回给生产者。当`mandatory`设置为`false`时，出现上述情形`RabbitMQ`会直接将消息扔掉。

除了`退回模式`，`RabbitMQ`还提供了`备份交换机`机制，当交换机接收到一条不可路由消息时，将会把这条消息转发到备份交换机中，由备份交换机来进行转发和处理。

**流程图如下说示：**

![在这里插入图片描述][f7768dbeb1724be785d94e3ae58b494b.png]

**注意事项**：当退回模式和备份交换机一起使用的时候，备份交换机的优先级比较高，不会执行回退消息的回调。

### 代码实现 ###

声明备份交换机、队列，类型为`Fanout`：

@Configuration
    public class MqBackupConfig {
        
    
        public static final String BACKUP_QUEUE = "backupQueue";
    
        public static final String BACKUP_EXCHANGE = "backupExchange";
    
        public static final String BACKUP_ROUTE_KEY = "backup.key";
    
        @Bean(BACKUP_QUEUE)
        public Queue backupQueue() {
        
            return QueueBuilder.durable(BACKUP_QUEUE).build();
        }
    
        @Bean(BACKUP_EXCHANGE)
        public FanoutExchange backupExchange() {
        
            return ExchangeBuilder.fanoutExchange(BACKUP_EXCHANGE).durable(true).build();
        }
    
        @Bean("backupBinding")
        public Binding backupBinding(@Qualifier(BACKUP_QUEUE) Queue backupQueue, @Qualifier(BACKUP_EXCHANGE) FanoutExchange backupExchange) {
        
            return BindingBuilder.bind(backupQueue).to(backupExchange);
        }
    
    }

声明业务交换机、队列，并绑定备份交换机：

@Configuration
    public class MqBizConfig {
        
    
    
        public static final String BIZ_QUEUE = "bizQueue";
    
        public static final String BIZ_EXCHANGE = "bizExchange";
    
        public static final String BIZ_ROUTE_KEY = "biz.key";
    
    
        @Bean(BIZ_QUEUE)
        public Queue bizQueue() {
        
            return QueueBuilder.durable(BIZ_QUEUE).build();
        }
    
        @Bean(BIZ_EXCHANGE)
        public Exchange bizExchange() {
        
            // 使用alternate-exchange 设置备份交换机
            return ExchangeBuilder.directExchange(BIZ_EXCHANGE).withArgument("alternate-exchange", MqBackupConfig.BACKUP_EXCHANGE).durable(true).build();
        }
    
        @Bean("bizBinding")
        public Binding bizBinding(@Qualifier(BIZ_QUEUE) Queue bizQueue, @Qualifier(BIZ_EXCHANGE) Exchange bizExchange) {
        
            return BindingBuilder.bind(bizQueue).to(bizExchange).with(BIZ_ROUTE_KEY).noargs();
        }
    
    }

设置备份队列消费者：

@RabbitListener(queues = {
        MqBackupConfig.BACKUP_QUEUE})
        public void receiveMessage(Message message) {
        
            System.out.println("备份队列收到消息" + new String(message.getBody()));
            System.out.println("发送告警信息给管理员");
            System.out.println("存入数据库等待人工处理");
        }

发送一条路由不正确的消息：

Message message = new Message("HELLO WORLD".getBytes(StandardCharsets.UTF_8));
            rabbitTemplate.send(MqBizConfig.BIZ_EXCHANGE, "boot.key", message);

### 测试 ###

发送消息，未被投递的消息被转发到备份交换机：  
![在这里插入图片描述][113bb5259fb941f7a1398afe90035650.png]

[Link 1]: https://blog.csdn.net/qq_43437874/article/details/127767264?spm=1001.2014.3001.5501
[0492ffab2d2f449ba9a3d8f3c2c9bf6c.png]: https://img-blog.csdnimg.cn/0492ffab2d2f449ba9a3d8f3c2c9bf6c.png
[f7768dbeb1724be785d94e3ae58b494b.png]: https://img-blog.csdnimg.cn/f7768dbeb1724be785d94e3ae58b494b.png
[113bb5259fb941f7a1398afe90035650.png]: https://img-blog.csdnimg.cn/113bb5259fb941f7a1398afe90035650.png