如何使用spring集成创建异步singleton socket服务器？

Question

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

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

如何实现这种异步模式？

特别是：如何使用序列化器/反序列化器？据我所知，序列化程序只在新的套接字连接上调用，所以在我的情况下，只在第一条消息的开头调用一次？

@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

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

如果您需要为单个请求发送多个响应，则必须使用协作通道适配器，如留档中所述。

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

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