【Netty】反应器 Reactor 模式 ( 单反应器 Reactor 单线程 | 单反应器 Reactor 多线程 )

简介: 【Netty】反应器 Reactor 模式 ( 单反应器 Reactor 单线程 | 单反应器 Reactor 多线程 )

文章目录

一、 反应器 ( Reactor ) 模式

二、 反应器 ( Reactor ) 模式两大组件

三、 单反应器 ( Reactor ) 单线程

四、 单反应器 ( Reactor ) 单线程 与 NIO 模型对应关系

五、 单反应器 ( Reactor ) 单线程优缺点分析

六、 单反应器 ( Reactor ) 多线程

七、 单反应器 ( Reactor ) 多线程优缺点分析





一、 反应器 ( Reactor ) 模式


反应器 ( Reactor ) 模式 简介 :



① 基于事件驱动 : 多个客户端同时向服务器端传递数据 , 每个客户端传递数据的行为都称为一个事件 , 每个事件都会触发相应操作 ;


② 服务器端处理事件 : 服务器端接收到多个客户端发送的事件请求 , 将这些事件对应的操作分发给对应的线程进行处理 ; 反应器 ( Reactor ) 模式 , 又称为 分发者 ( Dispatcher ) 模式 ;



反应器 ( Reactor ) 模式 中监听客户端请求事件 , 服务器端监听到事件后 , 将事件分发给指定的线程处理 ( 可以是唯一的一个 , 也可以是多个线程中的一个 ) ;






二、 反应器 ( Reactor ) 模式两大组件


反应器 ( Reactor ) 模式 涉及到两个组件 , 反应器 ( Reactor ) 组件 和 处理者 ( Handler ) 组件 ;



1 . 反应器 ( Reactor ) 组件 : 该组件调度分发事件给 处理者 ( Handler ) 组件 , 处理与相应客户端的 IO 事件 ;



① 运行线程 : 反应器 ( Reactor ) 在独立线程中运行 , 该线程只负责事件相关的监听与分发操作 , 不处理具体的业务逻辑 ;


② 监听事件 : 反应器 ( Reactor ) 在线程中监听客户端的请求事件 ;


③ 分发事件 : 反应器 ( Reactor ) 监听到事件后 , 将事件分发给其 处理者 ( Handler ) 组件 处理实际的业务逻辑 ;



2 . 处理者 ( Handler ) 组件 : 该 Handler 组件用于 处理实际的业务逻辑 ;








三、 单反应器 ( Reactor ) 单线程


1 . 单 反应器 ( Reactor ) 单 线程 模型 :



① 客户端 : 向服务器发送请求事件 ;


② 服务器端 反应器 ( Reactor ) : 有两个功能 , 监听 ( Select ) 和 分发 ( Dispatch ) , 监听客户端请求事件 , 获取到事件后 , 将事件分发给 接受者 ( Acceptor ) 或 处理者 ( Handler ) ;


③ 服务器端 接受者 ( Acceptor ) : 负责处理客户端与服务器端建立 Socket 连接的操作 ;


④ 服务器端 处理者 ( Handler ) : 负责与客户端的数据交互 , 执行实际业务处理操作 , 调用 read 方法读取客户端上传的数据 , 并进行相应的业务处理 , 调用 write 方法将服务器的反馈数据发送给客户端 ; ( 读取客户端数据 -> 执行业务处理操作 -> 将结果回送给客户端 )



image.png





四、 单反应器 ( Reactor ) 单线程 与 NIO 模型对应关系


NIO 服务器与客户端通信 , 与上面的 反应器 ( Reactor ) 模式 是对应的 :



① 反应器 ( Reactor ) : NIO 中的 选择器 ( Selector ) 对应 反应器 ( Reactor ) ;


② 接受者 ( Acceptor ) : 反应器 ( Reactor ) 模式中的 接受者 ( Acceptor ) , 对应 NIO 中处理客户端与服务器端的连接事件 ;


③ 处理者 ( Handler ) : NIO 中的选择器 ( Selector ) 监听读取数据事件并进行相应处理 , 对应 处理者 ( Handler ) ;

image.png





五、 单反应器 ( Reactor ) 单线程优缺点分析


1 . 单反应器 ( Reactor ) 单线程 优点 : 单个线程实现 , 模型简单 , 不用考虑线程通信 , 线程同步等问题 ;




2 . 单 反应器 ( Reactor ) 单 线程 模型 弊端 : 除了简单之外 , 全是问题 ;



① 容易出现阻塞 : 该模式下 , 只有一个线程 , 处理者 ( Handler ) 每次只能处理一个客户端的请求事件 , 如果客户端数量很多 , 出现高并发情况 , 只能阻塞等待前面的 处理者 ( Handler ) 将事件处理完毕 , 才能轮到后面的事件开始处理 ;


② 服务器性能 : 一般的服务器都是多核多线程 CPU , 只跑一个线程 , 浪费了大量服务器性能 ;


③ 处理延迟 : 当 处理器 ( Handler ) 处理一个客户端的业务逻辑时 , 无法及时响应其它客户端的连接 , 造成延迟 ;


④ 可靠性问题 : 如果仅有的一个线程运行出现异常 , 整个程序都崩了 ;




