我的应用程序正在通过 Jms MessageListener 类读取消息，并且在某个时间点它会抛出异常任务拒绝异常。我知道你们大多数人都会说线程数超出了最大池大小而且队列也满了。
但我观察到一些事情。发送到 MessageListener 类从中获取消息的队列的消息数为 10353，我的 threadPoolExecutor 的 spring 属性如下：
<bean id="ticketReaderThreadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" scope="singleton" destroy-method="destroy">
<property name="corePoolSize" value="10" />
<property name="maxPoolSize" value="150" />
<property name="queueCapacity" value="11000" />
</bean>
现在根据我的说法， maxPoolSize 足以处理这么多请求。因此，如果你们中的任何人都可以给出除了 maxPoolSize 违规之外的原因，请这样做。
我们现在第二次面临这个问题，之前我们已经尝试增加 maxPoolSize，但 15 天后我们再次遇到这个异常，每天大约 5000 到 8000 次。
Update:
这是异常的完整堆栈跟踪：
从队列读取/处理消息时发生一般异常
org.springframework.core.task.TaskRejectedException：执行器 [java.util.concurrent.ThreadPoolExecutor@408b9775] 未接受任务：com.batman.rapid.rapidserver.sla.TicketHandler@1be5e598
在 org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:244)
在 com.batman.rapid.rapidserver.sla.JmsTicketReceiver.onMessage(JmsTicketReceiver.java:58)
在org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener（AbstractMessageListenerContainer.java:560）
在org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener（AbstractMessageListenerContainer.java:498）
在org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener（AbstractMessageListenerContainer.java:467）
在 org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
在org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute（AbstractPollingMessageListenerContainer.java:263）
在 org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
在 org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
在 org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
在 java.lang.Thread.run(Thread.java:662)
引起原因：java.util.concurrent.RejectedExecutionException
在 java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1774)
在java.util.concurrent.ThreadPoolExecutor.reject（ThreadPoolExecutor.java：768）
在 java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:656)
在 org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:241)
... 10 更多
这是相关代码：
if (message instanceof TextMessage)
{
textMessage = (TextMessage) message;
ticketReaderThreadPool.execute(new TicketHandler(textMessage.getText()));
}
以下是请求的配置：
<!-- End of JMS Queue Support -->
<bean id="ticketReaderThreadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" scope="singleton" destroy-method="destroy">
<property name="corePoolSize" value="10" />
<property name="maxPoolSize" value="150" />
<property name="queueCapacity" value="11000" />
</bean>
<bean id="notificationThreadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" scope="singleton" destroy-method="destroy">
<property name="corePoolSize" value="10" />
<property name="maxPoolSize" value="100" />
<property name="queueCapacity" value="10000" />
</bean>
<bean id="notificationManager" class="com.batman.rapid.rapidserver.sla.scheduler.NotificationManager" scope="singleton">
<property name="defaultPercent" value="80"></property>
</bean>
<bean id="dbUpdateThreads" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" scope="singleton" destroy-method="destroy">
<property name="corePoolSize" value="1" />
<property name="maxPoolSize" value="100" />
<property name="queueCapacity" value="10000" />
</bean>
不确定确切原因是什么。然而我强烈地感觉到，最大消息计数可能超出了您设置的 maxqueueCapacity 。然而，您使用的不同方法与 JMS 的一般用法不同。通常，在 DefaultMessageListener 中，我们配置并行处理异步处理的最大消费者数量。根据服务器资源，我们配置服务器可以处理的最大消费者
但是，在您的情况下，从 DefaultMessageListener 读取消息并生成新线程并在新线程中执行业务逻辑。由于消息侦听器读取速度快于业务逻辑，因此任务会累积在线程任务队列中。
我建议重新处理您当前的实施。因为它不支持交易。我的意思是，当服务器崩溃时，任务中的所有待处理消息处理都将被终止/丢失，并且由于您设置了自动确认，因此该消息将从队列中删除。其他问题如手动设置线程队列限制等。
最后回到你的问题，你可以快速检查一下你设置的150个线程中是否有锁
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
