Netty（2） - HelloWorld

 1 package com.foreign.netty.helloworld; 2 ?3 import io.netty.bootstrap.ServerBootstrap; 4 import io.netty.channel.ChannelFuture; 5 import io.netty.channel.EventLoopGroup; 6 import io.netty.channel.nio.NioEventLoopGroup; 7 import io.netty.channel.socket.nio.NioServerSocketChannel; 8 ?9 /**10 ?* Created with IDEA11 ?* author:foreign12 ?* Date:2018/12/2513 ?* Time:23:2114 ?*/15 public class TestServer {16 ????public static void main(String[] args) throws InterruptedException {17 ????????/**18 ?????????* 两个事件循环组(死循环) boos接受连接并发送给worker19 ?????????*/20 ????????EventLoopGroup bossLooper = new NioEventLoopGroup();21 ????????EventLoopGroup workerLooper = new NioEventLoopGroup();22 23 ????????try {24 ????????????/**25 ?????????????* ServerBootstrap 服务端启动26 ?????????????* NioServerSocketChannel 通道（反射）27 ?????????????*/28 ????????????ServerBootstrap serverBootstrap = new ServerBootstrap();29 ????????????serverBootstrap.group(bossLooper, workerLooper).channel(NioServerSocketChannel.class).childHandler(new TestServerInitializer());30 31 ????????????ChannelFuture channelFuture = serverBootstrap.bind(8899).sync();32 ????????????channelFuture.channel().closeFuture().sync();33 ????????} finally {34 ????????????bossLooper.shutdownGracefully();35 ????????????workerLooper.shutdownGracefully();36 ????????}37 ????}38 }

 1 package com.foreign.netty.helloworld; 2 ?3 import io.netty.channel.ChannelInitializer; 4 import io.netty.channel.ChannelPipeline; 5 import io.netty.channel.socket.SocketChannel; 6 import io.netty.handler.codec.http.HttpServerCodec; 7 ?8 /** 9 ?* Created with IDEA10 ?* author:foreign11 ?* Date:2018/12/2512 ?* Time:23:3213 ?*/14 public class TestServerInitializer extends ChannelInitializer<SocketChannel> {15 16 ????/**17 ?????* 子处理器， channel被注册好，会被自动创建18 ?????* @param ch19 ?????* @throws Exception20 ?????*/21 ????@Override22 ????protected void initChannel(SocketChannel ch) throws Exception {23 ????????ChannelPipeline pipeline = ch.pipeline();24 ????????//编解码25 ????????pipeline.addLast("httpServerCodec",new HttpServerCodec());26 ????????//自己定义的handler27 ????????pipeline.addLast("testHttpServerHandler",new TestHttpServerHandler());28 29 ????}30 }

1 package com.foreign.netty.helloworld; 2 ?3 import io.netty.buffer.ByteBuf; 4 import io.netty.buffer.Unpooled; 5 import io.netty.channel.ChannelHandlerContext; 6 import io.netty.channel.SimpleChannelInboundHandler; 7 import io.netty.handler.codec.http.*; 8 import io.netty.util.CharsetUtil; 9 10 import java.net.URI;11 12 /**13 ?* Created with IDEA14 ?* author:foreign15 ?* Date:2018/12/2516 ?* Time:23:3417 ?*/18 public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject> {19 ????/**20 ?????* 把结果返回给客户端（回调）21 ?????*/22 ????@Override23 ????protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {24 ????????if (msg instanceof HttpRequest) {25 26 ????????????HttpRequest httpRequest = (HttpRequest) msg;27 28 ????????????//获取请求的方法类型29 ????????????System.out.println(httpRequest.method().name());30 31 ????????????URI uri = new URI(httpRequest.uri());32 ????????????if("/favicon.io".equals(uri)) {33 ????????????????System.out.println("请求了favicon.io 图标");34 ????????????????return;35 ????????????}36 37 ????????????ByteBuf content = Unpooled.copiedBuffer("Hello Netty", CharsetUtil.UTF_8);38 ????????????FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, content);39 ????????????response.headers().set(HttpHeaderNames.CONTENT_TYPE, "text/plain");40 ????????????response.headers().set(HttpHeaderNames.CONTENT_LENGTH, content.readableBytes());41 42 ????????????ctx.writeAndFlush(response);43 44 ????????????ctx.channel().close();45 ????????}46 ????}47 }

plugins { ???id ‘java‘}group ‘com.foreign‘version ‘1.0-SNAPSHOT‘apply plugin: ‘java‘sourceCompatibility = 1.8targetCompatibility = 1.8repositories { ???mavenCentral()}dependencies { ???implementation ‘io.netty:netty-all:4.1.10.Final‘ ???testCompile ( ???????????"junit:junit:4.11" ???)}