当前位置: 首页 > ds >正文

【Netty系列】Reactor 模式 2

目录

流程图说明

关键流程


以下是 Reactor 模式流程图,结合 Netty 的主从多线程模型,帮助你直观理解事件驱动和线程分工:


流程图说明

  1. Clients(客户端)
    • 多个客户端(Client 1~N)向服务端发起连接请求。
  1. Main Reactor(主 Reactor)
    • bossGroup 中的单个 EventLoop 线程负责监听端口(如 8080)。
    • Acceptor 接受新连接,并将新连接的 Channel 分配给 workerGroup 中的某个子 Reactor(如轮询分配)。
  1. Sub Reactors(子 Reactor)
    • workerGroup 包含多个 EventLoop 线程(如 EventLoop 1~N),每个线程处理多个 Channel 的 I/O 事件。
    • 例如:EventLoop 1 处理 Channel 1 的读写,EventLoop 2 处理 Channel 2 的读写。
  1. ChannelPipeline(责任链)
    • 每个 Channel 对应一个 Pipeline,数据按顺序经过解码器、业务逻辑、编码器等处理步骤。

关键流程

  1. 连接建立
    • 客户端发起 TCP 连接 → Main Reactor 的 Acceptor 接受连接 → 分配 Channel 给 Sub Reactor。
  1. I/O 事件处理
    • Sub Reactor 的 EventLoop 监听 Channel 的读写事件 → 触发 channelRead → 数据通过 Pipeline 处理。
  1. 非阻塞机制
    • 每个 EventLoop 使用 Selector 监听多个 Channel,实现单线程处理多连接的 I/O 事件。

http://www.xdnf.cn/news/10170.html

相关文章:

  • 奇异值分解(SVD):线性代数在AI大模型中的核心工具
  • 使用原生前端技术封装一个组件
  • 面试题 08.08. 有重复字符串的排列组合【 力扣(LeetCode) 】
  • Smith圆图知识学习笔记
  • Linux 文件 IO 性能监控与分析指南
  • QEMU/KVM课程大纲暨学习路线(1)
  • 榕壹云医疗服务系统:基于ThinkPHP+MySQL+UniApp的多门店医疗预约小程序解决方案
  • 算法打卡第11天
  • BKP(备份寄存器)和 RTC(实时时钟)
  • 飞牛fnNAS的Docker应用之迅雷篇
  • leetcode538.把二叉搜索树转换为累加树:反向中序遍历的数值累加之道
  • 半导体厂房设计建造流程、方案和技术要点-江苏泊苏系统集成有限公司
  • 跨平台浏览器集成库JxBrowser 支持 Chrome 扩展程序,高效赋能 Java 桌面应用
  • Apache SeaTunnel 引擎深度解析:原理、技术与高效实践
  • 【Linux 基础知识系列】第四篇-用户与权限管理
  • c/c++的opencv霍夫变换
  • 阻止H5页面中键盘收起的问题
  • CTFSHOW Pwn94 WP
  • [原创](Windows使用技巧): Windwos11如何设置局域网共享访问? (多图详解)
  • 在Linux上安装Docker并配置镜像加速器:从入门到实战
  • PostgreSQL 临时表空间
  • AWS API Gateway 配置WAF(中国区)
  • 《智慧医疗分级评价方法及标准(2025版)》征求意见函全面解读:人工智能医疗应用的评价体系与指南方向
  • 无线通信模块简介
  • 智能流体仿真软件AICFD 2025R1新版本功能介绍
  • 每日c/c++题 备战蓝桥杯(Cantor 表)
  • LangChain实战:MMR和相似性搜索技术应用
  • 【python深度学习】Day 40 训练和测试的规范写法
  • 【C++】C++面向对象设计的核心思想之一: 接口抽象、解耦和可扩展性
  • Python打卡训练营Day40