先直接看demo，demo实现功能：
使用netty构建一个类似于tomcat的web服务器，服务端监听8899端口，当访问8899端口的时候，服务器端给客户端hello world的响应。
直接看代码：
服务端：
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;
public class TestServer {
public static void main(String[] args) throws Exception{
//bossGroup是获取连接的，workerGroup是用来处理连接的，这二个线程组都是死循环
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try{
//简化服务端启动的一个类
ServerBootstrap serverBootstrap = new ServerBootstrap();
//group有二个重载方法，一个是接收一个EventLoopGroup类型参数的方法，一个是接收二个EventLoopGroup类型的参数的方法
serverBootstrap.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class).
childHandler(new TestServerInitializer());
ChannelFuture channelFuture = serverBootstrap.bind(8899).sync();
channelFuture.channel().closeFuture().sync();
}finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
服务端HttpServerInitializer（初始化连接的时候执行的回调），处理器Handler构成了一个链路
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;
public class TestServerInitializer extends ChannelInitializer<SocketChannel>{
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
//http协议的编解码使用的,是HttpRequestDecoder和HttpResponseEncoder处理器组合
//HttpRequestDecoder http请求的解码
//HttpResponseEncoder http请求的编码
pipeline.addLast("httpServerCodec",new HttpServerCodec());
pipeline.addLast("testHttpServerHandler",new TestHttpServerHandler());
}
}
服务端Handler，对请求进行路由
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;
import java.net.URI;
//浏览器的特性会发送一个/favicon.ico请求，获取网站的图标
public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject>{
//channelRead0是读取客户端的请求并且向客户端返回响应的一个方法
@Override
protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
if(msg instanceof HttpRequest){
HttpRequest httpRequest = (HttpRequest)msg;
System.out.println("请求方法名："+httpRequest.method().name()); //get方法
URI uri = new URI(httpRequest.uri());
//使用浏览器访问localhost:8899会发送二次请求，其中有一次是localhost:8899/favicon.ico,这个url请求访问网站的图标
if("/favicon.ico".equals(uri.getPath())){
System.out.println("请求favicon.ico");
return;
}
//向客户端返回的内容
ByteBuf content = Unpooled.copiedBuffer("hello world", CharsetUtil.UTF_8);
FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
HttpResponseStatus.OK,content);
response.headers().set(HttpHeaderNames.CONTENT_TYPE,"text/plain");
response.headers().set(HttpHeaderNames.CONTENT_LENGTH,content.readableBytes());
ctx.writeAndFlush(response);
//其实更合理的close连接应该判断是http1.O还是1.1来进行判断请求超时时间来断开channel连接。
ctx.channel().close();
}
}
}
使用curl命令访问该服务：
➜ curl 'localhost:8899'
hello world%
控制台打印：
请求方法名：GET
相应的使用post，put，delete请求服务
post请求
curl -X post 'localhost:8899'
put请求
curl -X put 'localhost:8899'
delete请求
curl -X delete 'localhost:8899'
我们使用谷歌浏览器访问localhost:8899，打开开发者工具的时候发现还会请求一次/favicon.ico（请求当前网站的图标）。此时控制台打印
请求方法名：GET
请求方法名：GET
请求favicon.ico
扩展
我们改造一下TestHttpServerHandler代码，因为netty是事件驱动的网络框架，我们定义的TestHttpServerHandler继承SimpleChannelInboundHandler类，SimpleChannelInboundHandler类又继承ChannelInboundHandlerAdapter类，发现ChannelInboundHandlerAdapter中定义了好多事件回调方法，在不同的事件触发时会执行相应的方法，我们在TestHttpServerHandler重写这些方法来梳理一下netty的事件回调流程。
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.*;
import io.netty.util.CharsetUtil;
import java.net.URI;
//浏览器的特性会发送一个/favicon.ico请求，获取网站的图标
public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject>{
//channelRead0是读取客户端的请求并且向客户端返回响应的一个方法
@Override
protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
//io.netty.handler.codec.http.DefaultHttpRequest,io.netty.handler.codec.http.LastHttpContent$1
System.out.println(msg.getClass());
//打印出远程的地址，/0:0:0:0:0:0:0:1: 49734，本地线程的49734端口的线程和netty进行通信
System.out.println(ctx.channel().remoteAddress());
TimeUnit.SECONDS.sleep(8);
if(msg instanceof HttpRequest){
HttpRequest httpRequest = (HttpRequest)msg;
System.out.println("请求方法名："+httpRequest.method().name()); //get方法
URI uri = new URI(httpRequest.uri());
//使用浏览器访问localhost:8899会发送二次请求，其中有一次是localhost:8899/favicon.ico,这个url请求访问网站的图标
if("/favicon.ico".equals(uri.getPath())){
System.out.println("请求favicon.ico");
return;
}
//向客户端返回的内容
ByteBuf content = Unpooled.copiedBuffer("hello world", CharsetUtil.UTF_8);
FullHttpResponse response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
HttpResponseStatus.OK,content);
response.headers().set(HttpHeaderNames.CONTENT_TYPE,"text/plain");
response.headers().set(HttpHeaderNames.CONTENT_LENGTH,content.readableBytes());
ctx.writeAndFlush(response);
//其实更合理的close连接应该判断是http1.O还是1.1来进行判断请求超时时间来断开channel连接。
ctx.channel().close();
}
}
//管道活跃
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("channel active");
super.channelActive(ctx);
}
//管道注册
@Override
public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
System.out.println("channel registered");
super.channelRegistered(ctx);
}
//通道被添加
@Override
public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
System.out.println("handler added");
super.handlerAdded(ctx);
}
//管道不活跃了
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
System.out.println("channel inactive");
super.channelInactive(ctx);
}
//取消注册
@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
System.out.println("channel unregistered");
super.channelUnregistered(ctx);
}
}
使用curl命令访问该服务：
➜ curl 'localhost:8899'
hello world%
控制台显示，我们发现handlerAdded（通道被添加），channelRegistered（通道被注册），channelActive（管道活跃）然后通道关闭之后依次执行channelInactive（管道不活跃了），channelUnregistered（通道取消注册）
handler added
channel registered
channel active
class io.netty.handler.codec.http.DefaultHttpRequest
/0:0:0:0:0:0:0:1:49734
请求方法名：GET
class io.netty.handler.codec.http.LastHttpContent$1
/0:0:0:0:0:0:0:1:49734
channel inactive
channel unregistered
我们发现49734发起了调用8899端口的服务，可以使用命令来查看
➜ lsof -i:8899
COMMAND PID USER FD TYPE DEVICE SIZE/OFF NODE NAME
java 56283 naeshihiroshi 106u IPv6 0x72f1692aa9c77fbf 0t0 TCP *:8899 (LISTEN)
java 56283 naeshihiroshi 109u IPv6 0x72f1692aaca7cfbf 0t0 TCP localhost:8899->localhost: 49734 (ESTABLISHED)
curl 56649 naeshihiroshi 5u IPv6 0x72f1692aabcfa53f 0t0 TCP localhost: 49734->localhost:8899 (ESTABLISHED)
拓展，使用netty构建restful服务
使用netty,fastjson构建简单的restful服务，参考博客地址
我的代码的github地址，在com.zhihao.miao.netty.restful包下。
