【RabbitMq 篇三】-备份交换器

古城微笑少年丶 2022-01-13 11:59 268阅读 0赞

# #

## 前言 ##

备份交换器也叫备胎交换器，顾名思义就是，替代现任的，分手后可以及时上位，让你的爱情持续下去，原理就是我爱你换不来你爱我，那我就去找备胎了。回到消息里就很好理解了，生产者发送消息，由于路由错误不能到达指定队列，所以就路由到备胎队列消费，这样做可以保证未被路由的消息不会丢失，其实保证消息不会丢失还可以通过消息的回调方法，添加ReturnListener的编程逻辑，但是这样做生产者的代码会复杂写，所以我们使用备份交换器实现。

## 正文 ##

在实现之前我要介绍一个重要的参数

### mandatory ###

mandatory翻译成“强制的”，参数设置 true 时，交换器无法根据自身类型和路由键找到一个符合条件的队列，那么该消息会返回给生产者。当参数设置 false 时，出现上述情况，消息会被丢弃。

把参数设置 true，然后添加ReturnListener的编程逻辑就可以通过消息回调方式保证消息的可靠性。

### alternate-exchange ###

下面介绍第二种方法，可以通过在声明交换器的时候设置 alternate-exchange 参数来实现，这样处理代码逻辑更简洁，本文的案例也是通过这种方式实现的。

开始之前让大家理解更直观，我画来一个图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70][]

备份交换器和普通交换器一样，建议设置为 fanout 类型，你也可以设置direct或者topic，但是重新发送给备份交换器时路由键也要匹配上，我们设置备份交换器就是说在路由键没有匹配上才有意义，所以没必要设置direct或者topic。

**使用所有框架和中间件的版本**

<table>  环境  
 <tbody> 
  <tr> 
   <td>框架</td> 
   <td>版本</td> 
  </tr> 
  <tr> 
   <td>Spring Boot&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;</td> 
   <td>2.1.5.RELEASE</td> 
  </tr> 
  <tr> 
   <td>RabbitMq</td> 
   <td>3.7.15</td> 
  </tr> 
  <tr> 
   <td>JDK</td> 
   <td> <p>1.8.0_144</p> </td> 
  </tr> 
  <tr> 
   <td>Erlang</td> 
   <td>22.0.2</td> 
  </tr> 
 </tbody> 
</table>

### maven依赖 ###

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>

### RabbitMq配置 ###

spring.rabbitmq.host=localhost
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=yanlin
    spring.rabbitmq.password=yanlin

### 生产者 ###

## ##

@RestController
    public class AEController {
        @Autowired
        private AmqpTemplate amqpTemplate;
    
        @GetMapping("/ae/{id}")
        public String AETest(@PathVariable Integer id) {
            Order order = new Order(id, "现任");
            amqpTemplate.convertAndSend("TestAE", "abc", order);
            order.setName("备胎");
            amqpTemplate.convertAndSend("TestAE", "a", order);
            System.out.println(order);
            return "成功";
        }
    }

### 配置监听 ###

## ##

@Configuration
    public class AEListener {
        //一个正常对队列
        private static final String queue = "good-queue";
        //备份对队列
        private static final String AEQueue = "AE-queue";
    
    
        @Bean
        public Queue goodQueue() {
            return new Queue(queue);
        }
    
        @Bean
        public Queue AEQueue() {
            return new Queue(AEQueue);
        }
    
        @Bean
        public DirectExchange goodExchange() {
            Map<String, Object> arguments = new HashMap<>();
            //如果设置此参数，TestAE交换器绑定的路由没有匹配到就会发送到exchange-unroute交换器所绑定的队列进行消费
            arguments.put("alternate-exchange", "exchange-unroute");
            return new DirectExchange("TestAE", true, false, arguments);
        }
    
        @Bean
        public FanoutExchange unRouteExchange() {
            // 此处的交换器的名字要和 exchange() 方法中 alternate-exchange 参数的值一致
            return new FanoutExchange("exchange-unroute");
        }
    
        //被路由到的 交换器绑定队列
        @Bean
        Binding bindingExchangeGood(Queue goodQueue, DirectExchange goodExchange) {
            return BindingBuilder.bind(goodQueue()).to(goodExchange()).with("abc");
        }
    
        //未被路由到的 交换器绑定队列
        @Bean
        Binding bindingExchangeAE(Queue AEQueue, FanoutExchange unRouteExchange) {
            return BindingBuilder.bind(AEQueue).to(unRouteExchange);
        }
    }

### 消费者 ###

## ##

@Service
    public class AEConsumer {
    
        @RabbitListener(queues = "good-queue")
        @RabbitHandler
        public void good(Order order) {
            System.out.println("成功路由到，这是：" + order.getName());
        }
    
        @RabbitListener(queues = "AE-queue")
        @RabbitHandler
        public void AE(Order order) {
            System.out.println("错误路由到，这是：" + order.getName());
        }
    
    }

**启动生产者和消费者，调用接口**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 1][]

这样就实现了成功路由和备份交换器的路由

注意以下情况

如果设置的备份交换器不存在、备份交换器没有绑定任何队列、备份交换器绑定了队列但是没有匹配到，以上三种情况，客户端和服务端都不会出现异常，消息会丢失。

如果配置了 mandatory 参数和备份交换器一起用，那么参数无效。

github地址 [https://github.com/362460453/rabbitMQ-demo][https_github.com_362460453_rabbitMQ-demo]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 3][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70]: /images/20220113/ad0efac248f34b31922f8b4442b58ed6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 1]: /images/20220113/570b658ad7be4665928dae92a68e8d49.png
[https_github.com_362460453_rabbitMQ-demo]: https://github.com/362460453/rabbitMQ-demo
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 2]: /images/20220113/8d68528646804a819af4ae49fbc5fad4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zODAwMzM4OQ_size_16_color_FFFFFF_t_70 3]: /images/20220113/2d0a963a7f4744fc97541a2c2845e210.png