无法使用 Netty 将 JSON POST 到服务器

Posted 2023-03-14

【中文标题】无法使用 Netty 将 JSON POST 到服务器

【英文标题】：Can't POST JSON to server using Netty

【发布时间】：2012-04-11 12:00:31

【问题描述】：

我遇到了一个非常非常基本的问题：使用 HttpRequest 到 POST 向使用 Netty 的服务器发送少量 JSON。

通道连接后，我准备这样的请求：

HttpRequest request = new DefaultHttpRequest(
    HttpVersion.HTTP_1_1, HttpMethod.POST, postPath);
request.setHeader(HttpHeaders.Names.CONTENT_TYPE, "application/json");
String json = "\"foo\":\"bar\"";
ChannelBuffer buffer = ChannelBuffers.copiedBuffer(json, CharsetUtil.UTF_8);
request.setContent(buffer);

channel.write(request);
System.out.println("sending on channel: " + json);

最后一行打印出"foo":"bar"，这是格式正确的JSON。

但是，我使用 Flask 在 Python 中编写的一个非常简单的回显服务器会显示请求，但它没有 body 或 json 字段，就像无法将正文正确解析为 JSON。

当我简单地使用curl 发送相同的数据时，回显服务器会正​​确找到并解析 JSON：

curl --header "Content-Type: application/json" -d '"foo":"bar"' -X POST http://localhost:5000/post_path

我在 Netty 中的管道由以下组成：

return Channels.pipeline(
    new HttpClientCodec(),
    new MyUpstreamHandler(...));

MyUpstreamHandler 扩展 SimpleChannelUpstreamHandler 并且是在通道连接后尝试发送 HttpRequest 的位置。

再一次，我完全不知所措。任何帮助将不胜感激。

【参考方案1】：

正如 Veebs 所说，您必须设置一些 http 标头，我也遇到了同样的问题并且丢失了几个小时，我使用以下代码让它工作:)。

    import static org.jboss.netty.handler.codec.http.HttpHeaders.Names.*;

    ......  

    HttpRequest httpRequest = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, "/post_path");

    final ChannelBuffer content = ChannelBuffers.copiedBuffer(jsonMessage, CharsetUtil.UTF_8);

    httpRequest.setHeader(CONTENT_TYPE, "application/json");
    httpRequest.setHeader(ACCEPT, "application/json");

    httpRequest.setHeader(USER_AGENT, "Netty 3.2.3.Final");
    httpRequest.setHeader(HOST, "localhost:5000");

    httpRequest.setHeader(CONNECTION, "keep-alive");
    httpRequest.setHeader(CONTENT_LENGTH, String.valueOf(content.readableBytes()));

    httpRequest.setContent(content);

    channel.write(httpRequest);

【参考方案2】：

不确定您是否启用了 http keep alive on，但如果这样做，您可能必须在标头中发送内容长度。

【讨论】：

这确实是问题所在。我最初放了以下内容：request.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.getByteArray().length)); 但缓冲区的底层byte[] 似乎来自一个池，而不是从复制缓冲区的json 派生而来。因此，回首过去，它返回的是53，而不是13。此时，我省略了对setHeader 的调用，有点希望Netty 会根据传递给request.setContent 的参数简单地为我添加它。正如 Jestan 指出的，我必须使用 buffer.readableBytes()。