前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Netty源码阅读入门实战(二)-基本组件

Netty源码阅读入门实战(二)-基本组件

作者头像
JavaEdge
修改2021-01-01 23:52:37
8240
修改2021-01-01 23:52:37
举报
文章被收录于专栏:JavaEdge

1 传统socket网络编程

1.1 实战

  • 服务端:ServerBoot
  • Server
  • ClientHandler
  • 客户端:Client
  • 先后启动 ServerBootClient,分别输出如下:

1.2 传统HTTP服务器原理

  1. 创建一个ServerSocket
  2. 监听并绑定一个端口一系列客户端来请求这个端口服务器使用Accept,获得一个来自客户端的Socket连接对象
  3. 启动一个新线程处理连接读Socket,
    • 得到字节流解码协议
    • 得到Http请求对象处理Http请求
    • 得到一个结果
    • 封装成一个HttpResponse对象编码协议
    • 将结果序列化字节流写Socket,
    • 将字节流发给客户端
  4. 继续循环步骤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',接受传入的连接。第二个(通常称为'工作人员')在上司接受连接并登记到工作人员后处理接受连接的流量。使用多少线程以及如何映射到创建的通道取决于 EventLoopGroup 实现,甚至可能通过构造函数进行配置。

  • Netty的发动机
  • Server端
  • Client端

while(true)就对应一个 run 方法

  • NioEventLoop#run

netty有不同的io编程模型实现。

  • 以NIO为例,对IO事件的处理是在NioEventLoop里做的,事件的注册在下面的方法

不同事件调用unsafe的不同方法,netty对底层socket的操作都是通过unsafe来做的

unsafe主要由两种不同的实现:

  1. NioMessageUnsafe NioServerSocketChannel使用的是NioMessageUnsafe来做socket操作
  2. NioByteUnsafe NioSocketChannel使用NioByteUnsafe来做socket操作
  • 处理每一个连接
    EventExecutorGroupEventExecutorGroup 负责经由其使用next()方法提供EventExecutor。 除此之外,还负责处理自己的生命周期,并允许在全局模式中关闭它们。

EventExecutor

EventExecutor是个特殊的EventExecutorGroup,附带一些快捷方法,看是否有Thread在事件循环执行。

除此之外,它还继承了EventExecutorGroup以允许通用的方法来访问。

eventloopGroup

特殊的 EventExecutorGroup,它允许注册 Channel,即事件循环期间可以执行 channel 操作,得到处理,供以后选用

3.2 Channel

  • 以服务端的NioMessageUnsafe为例来看下read()方法的实现,对应是否有新连接进来的情况
    AbstractNioMessageChannel#doReadMessages
    AbstractNioMessageChannel#doReadMessages
    NioServerSocketChannel#doReadMessages
    NioServerSocketChannel#doReadMessages
    直接把底层的 channel 封装成 NioSocketChannel
    3.3 ByteBuf

3.4 Pipeline

小样例中对应内容,实际非常复杂
小样例中对应内容,实际非常复杂

netty 将其抽象成逻辑链,看看 netty 是怎么把每个 pipeline 加入到客户端连接的

3.5 ChannelHandler

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2018.07.13 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1 传统socket网络编程
    • 1.1 实战
      • 1.2 传统HTTP服务器原理
        • 1.3 C/S 交互流程
        • 2 Netty版socket网络编程
        • 3 Netty核心组件
          • 3.1 NioEventLoop
            • 3.1.1 简介
            • EventExecutor
            • eventloopGroup
          • 3.2 Channel
            • 3.4 Pipeline
              • 3.5 ChannelHandler
              领券
              问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档