RabbitMq如何配置多个多个Virtual host生产者和消费者

** springboot服务下进行rabbitmq生产和消费自定义配置@Configuration

1、生产者进行配置 1-1配置主连接工厂

@Bean("connectionFactory")
    @Primary//这个地方必须声明一个唯一主要的
    public CachingConnectionFactory connectionFactory(){
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(host,port);
        cachingConnectionFactory.setUsername(username);
        cachingConnectionFactory.setPassword(password);
        cachingConnectionFactory.setVirtualHost(virtualHost);
        return cachingConnectionFactory;
    }

1-2配置主模板

    @Bean("rabbitTemplate")
    @Primary
    public RabbitTemplate rabbitTemplate(@Qualifier("connectionFactory") CachingConnectionFactory connectionFactory){
        return new RabbitTemplate(connectionFactory);
    }

1-3配置次连接工厂

 @Bean("connectionSecondFactory")
    public CachingConnectionFactory connectionSecondFactory(){
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(host,port);
        cachingConnectionFactory.setUsername(username);
        cachingConnectionFactory.setPassword(password);
        cachingConnectionFactory.setVirtualHost(virtualHostOld);
        return cachingConnectionFactory;
    }

1-4配置次模板

  @Bean("rabbitTemplateSecond")
    public RabbitTemplate rabbitTemplateSecond(@Qualifier("connectionSecondFactory") CachingConnectionFactory connectionSecondFactory){
        return new RabbitTemplate(connectionSecondFactory);
    }

2、消费者进行配置 2-1、自定义消费者监听工厂

    @Bean("newContainerFactory")
    public SimpleRabbitListenerContainerFactory newContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,
                                                                    @Qualifier("connectionSecondFactory") ConnectionFactory connectionFactory){
        SimpleRabbitListenerContainerFactory listenerContainerFactory = new SimpleRabbitListenerContainerFactory();
        listenerContainerFactory.setAcknowledgeMode(AcknowledgeMode.AUTO);
        configurer.configure(listenerContainerFactory, connectionFactory);
        return listenerContainerFactory;

    }

2-2、指定自定义消费者工厂进行监听消费 2-2-1、执行自定义消费工厂进行消息对列消费

 @RabbitListener(queues =  "${queue.****}",containerFactory ="newContainerFactory" )

2-2-2、默认工厂进行消息对列消费

    @RabbitListener(queues = ComboRabbitMQQueneConstant.QUEUE_COMBO_ORDER_PAY)

2-2-3、默认工厂进行消息对列消费，如果当前对列不存在主动创建

 @RabbitListener(queuesToDeclare = @Queue(value = AspectRabbitMQQueneConstant.QUEUE_ASPECT_AOP_LOG))