客户端启动类 不建议使用netty写客户端，可以使用Apache httpclient之类的工具
/** * @author yun * 类说明： */ public class HttpClient { public void connect(String host, int port) throws Exception { EventLoopGroup workerGroup = new NioEventLoopGroup(); try { Bootstrap b = new Bootstrap(); b.group(workerGroup); b.channel(NioSocketChannel.class); b.option(ChannelOption.SO_KEEPALIVE, true); b.handler(new ChannelInitializer<SocketChannel>() { @Override public void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new HttpClientCodec()); ch.pipeline().addLast("aggre", new HttpObjectAggregator(10*1024*1024)); ch.pipeline().addLast("decompressor",new HttpContentDecompressor()); ch.pipeline().addLast("busi",new HttpClientInboundHandler()); } }); // Start the client. ChannelFuture f = b.connect(host, port).sync(); URI uri = new URI("/test"); String msg = "Hello"; DefaultFullHttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, uri.toASCIIString(), Unpooled.wrappedBuffer(msg.getBytes("UTF-8"))); // 构建http请求 request.headers().set(HttpHeaderNames.HOST, host); request.headers() .set(HttpHeaderNames.CONNECTION, HttpHeaderValues.KEEP_ALIVE); request.headers() .set(HttpHeaderNames.CONTENT_LENGTH, request.content().readableBytes()); // 发送http请求 f.channel().write(request); f.channel().flush(); f.channel().closeFuture().sync(); } finally { workerGroup.shutdownGracefully(); } } public static void main(String[] args) throws Exception { HttpClient client = new HttpClient(); client.connect("127.0.0.1", HttpServer.port); } }客户端处理类
/** * @authoryun * 类说明： */ public class HttpClientInboundHandler extends ChannelInboundHandlerAdapter { public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { //开始对服务器的响应做处理 FullHttpResponse httpResponse = (FullHttpResponse)msg; System.out.println(httpResponse.headers()); ByteBuf content = httpResponse.content(); System.out.println(content.toString(CharsetUtil.UTF_8)); content.release(); } }服务端启动类
/** * @author yun * 类说明： */ 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 = false; 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(); } } }服务端channel初始器
/** * @author yun * 类说明： */ 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()); } }服务端业务处理器
/** * @author yun * 类说明： */ 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()); } }常量类
/** * @author yun * 类说明： */ public class RespConstant { private static final String[] NEWS = { "她那时候还太年轻，不知道所有命运赠送的礼物，早已在暗中标好了" + "价格。——斯蒂芬·茨威格《断头皇后》", "这是一个最好的时代，也是一个最坏的时代；" + "这是一个智慧的年代，这是一个愚蠢的年代；\n" + "这是一个信任的时期，这是一个怀疑的时期；" + "这是一个光明的季节，这是一个黑暗的季节；\n" + "这是希望之春，这是失望之冬；" + "人们面前应有尽有，人们面前一无所有；\n" + "人们正踏上天堂之路，人们正走向地狱之门。 —— 狄更斯《双城记》", }; private static final Random R = new Random(); public static String getNews(){ return NEWS[R.nextInt(NEWS.length)]; } }