Netty源码阅读实战(二)-Netty基本组件
1 一个简单的socket例子
-
无 netty 前编写的代码 传统的HTTP服务器的原理创建一个ServerSocket
-
监听并绑定一个端口一系列客户端来请求这个端口服务器使用Accept,获得一个来自客户端的Socket连接对象
-
启动一个新线程处理连接读Socket,
- 得到字节流解码协议
- 得到Http请求对象处理Http请求
- 得到一个结果
- 封装成一个HttpResponse对象编码协议
- 将结果序列化字节流写Socket,
- 将字节流发给客户端
-
继续循环步骤3
-
流程
- 服务端监听端口
- 客户端会连接服务端
- 客户端每次都会写数据,间歇5s
- 服务端收到并写回客户端
2 Netty对于socket的抽象
3 Netty组件简单介绍
3.1 NioEventLoop
netty的发动机
这些 while(true)就对应一个 run 方法 netty里有不同的io编程模型实现,以Nio为例,对io事件的处理是在NioEventLoop里做的,事件的注册,是下面的这个方法 不同的事件调用unsafe的不同方法,netty对底层socket的操作都是通过unsafe来做的 unsafe主要由两种不同的实现
- NioMessageUnsafe
- NioByteUnsafe
NioServerSocketChannel使用的是NioMessageUnsafe来做socket操作 NioSocketChannel使用NioByteUnsafe来做socket操作
3.2 Channel
- 以服务端的NioMessageUnsafe为例来看下read()方法的实现,对应是否有新连接进来的情况 直接把底层的 channel 封装成 NioSocketChannel
3.3 ByteBuf
3.4 Pipeline
netty 将其抽象成逻辑链,看看 netty 是怎么把每个 pipeline 加入到客户端连接的
3.5 ChannelHandler
#笔记##读书笔记#