Netty是一个java开源框架,是基于NIO的高性能、高可扩展性的异步事件驱动的网络应用框架,简化了TCP、UDP服务器和客户端的网络编程。
很多开源的项目,底层都使用了Netty,例如Dubbo、Elasticsearch、Facebook等,其他的支持者,请进入https://netty.io/wiki/adopters.html查看。
设计层面:
使用层面:
性能层面:
安全层面:
社区层面:
1:支持Socket、HTTP等多种传输方式
2:提供了多种协议的编码、解码实现
3:核心部分:事件处理模型、API、BUffer的增强
1:Channel,Netty自己定义了Channel,对其进行了增强
2:EventLoop,由线程驱动的,处理Channel的I/O事件
3:ChannelPipeline,事件处理机制,也叫做职责链
4:ChannelHandler,事件处理器
5:ByteBuf,增强版的缓冲区
6:BootStrap,启动器
//老板线程组 EventLoopGroup bossGroup = new NioEventLoopGroup(1); //员工线程组 EventLoopGroup workerGroup = new NioEventLoopGroup(); final EchoServerHandler serverHandler = new EchoServerHandler(); try { ServerBootstrap b = new ServerBootstrap(); //配置启动器 b.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 100) .handler(new LoggingHandler(LogLevel.INFO)) .childHandler(new ChannelInitializer<SocketChannel>() { @Override public void initChannel(SocketChannel ch) throws Exception { ChannelPipeline p = ch.pipeline(); if (sslCtx != null) { p.addLast(sslCtx.newHandler(ch.alloc())); } //p.addLast(new LoggingHandler(LogLevel.INFO)); p.addLast(serverHandler); } }); //启动启动器 ChannelFuture f = b.bind(PORT).sync(); //关闭服务 f.channel().closeFuture().sync(); } finally { bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); }
1:bossGroup就是一个线程,接收客户端连接,然后注册到workerGroup,分配给workerGroup中的线程
2:workerGroup主要是用来处理客户端连接的I/O操作的,里面有多个线程,线程的数量一般默认为CPU核心数*2,每个线程都有一个Selector用来监听客户端事件的发生,Selector会轮询的去看有没有事件
3:workerGroup中每个线程里,都有一个queue队列,当Selector轮询中没有事件,也就是当该线程空闲的时候,会去处理queue中的任务
本篇内容主要是介绍Netty的一些知识,下一篇会写下EventLoopGroup和Channel相关的东西