概述
1 传统socket网络编程
1.1 实战
-
服务端:ServerBoot
-
Server
-
ClientHandler
-
客户端:Client
-
先后启动
ServerBoot
、Client
,分别输出如下:
1.2 传统HTTP服务器原理
- 创建一个
ServerSocket
- 监听并绑定一个端口一系列客户端来请求这个端口服务器使用Accept,获得一个来自客户端的Socket连接对象
- 启动一个新线程处理连接读Socket,
- 得到字节流解码协议
- 得到Http请求对象处理Http请求
- 得到一个结果
- 封装成一个HttpResponse对象编码协议
- 将结果序列化字节流写Socket,
- 将字节流发给客户端
- 继续循环步骤3
1.3 C/S 交互流程
2 Netty版socket网络编程
下面分别介绍图中对应组件。
3 Netty核心组件
3.1 NioEventLoop
3.1.1 简介
EventLoop
- 一个 eventloop 就是一个 eventexecutor
NioEventLoopGroup
是一个处理 I/O 操作的多线程事件循环。Netty 为不同类型传输提供各种 EventLoopGroup
实现。
在示例代码中,我们实现服务器端应用程序,因此将使用两个 NioEventLoopGroup:
-
第一个,通常称为’boss’,接受传入的连接
-
第二个(通常称为’work’)在上司接受连接并登记到工作人员后处理接受连接的流量。使用多少线程以及如何映射到创建的通道取决于 EventLoopGroup 实现,甚至可能通过构造函数进行配置。
-
Netty的发动机
-
Server端
-
Client端
while(true)
就对应一个 run 方法
- NioEventLoop#run
netty有不同的io编程模型实现。
- 以NIO为例,对IO事件的处理是在NioEventLoop里做的,事件的注册在下面的方法
不同事件调用unsafe的不同方法,netty对底层socket的操作都是通过unsafe来做的
unsafe主要由两种不同的实现:
- NioMessageUnsafe
NioServerSocketChannel
使用的是NioMessageUnsafe来做socket操作 - NioByteUnsafe
NioSocketChannel
使用NioByteUnsafe来做socket操作
- 处理每一个连接
EventExecutorGroup
EventExecutorGroup
负责经由其使用next()
方法提供EventExecutor
。 除此之外,还负责处理自己的生命周期,并允许在全局模式中关闭它们。
EventExecutor
该EventExecutor
是个特殊的EventExecutorGroup
,附带一些快捷方法,看是否有Thread
在事件循环执行。
除此之外,它还继承了EventExecutorGroup
以允许通用的方法来访问。
eventloopGroup
特殊的 EventExecutorGroup
,它允许注册 Channel
,即事件循环期间可以执行 channel 操作,得到处理,供以后选用
3.2 Channel
- 以服务端的NioMessageUnsafe为例来看下read()方法的实现,对应是否有新连接进来的情况
直接把底层的 channel 封装成 NioSocketChannel
3.3 ByteBuf
3.4 Pipeline
netty 将其抽象成逻辑链,看看 netty 是怎么把每个 pipeline 加入到客户端连接的
3.5 ChannelHandler
最后
以上就是超级马里奥为你收集整理的阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件1 传统socket网络编程2 Netty版socket网络编程3 Netty核心组件的全部内容,希望文章能够帮你解决阿里P8架构师教你Netty源码面试解析实战(二)- 基本组件1 传统socket网络编程2 Netty版socket网络编程3 Netty核心组件所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复