日日操夜夜添-日日操影院-日日草夜夜操-日日干干-精品一区二区三区波多野结衣-精品一区二区三区高清免费不卡

需求點

1. 實現Get，Post功能
2. 打印Http請求方法，請求地址，Body內容
3. 返回數據到前端。

看代碼如下

HttpServer

public class HttpServer {
    public void run(int port){
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workGroup = new NioEventLoopGroup();
        ServerBootstrap bootstrap = new ServerBootstrap();
        bootstrap.group(bossGroup,workGroup)                .channel(NIOServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        //設置http解碼器
                        ch.pipeline().addLast(new HttpRequestDecoder());
                        //設置http內容處理器
                        ch.pipeline().addLast(new HttpObjectAggregator(65536));
                        //設置http編碼器
                        ch.pipeline().addLast(new HttpResponseEncoder());
                        //自定義服務處理器
                        ch.pipeline().addLast(new HttpServerHandler());
                    }
                });
        try {
            ChannelFuture future = bootstrap.bind(8080).sync();
            System.out.println("服務器啟動成功");
            future.channel().closeFuture().sync();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            bossGroup.shutdownGracefully();
            workGroup.shutdownGracefully();
        }
    }
    public static void main(String[] args) {
        new HttpServer().run(8080);
    }
}

自定義網絡I/O時間處理器HttpServerHandler

public class HttpServerHandler extends ChannelInboundHandlerAdapter {
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        //判斷是不是http請求
        if(msg instanceof HttpRequest){
            HttpRequest httpRequest = (HttpRequest) msg;
            parseUri(httpRequest);
            parseHttpMethod(httpRequest);
            parseHttpHeaders(httpRequest);
            parseBody(httpRequest);
            FullHttpResponse res = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrAppedBuffer("ok".getBytes()));
            HttpUtil.setContentLength(res, res.content().readableBytes());
            ctx.writeAndFlush(res);
        }
        super.channelRead(ctx, msg);
    }
    /**
     * 獲得請求方式
     * @param httpRequest
     */
    private HttpMethod parseHttpMethod(HttpRequest httpRequest){
        HttpMethod httpMethod = httpRequest.method();
        System.out.println("method:"+httpMethod.name());
        return httpMethod;
    }
    /**
     * 打印頭部信息
     * @param httpRequest
     */
    private HttpHeaders parseHttpHeaders(HttpRequest httpRequest){
        HttpHeaders httpHeaders = httpRequest.headers();
        for (Map.Entry<String, String> entry : httpHeaders.entries()) {
            System.out.println(entry.getKey()+":"+entry.getValue());
        }
        return httpHeaders;
    }
    /**
     * 打印請求地址
     * @param httpRequest
     */
    private void parseUri(HttpRequest httpRequest){
        String uri = httpRequest.uri();
        System.out.println("uri:"+uri);
    }
    /**
     * 打印請求體
     * @param httpRequest
     */
    private void parseBody(HttpRequest httpRequest){
        if(httpRequest instanceof HttpContent){
            HttpContent httpContent = (HttpContent) httpRequest;
            System.out.println("content:"+httpContent.content().toString(Charset.defaultCharset()));
        }
    }
}

啟動HttpServer。

網頁輸入http://localhost:8080/

控制臺顯示

uri:/
method:GET
Host:localhost:8080
Connection:keep-alive
Cache-Control:max-age=0
Upgrade-Insecure-Requests:1
User-Agent:Mozilla/5.0 (windows NT 6.1; Win64; x64) AppleWebKit/537.36 (Khtml, like Gecko) Chrome/85.0.4183.102 Safari/537.36
Accept:text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9
Sec-Fetch-Site:noneSec-Fetch-Mode:navigateSec-Fetch-User:?1
Sec-Fetch-Dest:documentAccept-Encoding:gzip, deflate, brAccept-Language:en,zh-CN;q=0.9,zh;q=0.8
content-length:0
content:

PostMan用Post方式請求http://localhost:8080/

控制臺顯示如下

uri:/
method:POST
Content-Type:text/plain
User-Agent:PostmanRuntime/7.26.3
Accept:*/*
Cache-Control:no-cache
Postman-Token:dbdb420e-5403-40da-8d8f-e2c11029c390
Host:localhost:8080
Accept-Encoding:gzip, deflate, br
Connection:keep-alive
Content-Length:21
content:{
    "test":1212
}

代碼實現起來不難，我們一步步來解析，為什么要這樣做。

HttpRequestDecoder

首先HttpRequestDecoder是一個解碼器，那就是從網絡讀取字節流來處理。

它的主要功能是，解析ByteBuf轉化成Http請求的相關數據，例如將請求數據轉化成，HttpRequest/HttpResponse,HttpContent,LastHttpContent。

HttpObjectAggregator

HttpObjectAggregator的作用是聚合，因為HttpRequestDecoder會解析成多個Http相關對象，它將它們聚合成一個對象。

HttpResponseEncoder

HttpResponseEncoder的作用是用來編碼，將我們響應的Http對象，轉化成ByteBuf，進行網絡通信。

我們最終需要把網絡請求的數據轉化成http請求的相關類。

我這里用相關類來表示，不特指netty的httpRequest和HttpResponse。因為我們自己也可以自定義實現。只要按照http請求的報文做相應的解析即可。

我們來看下網絡請求的過程。

HttpServerHandler是我們自定義的網絡I/O處理事件。當讀數據的時候，判斷msg是HttpRequest類型，說明是http請求，做相應的處理即可。

小知識點

對于一個陌生的框架，如果想知道它是否有某個功能，我們直接進去看接口有沒有相關的實現即可。

不用百度的，直接看接口，觀察函數參數，以及返回類型，就可以開始使用。如果調用不通，看注釋等等，最后才看下百度。

總結

我們本篇，講解了一個例子，用netty來做http服務器。其中網絡I/O事件打印了，請求的方式(GET/POST)，headers，post body，uri。

有了這幾個參數，基本上的http相關操作都可以實現。

但是HttpRequestDecoder，HttpObjectAggregator，HttpResponseEncoder是如何實現的呢？