java async nio ReadPendingException

Question

我已经写了一个NIO.2的http客户端。在读取响应时，可能没有接收到完整的响应，所以一旦我在字节缓冲区上获得content-length头，我就知道还剩下多少，所以我使用它或读取，直到完成处理程序告诉我我得到了0个字节。简化我使用CompletionHandler解决的问题

public void completed(Integer result, ClientSession clientSession) {
    final ByteBuffer buffer = clientSession.getBuffer();
    final ResponseParser responseParser = clientSession.getResponseParser();

    buffer.flip();
    if (responseParser.parse(buffer)) {
        final HttpResponse httpResponse = responseParser.httpResponse();
        doStuff(httpResponse);    
        buffer.clear();
    } else {
        clientSession.getChannel().read(buffer, clientSession, this);
    }
}

如果响应读取不完整，通道上的读取将返回到相同的完成处理程序，并且该过程将递归，直到完成。所示的完成处理程序在前面的http request write中指定，例如

clientSession.getChannel().write(buffer, clientSession, new ReadHandler())

所有的工作都很好，直到我增加负载并得到一个ReadPendingException。这是我的理解，这不应该发生，只要不超过1个读/写是在完成处理程序中执行。我的错误是什么？

Answer 1

您必须实现一个缓冲区队列，并等待读取完成。如果队列不是空的，则使用poll()获取buffer。您必须定义一个标志(busy)来监控读取操作的状态。您可能还必须实现一个与buffer元素相关的clientSession队列。对写操作做同样的事情。

    private Queue<ByteBuffer> input = new LinkedList<>();
                    ...
                    try {
                           
                            clientSession.getChannel().read(buffer, clientSession, this);

                        }catch(ReadPendingException ex) {

                            input.add(buffer);
                            busy= true;

                        }

                     ...