java - 使用关联消息进行与旧服务器的 TcpOutboundGateway 连接的正确方法是什么

Question

我的理解是 TcpOutboundGateway 关联 tcp 请求和响应，但我不确定如何使用它。

下面的代码片段通过 TcpOutboundGateway 发送消息以与旧系统通信。

message = new GenericMessage("ccs?cmd=5&itm="+(16600+t)+"&rf=2");
Test.sendChannel.send(message); // sendChannel is a DirectChannel. 
//Blocks here until reply comes in (in single use and cached)

我有一个端点来处理响应:

@ServiceActivator(inputChannel = "replyChannel")
public void handleReply(byte[] rawRes) {
    // handle the reply.
}

handleReply(...) 需要代码中发送点可用的上下文，反之亦然。使用 Threadlocal 将上下文传递给处理程序可以(在本例中)，但似乎是一个坏主意。

我已经看过这些示例，但它们似乎与我的代码相当不同(我认为是因为我使用的是 Spring boot)，所以提前道歉 - 我确信我忽略了显而易见的事情，但希望得到一些帮助。

Answer 1

您可以在 RequestMessage 的 MessageHeaders 中携带上下文，并且 replyMessage 将随请求的 header 一起提供。

对于 replyChannel 上的 POJO 处理程序，您可以使用 @Header("myContext") 添加另一个方法参数。