3 . 单反应器 ( Reactor ) 单线程 模型 适用场景 : 不容易出现堵塞的场景 , 即连接少 , 处理速度快 的场景 ;



① 客户端数量较少 : 客户端少 , 连接少 , 并发数量不高 ;


② 业务处理速度快 : 每个客户端连接执行的都是耗时较少的操作 ;






六、 单反应器 ( Reactor ) 多线程


1 . 单 反应器 ( Reactor ) 单 线程 模型 :



① 客户端 : 向服务器发送请求事件 ;


② 服务器端 反应器 ( Reactor ) : 该反应器 ( Reactor ) 占用一个单独的线程 , 反应器 ( Reactor ) 有两个功能 , 监听 ( Select ) 和 分发 ( Dispatch ) , 监听客户端请求事件 , 获取到事件后 , 将事件分发给 接受者 ( Acceptor ) 或 处理者 ( Handler ) ;


建立连接请求 , 分发 ( Dispatch ) 给 接受者 ( Acceptor ) ;

处理与客户端业务逻辑 , 分发给 处理者 ( Handler ) ;

③ 服务器端 接受者 ( Acceptor ) : 负责处理客户端与服务器端建立 Socket 连接的操作 ;


④ 服务器端 处理者 ( Handler ) : Handler 只负责响应业务处理的请求事件 , 不处理具体的与客户端交互的业务逻辑 , 因此不会长时间阻塞 , 其调用 read 方法读取客户端数据后 , 将业务逻辑交给 线程池 ( Worker ) 处理相关业务逻辑 , 处理完毕后 , 将结果返回 , Handler 将该结果写出到客户端 ;


⑤ 服务器端 线程池 ( Worker ) : 接收 处理者 ( Handler ) 的请求 , 为将请求对应业务逻辑操作 , 分配给某个独立线程完成 , 执行完成后的结果再次返回给 处理者 ( Handler ) ,


( Handler 读取客户端数据 -> Worker 线程池分配线程执行业务处理操作 -> Handler 将结果回送给客户端 )








七、 单反应器 ( Reactor ) 多线程优缺点分析


1 . 单反应器 ( Reactor ) 多线程 优点 : 充分发挥出服务器多核多线程 CPU 的优势 , 根据 CPU 性能定制线程个数 , 没有性能上的浪费 ;




2 . 单反应器 ( Reactor ) 多线程 缺点 :



① 数据同步 : 线程池 ( Worker ) 中的多个业务逻辑处理线程 , 需要与 处理器 ( Handler ) 共享数据 , 涉及到数据跨线程传输访问 , 比较复杂 ;


② 反应器 ( Reactor ) 负载较大 : 反应器 ( Reactor ) 处理所有的客户端的事件的监听与分发操作 , 其 在单线程中运行 , 如果并发数量很高 , 也是有线程堵塞的性能瓶颈产生 ;


目录
相关文章
|
1月前
|
NoSQL Redis
单线程传奇Redis,为何引入多线程?
Redis 4.0 引入多线程支持,主要用于后台对象删除、处理阻塞命令和网络 I/O 等操作,以提高并发性和性能。尽管如此,Redis 仍保留单线程执行模型处理客户端请求,确保高效性和简单性。多线程仅用于优化后台任务,如异步删除过期对象和分担读写操作,从而提升整体性能。
68 1
|
29天前
|
缓存 安全 Java
【JavaEE】——单例模式引起的多线程安全问题:“饿汉/懒汉”模式,及解决思路和方法(面试高频)
单例模式下,“饿汉模式”,“懒汉模式”,单例模式下引起的线程安全问题,解锁思路和解决方法
|
3月前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
53 3
|
3月前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
35 2
|
3月前
|
Java
Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口
【10月更文挑战第20天】《JAVA多线程深度解析:线程的创建之路》介绍了Java中多线程编程的基本概念和创建线程的两种主要方式:继承Thread类和实现Runnable接口。文章详细讲解了每种方式的实现方法、优缺点及适用场景,帮助读者更好地理解和掌握多线程编程技术,为复杂任务的高效处理奠定基础。
56 2
|
3月前
|
Java 开发者
Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点
【10月更文挑战第20天】Java多线程初学者指南:介绍通过继承Thread类与实现Runnable接口两种方式创建线程的方法及其优缺点,重点解析为何实现Runnable接口更具灵活性、资源共享及易于管理的优势。
58 1
|
3月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
71 1
|
2月前
|
数据采集 Java Python
爬取小说资源的Python实践:从单线程到多线程的效率飞跃
本文介绍了一种使用Python从笔趣阁网站爬取小说内容的方法,并通过引入多线程技术大幅提高了下载效率。文章首先概述了环境准备,包括所需安装的库,然后详细描述了爬虫程序的设计与实现过程,包括发送HTTP请求、解析HTML文档、提取章节链接及多线程下载等步骤。最后,强调了性能优化的重要性,并提醒读者遵守相关法律法规。
87 0
|
3月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
72 1
|
3月前
|
Java
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件成立时被唤醒,从而有效解决数据一致性和同步问题。本文通过对比其他通信机制,展示了 `wait()` 和 `notify()` 的优势,并通过生产者-消费者模型的示例代码,详细说明了其使用方法和重要性。
59 1