Netty实现简易http_server

package cn.enjoyedu.server;import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.ChannelFuture;import io.netty.channel.EventLoopGroup;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.ssl.SslContext;import io.netty.handler.ssl.SslContextBuilder;import io.netty.handler.ssl.util.SelfSignedCertificate;/** * @author Mark老师 ??享学课堂 https://enjoy.ke.qq.com * 往期课程和VIP课程咨询 依娜老师 ?QQ：2133576719 * 类说明： */public class HttpServer { ???public static final int port = 6789; //设置服务端端口 ???private static EventLoopGroup group = new NioEventLoopGroup(); ???private static ServerBootstrap b = new ServerBootstrap(); ???private static final boolean SSL = true; ???public static void main(String[] args) throws Exception { ???????final SslContext sslCtx; ???????if (SSL) { ???????????//netty为我们提供的ssl加密，缺省 ???????????SelfSignedCertificate ssc = new SelfSignedCertificate(); ???????????sslCtx = SslContextBuilder.forServer(ssc.certificate(), ???????????????????ssc.privateKey()).build(); ???????} else { ???????????sslCtx = null; ???????} ???????try { ???????????b.group(group); ???????????b.channel(NioServerSocketChannel.class); ???????????b.childHandler(new ServerHandlerInit(sslCtx)); ???????????// 服务器绑定端口监听 ???????????ChannelFuture f = b.bind(port).sync(); ???????????System.out.println("服务端启动成功,端口是:"+port); ???????????// 监听服务器关闭监听 ???????????f.channel().closeFuture().sync(); ???????} finally { ???????????group.shutdownGracefully(); ???????} ???}}

package cn.enjoyedu.server;import io.netty.channel.ChannelInitializer;import io.netty.channel.ChannelPipeline;import io.netty.channel.socket.SocketChannel;import io.netty.handler.codec.http.HttpContentCompressor;import io.netty.handler.codec.http.HttpObjectAggregator;import io.netty.handler.codec.http.HttpRequestDecoder;import io.netty.handler.codec.http.HttpResponseEncoder;import io.netty.handler.ssl.SslContext;/** * @author Mark老师 ??享学课堂 https://enjoy.ke.qq.com * 往期课程和VIP课程咨询 依娜老师 ?QQ：2133576719 * 类说明： */public class ServerHandlerInit extends ChannelInitializer<SocketChannel> { ???private final SslContext sslCtx; ???public ServerHandlerInit(SslContext sslCtx) { ???????this.sslCtx = sslCtx; ???} ???@Override ???protected void initChannel(SocketChannel ch) throws Exception { ???????ChannelPipeline ph = ch.pipeline(); ???????if (sslCtx != null) { ???????????ph.addLast(sslCtx.newHandler(ch.alloc())); ???????} ???????//http响应编码 ???????ph.addLast("encode",new HttpResponseEncoder()); ???????//http请求编码 ???????ph.addLast("decode",new HttpRequestDecoder()); ???????//聚合http请求 ???????ph.addLast("aggre", ???????????????new HttpObjectAggregator(10*1024*1024)); ???????//启用http压缩 ???????ph.addLast("compressor",new HttpContentCompressor()); ???????//自己的业务处理 ???????ph.addLast("busi",new BusiHandler()); ???}}

package cn.enjoyedu.server;import io.netty.buffer.Unpooled;import io.netty.channel.ChannelFutureListener;import io.netty.channel.ChannelHandlerContext;import io.netty.channel.ChannelInboundHandlerAdapter;import io.netty.handler.codec.http.*;import io.netty.util.CharsetUtil;/** * @author Mark老师 ??享学课堂 https://enjoy.ke.qq.com * 往期课程和VIP课程咨询 依娜老师 ?QQ：2133576719 * 类说明： */public class BusiHandler extends ChannelInboundHandlerAdapter { ???private String result=""; ???private void send(String content, ChannelHandlerContext ctx, ?????????????????????HttpResponseStatus status){ ???????FullHttpResponse response = ???????????????new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,status, ???????????????????????Unpooled.copiedBuffer(content,CharsetUtil.UTF_8)); ???????response.headers().set(HttpHeaderNames.CONTENT_TYPE, ???????????????"text/plain;charset=UTF-8"); ???????ctx.writeAndFlush(response).addListener(ChannelFutureListener.CLOSE); ???} ???/* ????* 收到消息时，返回信息 ????*/ ???@Override ???public void channelRead(ChannelHandlerContext ctx, Object msg) ???????????throws Exception { ???????String result=""; ???????//接收到完成的http请求 ???????FullHttpRequest httpRequest = (FullHttpRequest)msg; ???????try{ ???????????String path = httpRequest.uri(); ???????????String body = httpRequest.content().toString(CharsetUtil.UTF_8); ???????????HttpMethod method = httpRequest.method(); ???????????if(!"/test".equalsIgnoreCase(path)){ ???????????????result = "非法请求："+path; ???????????????send(result,ctx,HttpResponseStatus.BAD_REQUEST); ???????????????return; ???????????} ???????????//处理http GET请求 ???????????if(HttpMethod.GET.equals(method)){ ???????????????System.out.println("body:"+body); ???????????????result="Get request,Response="+RespConstant.getNews(); ???????????????send(result,ctx,HttpResponseStatus.OK); ???????????} ???????????//处理http POST请求 ???????????if(HttpMethod.POST.equals(method)){ ???????????????//..... ???????????} ???????}catch(Exception e){ ???????????System.out.println("处理请求失败!"); ???????????e.printStackTrace(); ???????}finally{ ???????????httpRequest.release(); ???????} ???} ???/* ????* 建立连接时，返回消息 ????*/ ???@Override ???public void channelActive(ChannelHandlerContext ctx) ???????????throws Exception { ???????System.out.println("连接的客户端地址:" ???????????????+ ctx.channel().remoteAddress()); ???}}