1. Channel

Channel是Netty的核心概念之一,它是Netty网络通信的主体,由它负责同对端进行网络通信、注册和数据操作等功能。

1.1 工作原理

如上图所示:

  • 一旦用户端连接成功,将新建一个channel同该用户端进行绑定
  • channel从EventLoopGroup获得一个EventLoop,并注册到该EventLoop,channel生命周期内都和该EventLoop在一起(注册时获得selectionKey)
  • channel同用户端进行网络连接、关闭和读写,生成相对应的event(改变selectinKey信息),触发eventloop调度线程进行执行
  • 如果是读事件,执行线程调度pipeline来处理用户业务逻辑

1.2 状态转换

如上图所示,Channel包含注册、活跃、非活跃和非注册状态,在一般情况下是从注册->活跃->非活跃->非注册,但用户可以从eventloop取消和重注册channel,因此在此情况下活跃->非注册->注册

1.3 线程

多个channel可以注册到一个eventloop上,所有的操作都是顺序执行的,eventloop会依据channel的事件调用channel的方法进行相关操作,每个channel的操作和处理在eventloop中都是顺序的,如下图:

2. ChannelPipeline和ChannelHandler

ChannelPipeline和ChannelHandler用于channel事件的拦截和处理,Netty使用类似责任链的模式来设计ChannelPipeline和ChannelHandlerChannelPipeline相当于ChannelHandler的容器,channel事件消息在ChannelPipeline中流动和传播,相应的事件能够被ChannelHandler拦截处理、传递、忽略或者终止,如下图所示:

2.1 INBOUD和OUTBOUND事件

inbound:当发生某个I/O操作时由IO线程流向用户业务处理线程的事件,如链路建立、链路关闭或者读完成等
outbound:由用户线程或者代码发起的IO操作事件

2.2 ChannelHandlerContext

每个ChannelHandler 被添加到ChannelPipeline 后,都会创建一个ChannelHandlerContext 并与之创建的ChannelHandler 关联绑定。如下图:

ChannelHandler通过ChannelHandlerContext来操作channel和channelpipeline

2.3 ChannelHandler

ChannelHandler负责I/O事件或者I/O操作进行拦截和处理,用户可以通过ChannelHandlerAdapter来选择性的实现自己感兴趣的事件拦截和处理。

由于Channel只负责实际的I/O操作,因此数据的编解码和实际处理都需要通过ChannelHandler进行处理。

2.4 注意

ChannelPipeline是线程安全的,多个业务线程可以并发的操作ChannelPipeline;ChannelHandler不是线程安全的,用户需要自己保重ChannelHandler的线程安全

3. ChannelFuture与ChannelPromise

在Netty中,所有的I/O操作都是异步的,因此调用一个I/O操作后,将继续当前线程的执行,但I/O操作的结果怎么获得?——ChannelFuture。

如上图,当前线程A异步发起I/O操作后,不阻塞继续执行相关操作,当IO线程B完成后,通过回调执行A设置的回调方法。

回调方法通过监听的形式实现:ChannelFutureListener。

ChannelPromise是ChannelFuture的扩展,允许设置I/O操作的结果,使ChannelFutureListener可以执行相关操作

转载于:https://www.cnblogs.com/TomSnail/p/6192885.html

