Spring集成-任务执行器卡住了

Question

我正在开发一个现有的Spring集成代码，该代码被卡住了。

代码：

<int-jdbc:outbound-gateway query="..." />

<int:splitter input-channel="..." output-channel="queueChannel"/>

<int:channel id="queueChannel">
    <int:queue capacity="25" />
</int:channel>

<int:service-activator ref="..."
    input-channel="queueChannel" output-channel="..." method="xxx">
    <int:poller max-messages-per-poll="25" fixed-delay="100"
    receive-timeout="30000"  task-executor="reqExecutor"/>
</int:service-activator>

<task:executor id="reqExecutor" pool-size="25" queue-capacity="5" rejection-policy="CALLER_RUNS" /> 

在网上做了一些搜索之后，下面是我对代码的理解。如果我错了，请纠正我：

拆分器输出通道是容量为25的队列通道，这意味着它将从查询中获取一批25条记录。

现在，service activator中编写的代码将每100毫秒轮询一次，并从队列通道中获取25条消息。Service Activator与task executor一起在多线程环境中运行。

任务执行器的池大小为25。这是一次可以运行的最大线程数。队列容量为5。若所有线程都很忙，那个么执行器将把它们放入队列中。如果队列容量达到5，则执行者将拒绝该任务。

拒绝策略是CALLER\u RUNS。执行人将在拒绝时使用主流程。

应用程序性能可能会受到CALLER_RUNS拒绝策略的影响。但是其他策略会丢弃或中止线程。因此，更改拒绝策略不是解决方案。

我是否应该更改任务执行程序的池大小或队列容量来解决问题。是否有任何首选值。它会产生什么影响。

或者，我应该更改轮询器的固定延迟吗？

编辑1：

在日志中，下面的行反复出现，过程没有完成：

Received no Message during the poll, returning 'false'

编辑2：

我的问题是否与以下链接中提到的问题相关：

http://docs.spring.io/autorepo/docs/spring-integration/3.0.x/reference/html/messaging-endpoints-chapter.html#async-polling

另外，我不清楚轮询器的接收超时属性。

Answer 1

做了一些代码优化后就解决了。代码中有两个主要问题：

>

HashMap键的hashcode和equals方法没有被覆盖。hashmap用于缓存查询，但由于缺乏被覆盖的方法，它无法正常工作。

在Spring集成代码中有一个插入查询，它插入记录大约20000次。因为，AFAIK我们不能在Spring集成中进行批量更新。所以，我将插入查询提取到java类中，并进行了批量更新。

然而，我想知道，为什么线程转储和内存转储没有给出任何提示？

感谢Geek和Gary帮我解决问题。

Answer 2

接收超时是轮询器（reqExecutor）线程在队列通道中等待消息到达的时间。如果在没有消息到达后过期，线程将返回到池。

如果消息到达，它将在线程上处理，然后线程返回池。

如果您无法从线程转储中解决问题，请将其发布到某个地方（不在这里-可能太大）-粘贴箱或github gist。