package com.liuliu.nio.http;
import io.netty.bootstrap.Bootstrap;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.ServerSocketChannel;import io.netty.channel.socket.nio.NioServerSocketChannel;
/** * @author 小六六 * @version 1.0 * @date 2020/8/18 14:57 */public class TestHttpServer {
    public static void main(String[] args)  throws Exception {
        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);        NioEventLoopGroup workGroup = new NioEventLoopGroup(8);        try {            ServerBootstrap serverBootstrap = new ServerBootstrap();            serverBootstrap.group(bossGroup,workGroup).channel(NioServerSocketChannel.class).childHandler(new TestServerInitializer());            ChannelFuture cf = serverBootstrap.bind(8868).sync();            cf.channel().closeFuture().sync();        }finally {            bossGroup.shutdownGracefully();            workGroup.shutdownGracefully();        }

    }}

    package com.liuliu.nio.http;

import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelPipeline;import io.netty.channel.socket.SocketChannel;import io.netty.handler.codec.http.HttpServerCodec;
/** * @author 小六六 * @version 1.0 * @date 2020/8/18 15:04 */public class TestServerInitializer extends ChannelInitializer<SocketChannel> {
    @Override    protected void initChannel(SocketChannel ch) throws Exception {
        //向管道加入处理器        //得到管道        ChannelPipeline pipeline = ch.pipeline();
        //加入一个netty 提供的httpServerCodec codec =>[coder - decoder]        //HttpServerCodec 说明        //1. HttpServerCodec 是netty 提供的处理http的 编-解码器
        pipeline.addLast("MyHttpServerCodec",new HttpServerCodec());

        //2. 增加一个自定义的handler        pipeline.addLast("MyTestHttpServerHandler", new TestHttpServerHandler());
        System.out.println("ok~~~~");
    }}

    package com.liuliu.nio.http;
import io.netty.buffer.ByteBuf;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.SimpleChannelInboundHandler;import io.netty.handler.codec.http.*;import io.netty.util.CharsetUtil;
import java.net.URI;
/** * @author 小六六 * @version 1.0 * @date 2020/8/18 14:56 * * 说明 * 1. SimpleChannelInboundHandler 是 ChannelInboundHandlerAdapter * 2. HttpObject 客户端和服务器端相互通讯的数据被封装成 HttpObject * */public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject> {



    @Override    protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {        System.out.println("对应的channel=" + ctx.channel() + " pipeline=" + ctx                .pipeline() + " 通过pipeline获取channel" + ctx.pipeline().channel());
        System.out.println("当前ctx的handler=" + ctx.handler());
        if (msg instanceof HttpRequest){            System.out.println("ctx 类型="+ctx.getClass());
            System.out.println("pipeline hashcode" + ctx.pipeline().hashCode() + " TestHttpServerHandler hash=" + this.hashCode());
            System.out.println("msg 类型=" + msg.getClass());            System.out.println("客户端地址" + ctx.channel().remoteAddress());
            HttpRequest httpRequest=(HttpRequest)msg;            URI uri = new URI(httpRequest.uri());            if("/favicon.ico".equals(uri.getPath())) {                System.out.println("请求了 favicon.ico, 不做响应");                return;            }
            //回复信息给浏览器 [http协议]            ByteBuf content = Unpooled.copiedBuffer("hello,小六六服务器", CharsetUtil.UTF_8);            //构造一个http的相应，即 httpresponse            //构造一个http的相应，即 httpresponse            FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content);
            response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain;charset=utf-8");            response.headers().set(HttpHeaderNames.CONTENT_LENGTH, content.readableBytes());
            //将构建好 response返回            ctx.writeAndFlush(response);        }    }}

    //通道就绪事件    public void channelActive(ChannelHandlerContext ctx) throws Exception {        ctx.fireChannelActive();    }    //通道读取数据事件    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {        ctx.fireChannelRead(msg);    }    //数据读取完毕事件    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {        ctx.fireChannelReadComplete();    }   //通道发生异常事件    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {        ctx.fireExceptionCaught(cause);    }

ChannelPipeline addFirst(ChannelHandler... handlers)，把一个业务处理类（handler）添加到链中的第一个位置ChannelPipeline addLast(ChannelHandler... handlers)，把一个业务处理类（handler）添加到链中的最后一个位置

ChannelFuture close()，关闭通道ChannelOutboundInvoker flush()，刷新ChannelFuture writeAndFlush(Object msg) ， 将 数 据 写 到 ChannelPipeline 中 当 前ChannelHandler 的下一个 ChannelHandler 开始处理（出站）

ChannelOption.SO_BACKLOG对应 TCP/IP 协议 listen 函数中的 backlog 参数，用来初始化服务器可连接队列大小。服务端处理客户端连接请求是顺序处理的，所以同一时间只能处理一个客户端连接。多个客户端来的时候，服务端将不能处理的客户端连接请求放在队列中等待处理，backlog 参数指定了队列的大小。
ChannelOption.SO_KEEPALIVE一直保持连接活动状态

EventLoopGroup 是一组 EventLoop 的抽象，Netty 为了更好的利用多核 CPU 资源，一般会有多个 EventLoop 同时工作，每个 EventLoop 维护着一个 Selector 实例。
EventLoopGroup 提供 next 接口，可以从组里面按照一定规则获取其中一个 EventLoop来处理任务。在 Netty 服务器端编程中，我们一般都需要提供两个 EventLoopGroup，例如：BossEventLoopGroup 和 WorkerEventLoopGroup。

//通过给定的数据和字符编码返回一个 ByteBuf 对象（类似于 NIO 中的 ByteBuffer 但有区别）
public static ByteBuf copiedBuffer(CharSequence string, Charset charset)