一，HTTP解码器可能会将一个HTTP请求解析成多个消息对象。
ch.pipeline().addLast(new HttpServerCodec()); ch.pipeline().addLast(new ParseRequestHandler());
经过HttpServerCodec解码之后，一个HTTP请求会导致：ParseRequestHandler的 channelRead()方法调用多次（测试时 "received message"输出了两次）
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg)
throws Exception {
System.out.println("received message");
可以用HttpObjectAggregator 将多个消息转换为单一的一个FullHttpRequest，如下：
ch.pipeline().addLast(new HttpServerCodec()); ch.pipeline().addLast(new HttpObjectAggregator(65536)); ch.pipeline().addLast(new ParseRequestHandler());
此时，一个HTTP消息(Object msg)是下面这样的。
HttpObjectAggregator$AggregatedFullHttpRequest(decodeResult: success, version: HTTP/1.1, content: CompositeByteBuf(ridx: 0, widx: 17, cap: 17, components=1)) POST / HTTP/1.1 Host: 127.0.0.1:8888 User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64; rv:46.0) Gecko/20100101 Firefox/46.0 Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8 Accept-Language: null Accept-Encoding: gzip, deflate Content-Type: application/x-www-form-urlencoded Content-Length: 17 Cookie: _ga=GA1.1.457486782.1446782739 Connection: keep-alive
从上面可以看出，实体首部字段Content-Length是17，表明实体主体有17个字节。
而我发送的消息是这样的：
HTTP POST 请求，请求体是JSON格式的数据。这里使用的是json-lib解析的 Json字符串。代码如下：
//parse job type 0,1 private String getJobType(FullHttpRequest request) throws IOException{ ByteBuf jsonBuf = request.content(); String jsonStr = jsonBuf.toString(CharsetUtil.UTF_8); JSONObject jsonObj = JSONObject.fromObject(jsonStr); String jobType = jsonObj.getString("jobType"); return jobType; }
需要注意是：使用json-lib解析Json字符串时，需要其他的依赖包如下：
解析完成之后，需要把处理后的结果发送到下一个ChannelHandler，进行下一步的处理。
@Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //do some process ..... ctx.fireChannelRead(job); }
注意，使用的是fireChannelRead()方法，而不是 ctx.writeAndFlush(...)。因为，writeAndFlush/write 是Outbound，它是把消息发送到上一个Handler，进而发送到remote peer，而这里是InBound。具体参考：
这里，通过 ctx.fireChannelRead(job); 将处理后的结果发送到下一个Channel处理。
ch.pipeline().addLast(new HttpServerCodec()); ch.pipeline().addLast(new HttpObjectAggregator(2048)); ch.pipeline().addLast(new ParseRequestHandler()); ch.pipeline().addLast(new OozieRequestHandler());
下一个Handler是OozieRequestHandler，它负责向Oozie Server提交作业，之后返回jobId给客户端(HttpServerCodec Handler 负责底层传输细节)。
Netty构造一个http 响应的方法如下：
String jobId = doPost(jobConfig);
FullHttpResponse response = new DefaultFullHttpResponse(
HttpVersion.HTTP_1_1, HttpResponseStatus.OK,
Unpooled.wrappedBuffer(jobId.getBytes()));
response.headers().set(CONTENT_TYPE, "application/xml");
response.headers().setInt(CONTENT_LENGTH,
response.content().readableBytes());
ctx.write(response).addListener(ChannelFutureListener.CLOSE);
整个完整代码可参考：https://github.com/hapjin/netty_schedule
本文转自hapjin博客园博客，原文链接：http://www.cnblogs.com/hapjin/p/5610253.html，如需转载请自行联系原作者
