> 技术文档 > 【项目日记】仿mudou的高并发服务器 --- 整体框架搭建 ,实现时间轮模块_仿mudo库实现并发服务器

【项目日记】仿mudou的高并发服务器 --- 整体框架搭建 ,实现时间轮模块_仿mudo库实现并发服务器

【项目日记】仿mudou的高并发服务器 --- 整体框架搭建 ,实现时间轮模块_仿mudo库实现并发服务器

命运的局限尽可永在, 不屈的挑战却不可须臾或缺。 --- 史铁生 ---


项目地址在这里: https://gitee.com/penggli_2_0/TcpServer


仿mudou的高并发服务器

  • 1 项目介绍
  • 2 模块组成
  • 3 实现时间轮模块
    • 3.1 设计思想
    • 3.2 定时任务类
    • 3.3 TimeWheel时间轮类

1 项目介绍

这是一个仿muduo库One Thread One Loop式主从Reactor模型实现⾼并发服务器项目。是对基于事件驱动Reactor模型的改良版!

通过实现的高并发服务器组件,可以简洁快速的完成⼀个⾼性能的服务器搭建。并且,通过组件内提供的不同应⽤层协议⽀持,也可以快速完成⼀个高性能应用服务器的搭建(当前为了便于项目的演⽰,项目中提供HTTP协议组件的支持)。在这里,要明确的是咱们要实现的是⼀个高并发服务器组件,因此当前的项目中并不包含实际的业务内容!

实现的是主从Reactor模型服务器!分为两个部分:主Reactor 与 子Reactor:

  1. 主Reactor线程仅仅监控监听描述符,获取新建连接,保证获取新连接的高效,提⾼服务器的并发性能。主Reactor获取到新连接后分发给⼦Reactor进⾏通信事件监控。
  2. 子Reactor线程监控各⾃的描述符的读写事件进行数据读写以及业务处理!

One Thread One Loop的思想就是把所有的操作都放到⼀个线程中进行,⼀个线程对应⼀个事件处理的循环。

当前实现中,因为并不确定组件使用者的意向,因此不提供业务层工作线程池的实现,只实现主从Reactor,而Worker工作线程池,可由组件库的使用者的需要自行决定是否使用和实现。

2 模块组成

【项目日记】仿mudou的高并发服务器 --- 整体框架搭建 ,实现时间轮模块_仿mudo库实现并发服务器

在这项目中我们需要两大模块:

  1. 协议模块:协议是双方进行通信的基础,这是一定要实现的!
  2. sever服务模块:实现Reactor模型的TCP服务器,实现高效派发任务!

SERVER模块就是对所有的连接以及线程进⾏管理,让它们各司其职,在合适的时候做合适的事,最终完成高性能服务器组件的实现。具体的管理也分为三个方面:

  • 监听连接管理:对监听连接进⾏管理。
  • 通信连接管理:对通信连接进⾏管理。
  • 超时连接管理:对超时连接进⾏管理。

基于以上的管理思想,将这个模块进⾏细致的划分⼜可以划分为以下多个子模块:

  1. Buffer模块
    Buffer模块是⼀个缓冲区模块,用于实现通信中用户态的接收缓冲区和发送缓冲区功能。先前的文章中我们使用string模拟过缓冲区,这里需要进行丰富功能!

  2. Socket模块
    Socket模块是对套接字操作封装的⼀个模块,主要实现的socket的各项操作。

  3. Channel模块
    Channel模块是对⼀个描述符需要进⾏的IO事件管理的模块,实现对描述符可读,可写,错误等事件的管理操作,以及Poller模块对描述符进⾏IO事件监控就绪后,根据不同的事件,回调不同的处理函数功能。

  4. Connection模块
    Connection模块是对Buffer模块,Socket模块,Channel模块的⼀个整体封装,实现了对⼀个通信套接字的整体的管理,每⼀个进⾏数据通信的套接字(也就是accept获取到的新连接)都会使用Connection进⾏管理。

  5. Acceptor模块
    Acceptor模块是对Socket模块,Channel模块的⼀个整体封装,实现了对⼀个监听套接字的整体的管理。

  6. TimerQueue模块
    TimerQueue模块是实现固定时间定时任务的模块,可以理解就是要给定时任务管理器,向定时任务管理器中添加⼀个任务,任务将在固定时间后被执行,同时也可以通过刷新定时任务来延迟任务的执行。这个模块主要是对Connection对象的⽣命周期管理,对非活跃连接进⾏超时后的释放功能

  7. Poller模块
    Poller模块是对多路转接epoll进⾏封装的⼀个模块,主要实现epoll的IO事件添加,修改,移除,获取活跃连接功能。

  8. EventLoop模块
    EventLoop模块可以理解就是我们上边所说的Reactor模块,进行事件派发。它是对Poller模块,TimerQueue模块,Socket模块的⼀个整体封装,进⾏所有描述符的事件监控。EventLoop模块必然是⼀个对象对应⼀个线程的模块,线程内部的目的就是运行EventLoop的启动函数。

  9. TcpServer模块
    这个模块是⼀个整体Tcp服务器模块的封装,内部封装了Acceptor模块,EventLoopThreadPool模块。

3 实现时间轮模块

3.1 设计思想

时间轮思想:时间轮的思想来源于钟表,如果我们定了⼀个3点钟的闹铃,则当时针⾛到3的时候,就代表时间到了。

同样的道理,如果我们定义了⼀个数组,并且有⼀个指针,指向数组起始位置,这个指针每秒钟向后⾛动⼀步,⾛到哪⾥,则代表哪⾥的任务该被执⾏了,那么如果我们想要定⼀个3s后的任务,则只需要将任务添加到tick+3位置,则每秒中⾛⼀步,三秒钟后tick⾛到对应位置,这时候执⾏对应位置的任务即可。

3.2 定时任务类

这里先对时间轮模块进行一个简单实现:
首先需要设计一个TimeTask 定时任务类

  1. 成员变量:
    • 任务ID uint64_t _id :用来标识任务
    • 超时时间 uint32_t _timeout
    • 回调任务 _task_cb void()类型
    • 释放操作 _release :用于删除TimeWheel保存的定时器对象信息
  2. 成员函数
  • 构造函数
  • 析构函数 :析构的时候执行定时任务,这样就可以通过释放空间实现定时实现!
  • SetRelease函数设置 _release 任务
  • DelayTime函数 返回延迟时间
class Timer{ private: uint64_t _id; // 任务Id uint32_t _timeout;