Spring Integration TCP - 在发送数据之前使用消息启动握手

Question

我正在使用@MessagingGateway 将数据发送到服务器。我为出站网关配置了 AbstractClientConnectionFactory 和 @ServiceActivator。

为了向我的服务器发送数据，我需要在连接启动时发送握手消息。如果来自服务器的响应是我期望的握手响应，那么我发送有意义的数据。我最初的解决方案是

if (gateway.handshake(HANDSHAKE).equals(HANDSHAKE_RESPONSE)) gateway.sendData(data);

当我扩大规模时，这不是很好，因为我已经通过 tcp 将我的呼叫增加了一倍，因为我只需要在连接启动时发送发送握手，而不是每次都发送。另外，我计划保持连接活跃。

那么在连接启动时，我怎样才能实现这个自定义握手呢？

@Bean
public AbstractClientConnectionFactory clientCF() {
    TcpNetClientConnectionFactory tcpNetClientConnectionFactory = new TcpNetClientConnectionFactory(host, port);

    tcpNetClientConnectionFactory.setSerializer(new serializerDeserializer());
    tcpNetClientConnectionFactory.setDeserializer(new serializerDeserializer());
    tcpNetClientConnectionFactory.setSoKeepAlive(true);
    tcpNetClientConnectionFactory.setSoTimeout(soTimeout);
    return tcpNetClientConnectionFactory;

}

@Bean
@ServiceActivator(inputChannel = "toTcp")
public MessageHandler tcpOutGate(AbstractClientConnectionFactory connectionFactory) {
    TcpOutboundGateway gate = new TcpOutboundGateway();
    gate.setConnectionFactory(connectionFactory);
    return gate;
}


@Bean
public MessageChannel fromTcp() {
    return new DirectChannel();
}

Answer 1

见Connection Interceptors。

可以使用对 TcpConnectionInterceptorFactoryChain 的引用来配置连接工厂。拦截器可用于向连接添加行为，例如协商、安全和其他设置。框架目前没有提供拦截器，但例如，请参阅源存储库中的 InterceptedSharedConnectionTests。

测试用例中使用的HelloWorldInterceptor的工作原理如下：

...

虽然框架中没有标准拦截器，但有test cases that show how to use them for an initial handshake, for example here 和here。

测试比您需要的更复杂，因为它们测试多个嵌套的拦截器。

第一次打开套接字时，hello world test interceptors 发送 Hello 并期待 World!。它们为客户端和服务器端实现握手。