与 Spring Integration 框架的 TCP 会话

Question

我正在尝试使用 Spring Integration 创建一个 iso8385 TCP 服务器。一个典型的场景如下：

• 客户端连接到服务器并存放 ISO8385 消息
• 服务器处理消息
• 服务器制定响应并关闭连接

我想跟踪每个新的 TCP 连接，并为它创建一个标识符，以便将每个处理与连接的客户端相关联。但我不知道该怎么做。我们的想法是：

• 一个 tcp 入站适配器，将 ISO8385 转换为 java 类
• 将处理消息的服务激活器
• 一个 tcp 出站适配器，将 java 类转换为 ISO8385 消息
• 一个频道（但在哪里？）
• 在所有这些之间共享的 TCP 会话标识符

有人知道怎么做吗？

Answer 1

其实<int-tcp:tcp-inbound-gateway> 为你做事：

• 你配置<int-tcp:tcp-connection-factory type="server">
• 将其注入<int-tcp:tcp-inbound-gateway>
• 所有其他correlation 逻辑都封装在最后一个中

我对@9​​87654326@ 有一些经验，但我认为没有理由在这里处理MCC 或terminalId 来关联消息。

为ISO message types 提供一些路由逻辑会更有趣。但这是一个不同的故事......