SpringBoot整合rabbitMQ,启动服务便创建交换机和队列

系统管理员 2023-07-12 14:53 1阅读 0赞

1.启动服务不默认先创建队列的话,在启动消费者时候,消费者服务监听会找不到对应的队列而报错,启动失败

@Component
    public class OrderRabbitMQConfig {
    
        @Autowired
        RabbitAdmin rabbitAdmin;
    
        /**
         * 派单队列
         */
        public static final String ORDER_DIC_QUEUE = "order_dic_queue";
        /**
         * 补单对接
         */
        public static final String ORDER_CREATE_QUEUE = "order_create_queue";
        /**
         * 订单交换机
         */
        private static final String ORDER_EXCHANGE_NAME = "order_exchange_name";
    
        /**
         * 定义派单队列
         */
        @Bean
        public Queue directOrderDicQueue() {
            return new Queue(ORDER_DIC_QUEUE);
        }
    
        /**
         * 定义补派单队列
         */
        @Bean
        public Queue directCreateOrderQueue() {
            return new Queue(ORDER_CREATE_QUEUE);
        }
    
        /**
         * 定义订单交换机
         */
        @Bean
        DirectExchange directOrderExchange() {
            return new DirectExchange(ORDER_EXCHANGE_NAME);
        }
    
        /**
         * 派单队列与交换机绑定
         */
        @Bean
        Binding bindingExchangeOrderDicQueue() {
            return BindingBuilder.bind(directOrderDicQueue()).to(directOrderExchange()).with("orderRoutingKey");
        }
    
        /**
         * 补单队列与交换机绑定
         */
        @Bean
        Binding bindingExchangeCreateOrder() {
            return BindingBuilder.bind(directCreateOrderQueue()).to(directOrderExchange()).with("orderRoutingKey");
        }
    
        //创建初始化RabbitAdmin对象
        @Bean
        public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
            RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
            // 只有设置为 true，spring 才会加载 RabbitAdmin 这个类
            rabbitAdmin.setAutoStartup(true);
            return rabbitAdmin;
        }
        //创建交换机和对列
        @Bean
        public void createExchangeQueue (){
            rabbitAdmin.declareExchange(directOrderExchange());
            rabbitAdmin.declareQueue(directOrderDicQueue());
            rabbitAdmin.declareQueue(directCreateOrderQueue());
        }
        
    }

#配置virtual-host虚拟主机
    spring.rabbitmq.virtual-host=/zhang_rabbit
    #ip地址
    spring.rabbitmq.host=127.0.0.1
    #用户名  密码
    spring.rabbitmq.username=zhang
    spring.rabbitmq.password=zhang
    #连接端口号
    spring.rabbitmq.port=5672