Netty之HTTP协议应用开发

Posted 2021-04-26 Liusy01

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Netty之HTTP协议应用开发相关的知识，希望对你有一定的参考价值。

1、HTTP协议

HTTP（超文本传输协议）是建立在TCP传输协议上的应用层协议，是一个属于应用层的面向对象的协议，也是目前Web开发主流的协议。

HTTP协议的特点如下：

（1）支持Client/Server模式

（2）简单，客户端向服务端发请求时，只需指定URL，携带必要的请求参数以及消息体。

（3）灵活，允许传输任意类型的数据对象，传输类型由请求头的Content-Type指定。

（4）无状态，协议对于事务处理没有记忆能力，如果后续需要处理之前的信息，必须进行重传。

2、Netty HTTP服务端开发

我们以获取请求参数为例，来开发HTTP服务端，客户端可以是浏览器，也可以是Postman工具。如果没有参数，则返回给客户端错误，如果有请求参数，则获取到请求参数返回给客户端。

服务端程序

public class HttpServer {
 public void start(int port) throws InterruptedException { NioEventLoopGroup boss = new NioEventLoopGroup(); NioEventLoopGroup worker = new NioEventLoopGroup();
 ServerBootstrap server = new ServerBootstrap();
 server.group(boss,worker) .channel(NioserverSocketChannel.class) .option(ChannelOption.SO_BACKLOG,1024) .childHandler(new ChannelInitializer<SocketChannel>() { @Override protected void initChannel(SocketChannel ch) throws Exception { ChannelPipeline pipeline = ch.pipeline();                        //使用Netty自带的HTTP请求解码类 pipeline.addLast(new HttpRequestDecoder());                        //参数的最大长度 pipeline.addLast(new HttpObjectAggregator(65535));                        //使用Netty自带HTTP返回体消息编码类 pipeline.addLast(new HttpResponseEncoder()); //支持异步发送大的码流，比如文件，但不占用过多的内存 pipeline.addLast(new ChunkedWriteHandler()); pipeline.addLast(new HttpServerNewHandler()); } }) .childOption(ChannelOption.SO_KEEPALIVE,true);
 ChannelFuture future = server.bind(port).sync(); System.out.println("服务端已启动，端口号为："+port); future.channel().closeFuture().sync();
 }
 public static void main(String[] args) throws InterruptedException { new HttpServer().start(8080); }}

这边使用Netty自带的HttpRequestDecoder和HttpResponseEncoder类进行编解码。

HttpObjectAggregator解码器的作用是将多个消息转换成单一的FullHttpRequest或者是FullHttpResponse，原因是HTTP解码器在每个HTTP消息中会生成多个消息对象。

ChunkedWriteHandler的作用是支持异步发送大的码流，例如大文件传输，但不占用过多的内存，放置JVM内存溢出。

然后看一下我们进行参数解析的自定义处理类：

public class HttpServerNewHandler extends SimpleChannelInboundHandler<FullHttpRequest> {
 @Override    protected void messageReceived(ChannelHandlerContext ctx, FullHttpRequest request) throws Exception  //解码失败 if (request.decoderResult().isFailure()) { sendResp(ctx,"请求解码失败",HttpResponseStatus.BAD_REQUEST); }        //获取请求方法 HttpMethod method = request.method(); if (method == HttpMethod.GET) { String uri = request.uri(); int index = 0; if ((index = uri.indexOf("?"))<=-1) { sendResp(ctx,"此请求没有参数，请求失败",HttpResponseStatus.BAD_REQUEST); } else { String param = uri.substring(index + 1); sendResp(ctx,"请求方式为GET，参数为："+param,HttpResponseStatus.OK); } } else if (method == HttpMethod.POST) { ByteBuf buf = request.content(); int length = buf.readableBytes(); if (length>0) { byte[] param = new byte[length]; buf.readBytes(param); String paramStr = new String(param); sendResp(ctx, "请求方式为POST，参数为：" + paramStr, HttpResponseStatus.OK); } else { sendResp(ctx, "此请求没有参数，请求失败" , HttpResponseStatus.BAD_REQUEST); } }    }
 /**     * 将消息封装成FullHttpResponse返回给客户端 */ private static void sendResp(ChannelHandlerContext ctx,String msg,HttpResponseStatus status) { ByteBuf byteBuf = Unpooled.copiedBuffer(msg.getBytes()); FullHttpResponse response = new DefaultFullHttpResponse(HTTP_1_1, status); response.headers().set(CONTENT_TYPE, "text/html; charset=UTF-8"); response.content().writeBytes(byteBuf); byteBuf.release(); ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE); }}