spring boot整合rabbitmq ack实现多个队列

Question

从别人手里拿到的代码是这样字的：@Component
public class SmsClient {

@Autowired
private SmsSendService smsSendService;



/**
 * 消费者数量，默认10
 */
private static final int DEFAULT_CONCURRENT = 10;
/**
 * 每个消费者获取最大投递数量，默认50
 */
private static final int DEFAULT_PREFETCH_COUNT = 5;


@Bean
public MessageConverter jsonMessageConverter(ObjectMapper objectMapper) {
    return new Jackson2JsonMessageConverter(objectMapper);
}

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setMessageConverter(new Jackson2JsonMessageConverter());
    return template;
}

@Bean
public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(
        SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {

    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setPrefetchCount(DEFAULT_PREFETCH_COUNT);
    factory.setConcurrentConsumers(DEFAULT_CONCURRENT);
    factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
    configurer.configure(factory, connectionFactory);
    return factory;
}

@RabbitListener(queues = MqConstant.QUEUE_NAME, containerFactory = "simpleRabbitListenerContainerFactory")
@RabbitHandler
public void process(@Payload MessageBody messageBody,
                           @Headers Map<String, Object> headers,
                           Channel channel) throws Exception {....}

但这里只是监听一个队列，请问我怎样可以按照这个模式实现监听多个队列？

Answer 1

配置多个监听，监听不同的queues好了