Javanetty获得POST请求内容

Question

我正在使用嵌入Java的netty 4.1，并尝试从管道中的客户端POST请求中检索数据。我在网上找到了几种选择，但都没用。。。

也许有人对此有一个有用的想法。

向所有提供帮助的人致以问候和感谢。

管道：

    p.addLast ("codec", new HttpServerCodec ());
    p.addLast("decoder", new HttpRequestDecoder());
    p.addLast("encoder", new HttpRequestEncoder());
    p.addLast("handler",new InboundHandlerA());

处理程序：

private static class InboundHandlerA extends ChannelInboundHandlerAdapter{
     @Override
     public void channelActive(ChannelHandlerContext ctx) {
         System.out.println("Connected!");
         ctx.fireChannelActive();
     } 

 public void channelRead (ChannelHandlerContext channelHandlerCtxt, Object msg) throws Exception   {

         System.out.println(msg);
     }
    }

Answer 1

使用netty接收HTTP请求很简单，您可以使用以下管道执行此操作：

// Provides support for http objects:
p.addLast("codec", new HttpServerCodec());
// Deals with fragmentation in http traffic: 
p.addLast("aggregator", new HttpObjectAggregator(Short.MAX_VALUE));
// Deals with optional compression of responses:
// p.addLast("aggregator", new HttpContentCompressor());
p.addLast("handler",new InboundHandlerA());

这可以与自定义的SimpleChannelInboundHandler一起使用

public class InboundHandlerA extends SimpleChannelInboundHandler<FullHttpRequest> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) {
        super.channelActive(ctx);
        System.out.println("Connected!");
    } 

    // Please keep in mind that this method 
       will be renamed to messageReceived(ChannelHandlerContext, I) in 5.0.
    @Override
    public void channelRead0 (ChannelHandlerContext ctx, 
                              FullHttpRequest msg) throws Exception {
        // Check for invalid http data:
        if(msg.getDecoderResult() != DecoderResult.SUCCESS ) {
            ctx.close();
            return;
        }

        System.out.println("Recieved request!");
        System.out.println("HTTP Method: " + msg.getMethod());
        System.out.println("HTTP Version: " + msg.getProtocolVersion());
        System.out.println("URI: " + msg.getUri());
        System.out.println("Headers: " + msg.headers());
        System.out.println("Trailing headers: " + msg.trailingHeaders());

        ByteBuf data = msg.content();
        System.out.println("POST/PUT length: " + data.readableBytes());
        System.out.println("POST/PUT as string: ");
        System.out.println("-- DATA --");
        System.out.println(data.toString(StandardCharsets.UTF_8));
        System.out.println("-- DATA END --");

        // Send response back so the browser won't timeout
        ByteBuf responseBytes = ctx.alloc().buffer();
        responseBytes.writeBytes("Hello World".getBytes());

        FullHttpResponse response = new DefaultFullHttpResponse(
            HttpVersion.HTTP_1_1, HttpResponseStatus.OK, responseBytes);
        response.headers().set(HttpHeaders.Names.CONTENT_TYPE, 
                               "text/plain");
        response.headers().set(HttpHeaders.Names.CONTENT_LENGTH, 
                               response.content().readableBytes());

        response.headers().set(HttpHeaders.Names.CONNECTION, 
                               HttpHeaders.Values.KEEP_ALIVE);
        ctx.write(response);
    }
}

上面的代码打印出了传入消息的所有细节，包括post数据。如果您只需要post数据，那么可以添加一个简单的If语句来过滤post响应类型