我在这个网站上读过另一个这样的问题，但我不知道如何解决这个问题。
Spring 集成：应用程序泄漏 SimpleAsyncTaskExecutor 线程？
我的错误类似于上一个链接
SimpleAsyncTaskExecutor-2327" - Thread t@2405
java.lang.Thread.State: WAITING
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <7a224c1> (a java.util.concurrent.CountDownLatch$Sync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
at org.springframework.messaging.core.GenericMessagingTemplate$TemporaryReplyChannel.receive(GenericMessagingTemplate.java:199)
at org.springframework.messaging.core.GenericMessagingTemplate$TemporaryReplyChannel.receive(GenericMessagingTemplate.java:192)
at org.springframework.messaging.core.GenericMessagingTemplate.doReceive(GenericMessagingTemplate.java:130)
at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:157)
at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:45)
at org.springframework.messaging.core.AbstractMessagingTemplate.sendAndReceive(AbstractMessagingTemplate.java:42)
at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:97)
at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:38)
at org.springframework.messaging.core.AbstractMessagingTemplate.convertSendAndReceive(AbstractMessagingTemplate.java:79)
at org.springframework.messaging.core.AbstractMessagingTemplate.convertSendAndReceive(AbstractMessagingTemplate.java:70)
at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:449)
我正在使用
- spring-integration-java-dsl-1.2.3.RELEASE
- 弹簧集成-ip-4.3.17.发布
- spring-integration-http-4.3.17.RELEASE
我的方案是下一个：我通过 API 控制器收到一条消息，并且此消息通过 un TCP 套接字发送。
我已定义一个消息网关接口
@MessagingGateway(defaultRequestChannel = "toTcp.input")
public interface MessageTcpGateway {
@Gateway
public ListenableFuture<Void> sendTcpChannel(byte[] data,
@Header("connectionId") String connectionId );
}
在这样的服务类中使用此接口后：
public void sendMessageTcpGateway(final String bridgeId,final String connectionId, final byte[] message) {
LOGGER.debug("sendMessageTcpGateway connectionId:{} - message:{}", connectionId, message);
if (holder.existsConnection(connectionId)!=null) {
gatewayTcp.sendTcpChannel(message,connectionId);
} else {
LOGGER.error("Not send message connectionId:{} - message:{}", connectionId, message);
}
}
为什么线程正在等待？我的过程是否在等待任何类型的迹象，而我没有被考虑？我猜如果连接不可用或出现任何类型的错误，弹簧集成将引发异常
如何解决此问题？
我想知道为什么不遵循该 SO 线程的建议......ListenableFuture<Void>是解决方案中的瓶颈。正如您在堆栈跟踪中看到的那样，您有doSendAndReceive()，但我想您的目标解决方案实际上是单向的，并且不会为标头中的replyChannel返回任何内容。
您应该考虑只有普通的void返回类型和下游ExecutorChannel。
不幸的是，我们无法从框架端检测到这种情况，因为网关方法的Future返回类型表明您将执行请求-回复异步方式。在您的情况下，它只是一个异步请求，仅此而已。