踏破九重天阙 2019-09-29 10:37 采纳率: 66.7%
浏览 1242
已结题

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

从别人手里拿到的代码是这样字的:@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 {....}

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

  • 写回答

1条回答

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 已结题 9月2日
      • 已采纳回答 9月2日

      悬赏问题

      • ¥40 python,计算机程序运行结果很奇怪
      • ¥15 有关时间计算器的问题
      • ¥200 Chrome浏览器自动保存密码需要解密!来人
      • ¥18 关于#c语言#的问题:如何把下面几个代码放在一起编序号,然后输入对应数字运行对应代码,还可以返回重输
      • ¥30 windows下无法运行go test的问题
      • ¥15 多个Rigify骨骼 导入一起 后 没有 控制器面板
      • ¥15 想问一下sprak ada语言的pre和post怎么设
      • ¥15 使用python将分子模拟输出.gro文件
      • ¥15 港诡实录的背包系统拆解
      • ¥15 宽带IP网络路由器的初始路由表和最终路由表