消费者无法在60000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?

问题描述 投票:0回答:1

记录器错误:

消费者无法在60000毫秒内启动;执行任务执行器有足够的线程来支持容器并发?

我该如何解决?

非常感谢。

我试图这样更改我的配置:

@配置公共类RabbitMQConfig {

private final SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory;

private final RabbitTemplate mqTemplate;

@Autowired
public RabbitMQConfig(SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory,
                      RabbitTemplate mqTemplate) {
    this.simpleRabbitListenerContainerFactory = simpleRabbitListenerContainerFactory;
    this.mqTemplate = mqTemplate;
}

@PostConstruct
public void init() {
    simpleRabbitListenerContainerFactory.setMessageConverter(new Jackson2JsonMessageConverter());
    simpleRabbitListenerContainerFactory.setTaskExecutor(Executors.newCachedThreadPool());
    simpleRabbitListenerContainerFactory.setContainerConfigurer(c -> {
        c.setAutoDeclare(false);
        c.setConsumerStartTimeout(100000L);

    });
    mqTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
}

@Bean
public Queue dlQueue() {
    return new Queue(RabbitMQConstant.DEAD_LETTER_Q, true, false, false);
}

@Bean
public TopicExchange dlExchange() {
    return new TopicExchange(RabbitMQConstant.DEAD_LETTER_EXCHANGE, true, false);
}

@Bean
public Binding dlxBinding() {
    return BindingBuilder.bind(dlQueue()).to(dlExchange()).with(RabbitMQConstant.ROUTE_KEY);
}

}

调试日志也存在,并且Spring Boot启动缓慢。

2020-02-14 12:29:14.861 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:30:54.870 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:32:34.872 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者无法在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:34:14.873 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者未能在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?2020-02-14 12:35:54.877 [main]错误org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer [,,,] hia-api-使用者无法在100000毫秒内启动;任务执行器是否有足够的线程来支持容器并发?

concurrency amqp consumer
1个回答
0
投票

您解决了问题吗?我有同样的问题。

© www.soinside.com 2019 - 2024. All rights reserved.