开发笔记:Netty之HTTP协议应用开发

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() { @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); }}


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); }}