如何使用弹簧集成创建异步单例套接字服务器？

Question

我想使用spring-integration 实现以下目标：拥有一个不断接收和写入数据的单例打开套接字，asyncrhon！

这意味着我必须打开一个不断从单个套接字读取的套接字，调度每个消息以进行异步处理，并通过套接字返回也异步的响应。

我怎样才能实现这种异步模式？

特别是：我如何使用Serializer/Deserializer？据我了解，仅在 new 套接字连接上调用序列化程序，所以在我的情况下，仅在第一条消息开始时调用一次？

@Configuration
public class SocketConfig {
    @Bean
    public TcpConnectionFactoryFactoryBean tcpFactory(MyConverter converter) {
        TcpConnectionFactoryFactoryBean fact = new TcpConnectionFactoryFactoryBean();
        fact.setType("server");
        fact.setPort(PORT);
        fact.setUsingNio(true); //should I use true or false?
        fact.setSingleUse(false); //keep socket constantly open
        fact.setSerializer(converter);
        fact.setDeserializer(converter);
        return fact;
    }

    @Bean
    public TcpInboundGateway serverGateway(
            @Qualifier("tcpFactory") TcpConnectionFactoryFactoryBean factory,
            @Qualifier("serverChannel") MessageChannel serverChannel) throws Exception {
        TcpInboundGateway g = new TcpInboundGateway();
        g.setConnectionFactory(factory.getObject());
        g.setRequestChannel(serverChannel);
        return g;
    }

}

@MessageEndpoint
public class SocketEndpoint {

    @ServiceActivator(inputChannel = "serverChannel")
    public Object run(Object obj) {

    }
}


@Service
public class MyConverter implements Serializer<Object>, Deserializer<Object> {
    //read from socket
    @Override
    public Object deserialize(InputStream inputStream) {
    }

    //send back to socket
    @Override
    public void serialize(Object message, OutputStream outputStream) {
    }
}

Answer 1

网关用于单个请求/响应对。

如果您需要为单个请求发送多个响应，则必须使用collaborating channel adapters as described in the documentation。

协作适配器也可用于（服务器端或客户端）完全异步通信（而不是请求/回复语义）。

在服务器端，必须小心填充 ip_connectionId 标头，因为它用于将消息与连接相关联。源自入站适配器的消息将自动设置标头。如果您希望构建其他要发送的消息，则需要设置标头。可以从传入的消息中捕获标头值。