如何在netty中设置不关闭连接的读取超时？

Question

我有一个netty服务器，它接收来自客户端的请求，向另一个服务器发出请求，然后在对原始客户端请求的响应中使用来自第二个请求的响应。我希望对第二台服务器的请求有一个较短的超时（~40ms），以便在超时时发送一般响应，但我不想关闭与第二台服务器的连接。相反，我将在超时请求到达时放弃响应，然后将连接返回到我的池。

在Netty最好的方法是什么？我尝试过ReadTimeoutHandler，但当超时发生时，这似乎会关闭与第二台服务器的连接。

Answer 1

根据您的需求，您可能需要围绕与第二台服务器的连接编写自己的定时管理。此外，由于您提到的连接池可能意味着您对可以同时建立到第二台服务器的连接数量也有限制（当然，总是有限制的，这取决于您是否真的需要担心）。

对于一个简单的情况，您不必担心将出站请求排队，您只需要创建ReadTimeoutHandler的副本并根据需要修改它，最有可能的方法是让它从上下文中拉回一个回调供调用，而不是在其readTimedOut（）方法中关闭连接。

在你要排队出站请求的情况下，你应该考虑在队列上花费的时间以及接收响应的时间，所以你的解决方案需要你自己的计时器，一旦你把一个项目放到出站队列中就开始了。此外，您需要一种在计时器和返回的有效结果之间进行同步的方法（您只希望发送一个响应，而不是在计时器超时时发送一个响应，以及在第二个服务器的响应进入时发送一个响应）。要做到这一点，我想您需要使用某种类型的管理器对象，该对象包含对通道的引用，您的回调通过该管理器写回。

例如（伪代码）

MyStateManager manager = new MyStateManager(channel);
// Scheduled a timer task for 40ms from now to invoke the callback
// method of your ReadTimedOutCallback and send a message through the manager
myTimer.schedule(new ReadTimedOutCallback(manager),40);
// Send an outbound request to server 2 through a class that queues
// and manages such requests asynchronously.  When the request is complete
// it invokes the callback method of RequestCompletedCallback which then
// sends a response through the manager.
myAsyncOutboundServerRequester.request(new RequestCompletedCallback(manager));
// ... finish and return the thread to Netty for use with other requests
// while the async tasks process

简单形式的管理器类似于（不包括异常处理、通道状态检查等）：

public class MyStateManager
{
    private final Channel channel;
    private AtomicBoolean messageSent = new AtomicBoolean(false);
    public MyStateManager(Channel channel)
    {
        this.channel = channel;
    }

    // Called by the ReadTimeoutCallback
    public void sendGenericResponse()
    {
        if (messageSent.getAndSet(true))
        {
           //... write generic response to channel
           ChannelFuture future = channel.write... 
           // Add listeners to future, etc
        } 
    }

    // Called by the RequestCompletedCallback
    public void sendResponse(MyResponseObject response)
    {
        if (messageSent.getAndSet(true))
        {
            // write returned response to channel
            ChannelFuture future = channel.write(response);
            // Add listeners to future, etc
        }
    }

}

您可能仍然希望对与第二台服务器的连接进行某种类型的超时检查，以便在连接没有响应的时间过长（30秒或一分钟或其他时间）时关闭连接。