Netty4之如何实现HTTP请求、响应

Netty4 是一个开源的、事件驱动的、异步的、高性能的网络通信框架，支持多种协议通信。Netty4 同时支持 HTTP 和 HTTP/2 协议，本文将介绍如何在 Netty4 中实现 HTTP 请求和响应的过程和示例。

简介

Netty4 实现 HTTP 请求、响应的过程主要分为以下几个步骤：

1. 创建 HTTP Server。
2. 绑定端口启动 HTTP Server。
3. 编写 HTTP 请求处理器，处理 HTTP 请求。
4. 编写 HTTP 响应处理器，处理 HTTP 响应。

示例1：实现一个简单的 HTTP Server

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class HttpServer {

    private final int port;

    public HttpServer(int port) {
        this.port = port;
    }

    public void start() throws Exception {
        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(new HttpServerHandler());
                        }
                    })
                    .option(ChannelOption.SO_BACKLOG, 128)
                    .childOption(ChannelOption.SO_KEEPALIVE, true);

            ChannelFuture f = b.bind(port).sync();

            f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
            bossGroup.shutdownGracefully();
        }
    }

    public static void main(String[] args) throws Exception {
        int port = Integer.parseInt(args[0]);
        new HttpServer(port).start();
    }
}

1. EventLoopGroup 用于处理网络事件，可理解为是一个线程池。
2. ServerBootstrap 用于启动服务器。
3. NioEventLoopGroup 创建两个线程组，其中一个负责接收客户端连接，另一个负责处理数据传输。
4. ChannelInitializer 配置 ChannelHandler。
5. HttpServerHandler 继承 SimpleChannelInboundHandler，重写 channelRead0 方法，用于处理 HTTP 请求。

示例2：实现一个 HTTP 请求处理器

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.DefaultFullHttpResponse;
import io.netty.handler.codec.http.FullHttpResponse;
import io.netty.handler.codec.http.HttpMethod;
import io.netty.handler.codec.http.HttpRequest;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;

import java.nio.charset.StandardCharsets;

public class HttpServerHandler extends SimpleChannelInboundHandler<HttpRequest> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, HttpRequest request) throws Exception {
        if (request.method().equals(HttpMethod.GET)) {
            ByteBuf content = ctx.alloc().buffer();
            content.writeBytes("Hello, world!".getBytes(StandardCharsets.UTF_8));
            FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content);
            response.headers().set("Content-Type", "text/plain");
            response.headers().set("Content-Length", content.readableBytes());
            ctx.writeAndFlush(response);
            ctx.close();
        }
    }
}

1. 继承 SimpleChannelInboundHandler，用于处理收到的 HTTP 请求。
2. 重写 channelRead0 方法，判断请求方法是否是 GET。
3. 构造响应信息并返回给客户端。

至此，Netty4 实现 HTTP 请求、响应的完整攻略讲解完毕。