RabbitMq 消费者的启动与关闭

古城微笑少年丶 2022-12-29 00:09 958阅读 0赞

## 思路 ##

消费者默认就是开启的，如果需要动态开启或关闭消费者的话，可以通过配置文件或者数据库或者提供一个可供调用的接口实现。

首先看一下消费者注解@RabbitListener。相关的主要是id和autoStartup。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70]

> ![id是唯一标识，可以据此通过RabbitListenerEndpointRegistry拿到消费者监听器的容器实例（MessageListenerContainer）。再利用其提供的相关方法开启/关闭消费者。][id_RabbitListenerEndpointRegistry_MessageListenerContainer]  
> id是唯一标识，可以据此通过RabbitListenerEndpointRegistry拿到消费者监听器的容器实例（MessageListenerContainer）。再利用其提供的相关方法开启/关闭消费者。
> 
> ![在这里插入图片描述][20201218112015889.png]  
> autoStartup有true和false两个取值。代表是否自动开启。

## 实现 ##

#### 1.消费者注解添加Id ####

import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    public class Receiver {
    	
        @RabbitListener(id="consumer_default_close",autoStartup="false")
        public void consumer(String message){
            /**
             * 业务逻辑
             */
        }
    }

#### 2.springBoot启动后，根据配置文件的参数选择性开启消费者 ####

@Data
    @Configuration
    @ConfigurationProperties(prefix = "mqConsumers")
    public class SpringPost4Mq implements ApplicationRunner {
        @Autowired
        private RabbitListenerEndpointRegistry rabbitListenerEndpointRegistry;
        private String startflag;
        private List<String> startConsumers;
    
        @Override
        public void run(ApplicationArguments args) {
            startConsumers.forEach(consumerId->startOneConsumer(consumerId));
    
        }
        /**
         * 开启/关闭单个消费者
         */
        private void startOneConsumer(String consumerId){
            MessageListenerContainer consumer = rabbitListenerEndpointRegistry.getListenerContainer(consumerId);
            if("true".equals(startflag)){
                // consumer.stop();     // 关闭消费者
                consumer.start();       // 开启消费者
            }
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDU2NTA5NQ_size_16_color_FFFFFF_t_70]: /images/20221120/7e419f3ce9fc47d392dce7623ce6ce6c.png
[id_RabbitListenerEndpointRegistry_MessageListenerContainer]: /images/20221120/f06ce5991c6441aa833f88f82b94ee34.png
[20201218112015889.png]: /images/20221120/d0c1a73614ea434fa6688f0afb6c77e0.png