Netty学习四:Channel相关推荐

  1. Netty 学习和进阶策略

    https://www.infoq.cn/article/xt9*7K4fJktiuWTLYrZS 背景 Netty 框架的特点 Netty 的一个特点就是入门相对比较容易,但是真正掌握并精通是非常困 ...

  2. Netty学习笔记(六)Pipeline的传播机制

    前面简单提到了下Pipeline的传播机制,这里再详细分析下 Pipeline的传播机制中有两个非常重要的属性inbound和outbound(AbstractChannelHandlerContex ...

  3. Netty学习笔记(二)Netty服务端流程启动分析

    先贴下在NIO和Netty里启动服务端的代码 public class NioServer { /*** 指定端口号启动服务* */public boolean startServer(int por ...

  4. Netty 学习笔记(已完结)

    Netty 0代码示例 A.经典IO多线程 // 获取到的inputStream是SocketInputStream,这个类不是公开的,继承了FileInputStream, InputStream ...

  5. 04、Netty学习笔记—(黏包半包及协议设计解析)

    文章目录 一.粘包与半包 1.1.现象分析 1.1.1.粘包.半包情况分析 1.1.2.滑动窗口.MSS限制.Nagle算法介绍 1.2.粘包.半包现象复现 1.2.1.粘包复现 1.2.2.半包复现 ...

  6. 尚硅谷Netty学习笔记

    Netty 一些问题 1.阻塞与非阻塞 阻塞和非阻塞指的是执行一个操作是等操作结束再返回,还是马上返回 举例:在 BIO 案例的 handler 方法中,如果读取不到数据就会阻塞在 read() 方法 ...

  7. Netty学习笔记二网络编程

    Netty学习笔记二 二. 网络编程 1. 阻塞模式 阻塞主要表现为: 连接时阻塞 读取数据时阻塞 缺点: 阻塞单线程在没有连接时会阻塞等待连接的到达,连接到了以后,要进行读取数据,如果没有数据,还要 ...

  8. Netty学习笔记一NIO基础

    Netty学习笔记一 一. NIO 基础 non-blocking io 非阻塞IO (也可称为new IO, 因为是JDK1.4加入的) 1. 三大组件 1.1 Channel 通道:数据的传输通道 ...

  9. Netty学习笔记(二) 实现服务端和客户端

    在Netty学习笔记(一) 实现DISCARD服务中,我们使用Netty和Python实现了简单的丢弃DISCARD服务,这篇,我们使用Netty实现服务端和客户端交互的需求. 前置工作 开发环境 J ...

最新文章

  1. c语言中管理员信息注册,regsvr32注册控件如果使用管理员身份执行
  2. 【译】在ASP.Net和IIS中删除不必要的HTTP响应头
  3. python打开csv文件乱码_python脚本解决csv文件用excel打开乱码
  4. 第一范式,第二范式,第三范式,BCNF范式理解
  5. python os.environ windows_python 获取系统环境变量 os.environ and os.putenv
  6. PyTorch Cookbook by Eric
  7. Codeforces Round #772 (Div. 2) D. Infinite Set (动态规划+思维)
  8. rand()和srand()GetTickCount函数用法
  9. mysql简易购物车系统_jsp+mysql实例简单的购物车
  10. NFC Reader Tool 蓝牙NFC读写器使用教学
  11. 分布式系统互斥算法---令牌环算法
  12. 值得收藏!最佳26个国外 CSS 酷站推荐网站
  13. 洛克菲勒写给儿子的38封信
  14. HTML中Form表单的使用
  15. 微信小程序中使用第三方库的方法
  16. 阿里飞冰的介绍以及使用
  17. RT-Thread学习笔记【ADC与DAC设备】
  18. 下载国外软件慢(例如:Python安装包)
  19. 硬件设计学习笔记---第一季第一集
  20. 网络推广100法,果然很强悍。

热门文章

  1. mvcc原理_MVCC原理探究及MySQL源码实现分析
  2. 【2017-02-19】数据类型、类型转换、常量、变量、转义符。
  3. SpringSecurity简单应用(二)
  4. [转]为mysql数据库建立索引
  5. Qt 事件处理机制-qt源码解读
  6. 模态对话框的消息循环原理及分析笔记
  7. HTTP 错误 404.13 - Not Found 请求筛选模块被配置为拒绝超过请求内容长度的请求。(上传文件长度问题)
  8. TabControl控件和TabPage的使用
  9. Android—EventBus使用与源码分析
  10. C语言之连接Mysql数据篇