Netty实现简易版Http服务

秒速五厘米 2022-09-05 05:28 228阅读 0赞

浏览器访问服务端监听的端口，服务端做出应答

package com.tech.netty.http;
    
    import io.netty.bootstrap.ServerBootstrap;
    import io.netty.channel.ChannelFuture;
    import io.netty.channel.nio.NioEventLoopGroup;
    import io.netty.channel.socket.nio.NioServerSocketChannel;
    
    /**
     * @author lw
     * @since 2021/8/17
     */
    public class TestServer {
        public static void main(String[] args) throws InterruptedException {
            NioEventLoopGroup bossGroup = new NioEventLoopGroup();
            NioEventLoopGroup workerGroup = new NioEventLoopGroup();
            try{
                ServerBootstrap serverBootstrap = new ServerBootstrap();
                serverBootstrap.group(bossGroup,workerGroup)
                        .channel(NioServerSocketChannel.class)
                        .childHandler(new TestServerInitializer());
                ChannelFuture channelFuture = serverBootstrap.bind(7000).sync();
                channelFuture.channel().closeFuture().sync();
            }finally {
                bossGroup.shutdownGracefully();
                workerGroup.shutdownGracefully();
            }
        }
    }

package com.tech.netty.http;
    
    import io.netty.channel.ChannelInitializer;
    import io.netty.channel.socket.SocketChannel;
    import io.netty.handler.codec.http.HttpServerCodec;
    
    /**
     * @author lw
     * @since 2021/8/17
     */
    public class TestServerInitializer extends ChannelInitializer<SocketChannel> {
        @Override
        protected void initChannel(SocketChannel socketChannel) throws Exception {
            // HttpServerCodec 是Netty提供的编解码器
            socketChannel.pipeline().addLast("MyHttpServerCodec",new HttpServerCodec())
                    .addLast("",new TestServerHandler()); //在管道添加一个自定义处理器
        }
    }

package com.tech.netty.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;
    
    /**
     * SimpleChannelInboundHandler 是 ChannelInboundHandlerAdapter
     * 客户端与服务端相互通信的数据被封装成 HttpObject
     * @author lw
     * @since 2021/8/17
     */
    public class TestServerHandler extends SimpleChannelInboundHandler<HttpObject> {
    
        /**
         * @description 读取客户端数据
         * @author lw
         * @since 2021/8/17
         **/
        @Override
        protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
    
            //判断msg是不是HttpRequest请求
            if(msg instanceof HttpRequest){
                System.out.println("pipeline hashCode="+ctx.pipeline().hashCode()+",TestServerHandler hashCode="+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响应
                DefaultFullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content);
                response.headers().add(HttpHeaderNames.CONTENT_TYPE,"text/plain;charset=utf-8");
                response.headers().add(HttpHeaderNames.CONTENT_LENGTH,content.readableBytes());
                //将构建好response返回
                ctx.writeAndFlush(response);
            }
        }
    }