获课：weiranit.fun/4976/
获取ZY↑↑方打开链接↑↑
Reactor 模式简介
Reactor 模式是一种基于事件驱动的并发处理模式。核心思想是将所有事件统一处理，通过事件分派器将事件分发给对应的事件处理器。主要具有以下优点：
-
高并发：能同时处理大量并发连接。
-
高性能：事件处理在同一线程完成，减少线程切换开销。
-
易于扩展：新增事件类型只需添加相应的事件处理器。
C++ 实现百万并发 Reactor 服务器
-
网络库选择：可选择如 Boost.Asio 等 C++ 网络库，其提供异步 IO 操作，便于实现 Reactor 模式。
-
服务器架构
-
事件循环（EventLoop）：负责监听事件，并将事件分发给相应的事件处理器。
-
事件分派器（Dispatcher）：根据事件类型，将事件分发给对应的事件处理器。
-
事件处理器（Handler）：处理具体事件，如连接建立、数据读写、连接关闭等。
-
-
关键代码实现
-
EventLoop 类：
-
cpp
class EventLoop {public: void loop() { while (true) { // 监听事件 pollEvents(); // 处理事件 handleEvents(); } }private: void pollEvents() { // 使用epoll等机制监听事件 } void handleEvents() { // 遍历事件，分发给相应的事件处理器 }};
-
Handler 基类：
cpp
class Handler {public: virtual void handleEvent() = 0;};
-
TcpConnection 类：
cpp
class TcpConnection : public Handler {public: void handleEvent() override { // 处理TCP连接事件 }};
-
性能优化
-
使用多线程：将事件循环运行在多个线程中，提高 CPU 利用率。
-
使用内存池：减少内存分配和释放的开销。
-
零拷贝技术：减少数据在用户态和内核态之间的拷贝。
-
与其它服务器的不同之处
-
与同步阻塞服务器相比：同步阻塞服务器处理每个连接时会阻塞当前线程，高并发场景下性能差，无法充分利用 CPU 资源；Reactor 服务器通过事件驱动方式，能更好利用 CPU 资源。
-
与异步非阻塞服务器（如 Proactor 模式）相比：Proactor 模式处理 IO 操作时将操作提交给操作系统，完成后由操作系统通知线程，减少了线程切换开销，但在 C++ 中实现复杂，且依赖操作系统异步 IO 接口；Reactor 服务器在 C++ 中实现较简单，有较好的跨平台性。
-
要优化 C++ 实现的百万并发 Reactor 服务器的性能，可以从多个方面入手，下面为你详细介绍：网络 IO 层面
-
1. 选择高效的 IO 多路复用机制
-
不同的操作系统提供了不同的 IO 多路复用机制，应根据具体的操作系统选择最合适的机制：
-
Linux：优先使用
epoll，它采用事件通知机制，在处理大量并发连接时，性能远远优于传统的select和poll。epoll有两种工作模式，水平触发（LT）和边缘触发（ET），ET 模式可以减少不必要的系统调用，提高性能，可根据业务需求合理选择。 -
cpp
#include <sys/epoll.h>// 创建 epoll 实例int epoll_fd = epoll_create1(0);// 添加监听事件struct epoll_event ev;ev.events = EPOLLIN | EPOLLET; // 使用边缘触发模式ev.data.fd = listen_fd;epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listen_fd, &ev);
-
Windows：使用
IOCP（I/O Completion Ports），它是 Windows 下高效的异步 IO 模型，能很好地处理大量并发连接。
2. 零拷贝技术
减少数据在用户空间和内核空间之间的拷贝次数，可以显著提高数据传输效率。
-
sendfile：在 Linux 中，可以使用
sendfile函数，它允许将文件内容直接从磁盘传输到网络套接字，避免了数据在用户空间的缓冲。
cpp
#include <sys/sendfile.h>#include <fcntl.h>int file_fd = open("file.txt", O_RDONLY);off_t offset = 0;sendfile(socket_fd, file_fd, &offset, file_size);
线程与并发层面
1. 多线程模型
-
主从 Reactor 模型：将连接的接受和事件处理分离。主 Reactor 负责监听新的连接，当有新连接到来时，将其分配给从 Reactor 进行后续的事件处理。从 Reactor 可以有多个，每个从 Reactor 运行在一个独立的线程中，这样可以充分利用多核 CPU 的性能。
-
cpp
// 主 Reactor 线程void main_reactor() { // 监听新连接 while (true) { int conn_fd = accept(listen_fd, ...); // 将 conn_fd 分配给从 Reactor }}// 从 Reactor 线程void sub_reactor() { // 处理连接上的事件 while (true) { // 事件循环 }}
-
线程池：对于一些耗时的任务，如业务逻辑处理，可以使用线程池来避免阻塞 Reactor 线程。当有任务到来时，从线程池中取出一个线程来处理任务，处理完成后将线程归还到线程池。
2. 减少锁竞争
锁竞争会导致线程阻塞，降低系统的并发性能。可以采用以下方法减少锁竞争：
-
无锁数据结构：使用无锁队列、无锁哈希表等数据结构，避免使用传统的加锁方式来保证数据的一致性。
-
细粒度锁：将大锁拆分成多个小锁，减少锁的粒度，从而减少锁的持有时间和锁竞争的概率。
内存管理层面
1. 内存池技术
频繁的内存分配和释放会导致内存碎片，降低系统性能。使用内存池技术可以预先分配一大块内存，当需要使用内存时，直接从内存池中获取，使用完后归还给内存池，避免了频繁的系统调用。
cpp
class MemoryPool {public: MemoryPool(size_t block_size, size_t block_count) { // 预先分配内存块 } void* allocate() { // 从内存池中获取内存块 } void deallocate(void* ptr) { // 将内存块归还给内存池 }};
2. 缓冲区管理
合理管理网络数据的缓冲区，避免频繁的缓冲区扩容和缩容。可以采用固定大小的缓冲区，或者根据数据量动态调整缓冲区大小，但要注意控制调整的频率。
代码优化层面
1. 减少系统调用
系统调用会带来较大的开销，尽量减少不必要的系统调用。例如，可以批量处理数据，一次性读取或写入更多的数据，而不是频繁地进行小数据量的读写操作。
2. 优化算法和数据结构选择合适的算法和数据结构可以提高代码的执行效率。例如，使用哈希表来快速查找数据，使用红黑树来维护有序数据等。
3. 编译器优化
合理使用编译器的优化选项，如
-O2
、
-O3
等，可以让编译器对代码进行优化，提高代码的执行速度。例如，在使用
g++
编译时，可以使用以下命令：
sh
g++ -O3 -o server server.cpp
监控与调优
1. 性能监控工具
使用性能监控工具，如
strace
、
perf
、
gdb
等，来分析服务器的性能瓶颈。例如，使用
strace
可以查看服务器的系统调用情况，使用
perf
可以分析 CPU 的使用情况。
2. 动态调整参数
根据服务器的运行情况，动态调整一些参数，如线程池的大小、缓冲区的大小等，以达到最佳的性能。例如，可以根据服务器的负载情况，动态调整线程池中的线程数量。
