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

【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.lryc.cn/news/2398991.html

相关文章:

  • SDL_CreateRendererWithProperties报错Parameter ‘window‘ is invalid
  • 在容器里运行go程序报错:/bin/sh: ./manager: not found
  • TomatoSCI分析日记:数据分析为什么用csv不用excel
  • HTTP协议完全指南:从请求响应到HTTPS安全机制
  • [Java 基础]Java 语言的规范
  • SpringBoot插件化架构的4种实现方案
  • 设计模式——状态设计模式(行为型)
  • CppCon 2014 学习:Lightning Talk: Writing a Python Interpreter for Fun and Profit
  • CTFHub-RCE 命令注入-过滤运算符
  • 【音视频】H265 NALU分析
  • 运维 vm 虚拟机ip设置
  • 飞牛fnNAS存储模式RAID 5数据恢复
  • 论文笔记:DreamDiffusion
  • 户外摄像头监控如何兼顾安全实时监控
  • Neo4j 备份与恢复:原理、技术与最佳实践
  • 简单实现Ajax基础应用
  • 关于 java:3. Java 常用类库与数据结构
  • 数据挖掘顶刊《IEEE Transactions on Knowledge and Data Engineering》2025年5月研究热点都有些什么?
  • LabVIEW双光子显微镜开发
  • WordPress 6.5版本带来的新功能
  • 将材质球中的纹理属性对应的贴图保存至本地
  • Linux应用开发之网络套接字编程
  • 实现RabbitMQ多节点集群搭建
  • GLIDE论文阅读笔记与DDPM(Diffusion model)的原理推导
  • 机器学习——放回抽样
  • 前端内存泄漏:原理、检测与防范实践
  • Go的隐式接口机制
  • UE音频中间件wwise插件
  • C++.cstring string
  • Spring AOP 和 AspectJ 有什么区别