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

Question

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

if(gateway.HANDSHAKE(HANDSHAKE).equals(HANDSHAKE_RESPONSE))gateway.senddata（data）；

当我扩大规模时，这就不太好了，因为我通过tcp调用的次数增加了一倍，因为我只需要在连接启动时发送send handshake，而不是每次都发送send handshake。此外，我计划保持连接的活力。

@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

请参见连接拦截器。

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

测试用例中使用的HelloWorldInterceptor的工作方式如下：