在spring中节流@JMSListener（防止TaskRejectedException）

Question

我当前有一个配置有以下线程池的JMSListener：

    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5);
    executor.setMaxPoolSize(10);
    executor.initialize();

我正在监听的队列有超过100条消息，当我启动侦听器时，它将处理前10条消息，没有任何问题，然后我将为其余的消息获得TaskRejectedException异常。

我的意图是，如果没有可用的线程来处理消息，@JMSListener不应该拉出任何新消息。有没有人知道这个配置是不是可以？我使用的是SpringBoot的1.5.3版本。

Answer 1

如果您不想丢失消息,就不应该使用执行器；容器将在每个消息在执行器中排队后立即对其进行ack。如果系统死亡，任何尚未处理的消息都将丢失。

相反，使用容器的并发设置来多线程侦听器。

如果您确实必须使用executor并且不介意丢失消息，请在Executor-SetRejectedExecutionHandler()中使用调用方运行策略。