使用Spring Integration框架的TCP会话



我试图使用Spring集成创建一个iso8385 TCP服务器。典型的场景如下:

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

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

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

有人知道怎么做吗?

实际上<int-tcp:tcp-inbound-gateway>为您做了这些事情:

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

我对iso8385有一些经验,但我不认为有理由在这里处理MCCterminalId来关联消息。

ISO message types提供一些路由逻辑会更有趣。

最新更新