基于 ISO TCP/RFC 1006 的 TCP 消息

Question

我有一个 Spring Integration 项目，通过注解配置了以下与 TCP 相关的配置：

@Bean
public TcpReceivingChannelAdapter tcpIn(AbstractClientConnectionFactory connectionFactory) {
    TcpReceivingChannelAdapter receiver = new TcpReceivingChannelAdapter();
    receiver.setOutputChannel(fromTcpReceiver());
    receiver.setConnectionFactory(connectionFactory);
    return receiver;
}

@Bean
public AbstractClientConnectionFactory clientFactory() {
    TcpNetClientConnectionFactory factory = new TcpNetClientConnectionFactory(host, port);
    factory.setSoKeepAlive(keepAlive);
    factory.setSoTimeout(timeout);
    return factory;
}

@Bean
public TcpSendingMessageHandler tcpOut(AbstractClientConnectionFactory connectionFactory) {     
    TcpSendingMessageHandler sender = new TcpSendingMessageHandler();
    sender.setConnectionFactory(connectionFactory);
    return sender;
}

在 Spring Integration 中，通过 ISO TCP/RFC 1006 封装 TCP 消息的最佳方式是什么？

基本上，TCP ISO 会在初始连接中添加一个步骤，但还会为每个发送/接收的 TCP 消息添加一个附加标头。

我正在阅读文档，但我不知道这种消息丰富和协商的最佳方式是什么。这可以通过 Spring Integration 实现吗？

我有 3 个想法：

• messageBuilderFactory
• 串行器/解串器
• TcpConnectionInterceptorFactoryChain

欢迎任何帮助/示例

Answer 1

我没有查看 RFC，但您可能需要自定义序列化器/反序列化器的组合，以及自定义 TcpMessageMapper 将标头映射到 Spring Integration 消息标头/从 Spring Integration 消息标头映射。

以MessageConvertingTcpMessageMapper 为例。