SpringBoot与RabbitMQ：Direct直连生产者

灰太狼 2022-10-09 00:38 154阅读 0赞

# 1. 几个重要注解 #

# 1.1 @EnableRabbit #

开启容器对注册的bean的@RabbitListener检查

可以标注在启动类上

# 1.2 @RabbitListener #

注解指定目标方法来作为消费消息的方法

# 1.3 @RabbitHandler #

与@RabbitListener一起配合使用，用于不同类型的消息重载不同的方法来处理

@Component
    @RabbitListener(queues ="testQueue")
    public class CommandListener{ 
    
        @RabbitHandler
        public void handler1(ApiMessage msg){ 
            System.out.println(msg);
        }
    
        @RabbitHandler
        public void handler2(Map msg){ 
            System.out.println(msg);
        }
    }

# 2. SpringBoot实践 #

SpringBoot启动时，自动创建交换机、队列、路由键、及其绑定

@Configuration
    public class DirectRabbitConfig { 
    
        private static final String exchange = RabbitConfigConstant.QUS_EXCHANGE;
    
        private static final String routingKey = RabbitConfigConstant.QUS_ROUTING_KEY;
    
        private static final String queue = RabbitConfigConstant.QUS_QUEUE;
    
        @Autowired
        RabbitAdmin rabbitAdmin;
    
        /** * 消息转换器修改 * <p> * 有了这项配置后, 消息在rabbitMq的管理页面就可以显示看到消息的json数据，否则是序列化的数据 * * @return */
        @Bean
        public MessageConverter jackJsonMessageConverter() { 
            return new Jackson2JsonMessageConverter();
        }
    
        /** * 配置rabbitAdmin * * @param connectionFactory * @return */
        @Bean
        public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) { 
            RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
            // 只有设置为 true，spring 才会加载 RabbitAdmin 这个类
            rabbitAdmin.setAutoStartup(true);
            return rabbitAdmin;
        }
    
        /** * 队列、交换机的创建 */
        @Bean
        public void createExchangeQueue() { 
            Queue queue = directQueue();
            DirectExchange directExchange = directExchange();
            Binding binding = bindingDirect(queue, directExchange);
            rabbitAdmin.declareQueue(queue);
            rabbitAdmin.declareExchange(directExchange);
            rabbitAdmin.declareBinding(binding);
        }
    
        /** * 队列 * durable:是否持久化,默认是false,持久化队列：会被存储在磁盘上，当消息代理重启时仍然存在，暂存队列：当前连接有效 * exclusive:默认也是false，只能被当前创建的连接使用，而且当连接关闭后队列即被删除。此参考优先级高于durable * autoDelete:是否自动删除，当没有生产者或者消费者使用此队列，该队列会自动删除。 * * @return */
        public Queue directQueue() { 
            //一般设置一下队列的持久化就好,其余两个就是默认false
            return new Queue(queue, true);
        }
    
        /** * 交换机 * Direct交换机 起名：TestDirectExchange */
        DirectExchange directExchange() { 
            return new DirectExchange(exchange, true, false);
        }
    
        /** * 绑定 将队列和交换机绑定 * * @param directQueue * @param directExchange * @return */
        Binding bindingDirect(Queue directQueue, DirectExchange directExchange) { 
            return BindingBuilder.bind(directQueue).to(directExchange).with(routingKey);
        }
    }

附录：  
一篇比较好的博客：[https://www.jianshu.com/p/382d6f609697][https_www.jianshu.com_p_382d6f609697]

[https_www.jianshu.com_p_382d6f609697]: https://www.jianshu.com/p/382d6f609697