来自netty服务器的请求和响应挂起

Question

我有以下代码来创建一个基于netty示例中创建的http服务器的netty web服务器。我的业务逻辑如下。

public class HttpServerHandler extends SimpleChannelInboundHandler<Object> {

    private final static Logger LOG = LogManager
        .getLogger(HttpServerHandler.class);
    private WorkflowService workflowService;
    private HttpRequest request;
    private final StringBuffer buff = new StringBuffer();
    private API avalancheApi;

    public HttpServerHandler(WorkflowService workflowService) {
        this.workflowService = workflowService;
        this.avalancheApi = new API(this.workflowService);
    }


    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        LOG.debug("channelActive");
        LOG.debug(ctx.toString());
    };

    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) {
        ctx.flush();
    }

    @Override
    public void channelRead0(ChannelHandlerContext ctx, Object msg)
        throws IOException {
        avalancheApi.setContext(ctx);
        if (msg instanceof HttpRequest) {
            HttpRequest request = this.request = (HttpRequest) msg;
            if (HttpHeaders.is100ContinueExpected(request)) {
                send100Continue(ctx);
            }
            String command = getCommand(request);
            LOG.debug(command);
            Map<String, List<String>> parameters = getParameters(request);
            LOG.debug(parameters);
            switch (command) {
            case "/login":
                ctx = avalancheApi.login(parameters);
                break;
            case "/test":
                ctx = avalancheApi.test();
                break;
            default:
                break;
            }
        }
        if (msg instanceof LastHttpContent) {
            LOG.debug("msg is of LastHttpContent");
        }
        if (!HttpHeaders.isKeepAlive(request)) {
            // If keep-alive is off, close the connection once the content is
            // fully written.
            ctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(
                ChannelFutureListener.CLOSE);
        }
    }


public class API {

    private static final Logger LOG = LogManager.getLogger(API.class);
    private ChannelHandlerContext ctx;
    private HttpResponse response;
    private WorkflowService workflowService;

    public API(WorkflowService workflowService) {
        this.workflowService = workflowService;
        this.ctx = null;
    }

    public void setContext(ChannelHandlerContext ctx) {
        this.ctx = ctx;
    }

    public ChannelHandlerContext login(Map<String, List<String>> parameters)   {
        boolean success;
        String username = getUsername(parameters);
        String password = getPassword(parameters);
        User user = null;
        user = workflowService.login(username, password);
        success = validateLogin(user);
        this.response = writeLoginResponse(success);
        this.ctx.write(this.response);
        writeLoginContext(success, response);
        return this.ctx;
    }

    private void writeLoginContext(boolean success, HttpResponse response) {
        JsonObject jsonResponseMessage = new JsonObject();
        jsonResponseMessage.addProperty("result", success);
        LOG.debug(jsonResponseMessage.toString());
        this.ctx.write(Unpooled.copiedBuffer(jsonResponseMessage.toString(),
            CharsetUtil.UTF_8));

        this.response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,
            jsonResponseMessage.toString().length());
    }

    private HttpResponse writeLoginResponse(boolean success) {
        if (success)
            return createSuccessfullLoginResponse();
        else
            return createLoginFailureResponse();
    }

    private HttpResponse createLoginFailureResponse() {
        return Response.loginFailureResponse();
    }

    private HttpResponse createSuccessfullLoginResponse() {
        return Response.loginSuccessResponse();
    }
}

Response类只创建应用程序/json的响应和content_type。内容长度在API类中设置。使用带有请求的python客户端，导致在http://localhost/login?username=name&password=pass中发出的请求只工作一次。第二次，一切正常，但它没有完成对请求的处理并发送响应对象。Api调用可以正常执行，也可以得到打印LastHttpContext消息的消息。这个问题有时也会发生在浏览器上。我是不是遗漏了什么？可能内容数据和内容长度不匹配？会不会是当从python客户端发出请求时，前一个上下文的内容没有被刷新，并且上下文的头和内容长度的content_length值不匹配？

Answer 1

只是胡乱猜测

this.response.headers().set(HttpHeaders.Names.CONTENT_LENGTH,
         jsonResponseMessage.toString().length());

相反，你不应该做jsonResponseMessage.toString().getBytes().length吗?？有时，一个字符不仅仅是一个字节。

Answer 2

我的猜测是，您已经覆盖了API类中的上下文，因此，将响应写到了错误的上下文。您的HttpServerHandler是否标记为@Shareable？