如何在带有弹簧集成的套接字上设置回复超时？

Question

我如下创建一个nio 套接字服务器。

如何定义一个超时时间，如果超过了超时时间，它会自动向客户端发送某种错误响应？

@MessageEndpoint
public class SocketEndpoint {
    @ServiceActivator(inputChannel = "serverChannel", sendTimeout = "5000")
    public String handleMessage(String message) {
        TimeUnit.SECONDS.sleep(60);
        //...TODO how to send some kind of "timeout exceeded" response?
    }
}

    @Bean
    public TcpConnectionFactoryFactoryBean factory() {
        TcpConnectionFactoryFactoryBean f = new TcpConnectionFactoryFactoryBean();
        f.setType("server");
        f.setPort(port);
        f.setUsingNio(true);
        f.setSingleUse(false);
        f.setDeserializer(deserializer);
        f.setSerializer(serializer);
        return f;
    }

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

Answer 1

没有办法做到这一点。

在客户端，您可以设置套接字超时，这样如果在该时间内没有收到回复，客户端就会收到异常。