【Netty】使用 Netty 开发 HTTP 服务器 ( HTTP 请求过滤 )

package kim.hsl.http;
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;

import io.netty.handler.codec.http.HttpServerCodec;

import kim.hsl.netty.ServerHandler;
/**


HTTP 服务器


客户端使用浏览器访问即可

*/

public class HTTPServer {

public static void main(String[] args) {

// 1. 创建 BossGroup 线程池 和 WorkerGroup 线程池, 其中维护 NioEventLoop 线程

//     NioEventLoop 线程中执行无限循环操作
 // BossGroup 线程池 : 负责客户端的连接
 // 指定线程个数 : 客户端个数很少, 不用很多线程维护, 这里指定线程池中线程个数为 1
 EventLoopGroup bossGroup = new NioEventLoopGroup(1);
 // WorkerGroup 线程池 : 负责客户端连接的数据读写
 EventLoopGroup workerGroup = new NioEventLoopGroup();

 // 2. 服务器启动对象, 需要为该对象配置各种参数
 ServerBootstrap bootstrap = new ServerBootstrap();
 bootstrap.group(bossGroup, workerGroup) // 设置 主从 线程组 , 分别对应 主 Reactor 和 从 Reactor
         .channel(NioServerSocketChannel.class)  // 设置 NIO 网络套接字通道类型
         .option(ChannelOption.SO_BACKLOG, 128)  // 设置线程队列维护的连接个数
         .childOption(ChannelOption.SO_KEEPALIVE, true)  // 设置连接状态行为, 保持连接状态
         .childHandler(  
         		// 为 WorkerGroup 线程池对应的 NioEventLoop 设置对应的事件 处理器 Handler
                 new ChannelInitializer<SocketChannel>() {// 创建通道初始化对象
                     @Override
                     protected void initChannel(SocketChannel ch) throws Exception {
                         // 该方法在服务器与客户端连接建立成功后会回调
                         // 获取管道
                         ChannelPipeline pipeline = ch.pipeline();

                         // 为管道加入 HTTP 协议的编解码器 HttpServerCodec,
                         // codec 中的 co 是 coder 编码器的意思, dec 是 decoder 解码器的意思
                         // 第一个字符串是编解码器的名称
                         pipeline.addLast("HttpServerCodec" , new HttpServerCodec());

                         // 为管道 Pipeline 设置处理器 Hanedler
                         pipeline.addLast("HTTPServerHandler", new HTTPServerHandler());
                     }
                 }
         );
 System.out.println("HTTP 服务器准备完毕 ...");


 ChannelFuture channelFuture = null;
 try {
     // 绑定本地端口, 进行同步操作 , 并返回 ChannelFuture
     channelFuture = bootstrap.bind(8888).sync();
     System.out.println("HTTP 服务器开始监听 8888 端口 ...");
     // 关闭通道 , 开始监听操作
     channelFuture.channel().closeFuture().sync();
 } catch (InterruptedException e) {
     e.printStackTrace();
 } finally {
     // 出现异常后, 优雅的关闭
     bossGroup.shutdownGracefully();
     workerGroup.shutdownGracefully();
 }

}

}

package kim.hsl.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;
/**


HTTP 服务器处理类


SimpleChannelInboundHandler 是 ChannelInboundHandlerAdapter 子类


HttpObject 指的是服务器端与客户端处理数据时的数据类型

*/

public class HTTPServerHandler extends SimpleChannelInboundHandler<HttpObject> {

@Override

protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {

if(msg instanceof HttpRequest){ //判断该  HttpObject msg 参数是否是 Http 请求

System.out.println(ctx.channel().remoteAddress() + " 客户端请求数据 ... ");
     // HTTP 请求过滤核心代码 -----------------------------------------------------------
     // 判定 HTTP 请求类型, 过滤 HTTP 请求

     // 获取 HTTP 请求
     HttpRequest httpRequest = (HttpRequest) msg;
     // 获取网络资源 URI
     URI uri = new URI(httpRequest.uri());
     System.out.println(&#34;本次 HTTP 请求资源 &#34; + uri.getPath());

     // 判定 uri 中请求的资源, 如果请求的是网站图标, 那么直接屏蔽本次请求
     if(uri != null &amp;&amp; uri.getPath() != null &amp;&amp; uri.getPath().contains(&#34;ico&#34;)){
         System.out.println(&#34;请求图标资源 &#34; + uri.getPath() +&#34;, 屏蔽本次请求 !&#34;);
         return;
     }
     // HTTP 请求过滤核心代码 -----------------------------------------------------------

     // 准备给客户端浏览器发送的数据
     ByteBuf byteBuf = Unpooled.copiedBuffer(&#34;Hello Client&#34;, CharsetUtil.UTF_8);

     // 设置 HTTP 版本, 和 HTTP 的状态码, 返回内容
     DefaultFullHttpResponse defaultFullHttpResponse =
             new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
             HttpResponseStatus.OK, byteBuf);

     // 设置 HTTP 请求头
     // 设置内容类型是文本类型
     defaultFullHttpResponse.headers().set(HttpHeaderNames.CONTENT_TYPE, &#34;text/plain&#34;);
     // 设置返回内容的长度
     defaultFullHttpResponse.headers().set(
             HttpHeaderNames.CONTENT_LENGTH,
             byteBuf.readableBytes());

     // 写出 HTTP 数据
     ctx.writeAndFlush(defaultFullHttpResponse);
 }

}

}