重写Sylar基于协程的服务器(7、TcpServer HttpServer的设计与实现)

news/2024/12/22 20:11:08/

重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现)

重写Sylar基于协程的服务器系列:

重写Sylar基于协程的服务器(0、搭建开发环境以及项目框架 || 下载编译简化版Sylar)

重写Sylar基于协程的服务器(1、日志模块的架构)

重写Sylar基于协程的服务器(2、配置模块的设计)

重写Sylar基于协程的服务器(3、协程模块的设计)

重写Sylar基于协程的服务器(4、协程调度模块的设计)

重写Sylar基于协程的服务器(5、IO协程调度模块的设计)

重写Sylar基于协程的服务器(6、HOOK模块的设计)

重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现)

TcpServer模块架构图

将基于线程的主从Reactor模型进行协程的定制化修改,如图所示。

TcpServer架构图

TcpServer实现

TcpServer类是一个服务器通用类,TcpServer类的实现是Server端专门用来管理Tcp连接的,主要的成员函数及作用如下:

  1. 构造函数,用户在构造一个TcpServer时会传三个类型都为IOManager的参数,参数名以功能命名,分别是:worker、io_worker、accept_worker。

  2. bind函数,因为一台服务器有可能有多个<ip,端口>对,所以用户在调用bind函数时,可能会传入多个地址对,bind函数就是负责为这些ip地址创建套接字,并且将ip地址和固定端口绑定,开始监听这些套接字。

  3. start函数,创建accept协程,并将accept协程放到accept_worker协程调度器里面去,accept协程实际上就是回调函数是TcpServer::startAccept的协程。

    start函数的伪代码:

    start函数伪代码

  4. startAccept函数,是一个接受客户端连接的回调函数,内部是一个调用accept函数的死循环,在接受到一个socketfd后,将套接字封装成IO协程,并放入io_worker协程调度器中进行调度。IO协程就是回调函数是TcpServer::handleClient函数的协程。

    startAccept函数的伪代码:

    StartAcceptor函数伪代码

  5. handleClient函数,该函数是一个虚函数,是专门用来和客户请求对接的协程,在TcpServer中是一个简单打印连接信息的虚函数,想要实现一个实用的服务器(如HTTP服务器、FTP服务器等)只需要对handleClient函数做定制化重写即可。

    handleClient函数伪代码:

    HandleClient函数伪代码

HTTP服务器的实现

HttpServer类继承TcpServer类并重写TcpServer::handleClient函数。
HttpServer类重写了handleClient函数,内部实现为不断调用recvRequest函数的死循环,recvRequest函数底层会调用read函数读取并解析客户请求。在调用revcRequest函数后会将解析的请求提交给Servlet类处理请求,Servlet层会返回回复报文,然后利用sendResponse函数,将回复报文发送回客户端。sendResponse函数底层调用write函数。

handleClient函数重写如下:

HandleClient函数重写

感兴趣的同学,可以阅读一下本文实现的源码:https://github.com/LunarStore/lunar

于此Sylar基础模块设计的讲解完结。

除了基于协程的服务器外,推荐读者也可以去看一下Muduo基于线程的网络库的设计。两者对比着学习才能有更好的理解。sylar相对于Muduo来说,性能确实没那么高,但是sylar设计的初衷是奔着框架去的,所以sylar基础设施做的特别好,比如有Muduo没有的配置模块、动态库模块、daemon模块等,sylar另一大优势是对网络编程友好,可以以同步的方式进程网络业务的编写,同时享受异步的性能。而深入阅读Muduo其实就可以发现Muduo网络库One Loop Per Thread的思想,和Nginx的One Loop Per Process有神奇的相似之处,这种模型,靠着每个线程都有自己的loop和任务队列,将需要跨线程执行的任务添加到各自的队列中去串行执行,加锁的临界区会很小,几乎不需要锁。所以Muduo性能很高。

Muduo源码笔记系列:

muduo源码阅读笔记(0、下载编译muduo)

muduo源码阅读笔记(1、同步日志)

muduo源码阅读笔记(2、对C语言原生的线程安全以及同步的API的封装)

muduo源码阅读笔记(3、线程和线程池的封装)

muduo源码阅读笔记(4、异步日志)

muduo源码阅读笔记(5、Channel和Poller)

muduo源码阅读笔记(6、EvevntLoop和Thread)

muduo源码阅读笔记(7、EventLoopThreadPool)

muduo源码阅读笔记(8、定时器TimerQueue)

muduo源码阅读笔记(9、TcpServer)

muduo源码阅读笔记(10、TcpConnection)

muduo源码阅读笔记(11、TcpClient)


本章完结


http://www.ppmy.cn/news/1346690.html

相关文章

两次NAT

两次NAT即Twice NAT&#xff0c;指源IP和目的IP同时转换&#xff0c;该技术应用于内部网络主机地址与外部网络上主机地址重叠的情况。 如图所示&#xff0c;两次NAT转换的过程如下: 内网Host A要访问地址重叠的外部网络Host B&#xff0c;Host A向位于外部网络的DNS服务器发送…

【网页设计期末】茶文化网站

本文资源&#xff1a;https://download.csdn.net/download/weixin_47040861/88818886 1.题目要求 设计要求&#xff1a; &#xff08;1&#xff09;网站页面数量不少于4个&#xff0c;文件命名规范&#xff0c;网站结构要求层次清楚&#xff0c;目录结构清晰&#xff0c;代码…

【doghead】VS2022 win11 安装配置WSL2 以编译linux端的cmake项目并运行2

【bifrost】VS2022 win11 安装配置WSL2 以编译linux端的cmake项目并运行1 完成了WSL2的安装。13900K 的电脑安装了ubuntu22.04构建中出现了一些问题,fix了。发现libuv 似乎不识别,认为是libuv.so ,无法让worker识别到uv 从而没构建。干脆单独构建好了,官方的脚本如此:而且…

laravel distinct查询问题,laravel子查询写法

直接调用后&#xff0c;count查询会和实际查询的数据对不上&#xff0c;count还是查询全部数据&#xff0c;而实际的列表是去重的。 给distinct加上参数&#xff0c;比如去重的值的id&#xff0c;就加id。 另一种写法是使用group by id 子查询。 sql语句&#xff1a; selec…

通过nginx学习linux进程名的修改

目录 1. 缘起2. 背景知识3. 源码分析3.1 准备工作3.2 设置进程名字 1. 缘起 在运行nginx的时候&#xff0c;用ps查看nginx的进程信息&#xff0c;可能的输出如下&#xff1a; root 42169 3105 0 16:51 ? 00:00:00 nginx: master process ./objs/nginx root …

市场复盘总结 20240207

仅用于记录当天的市场情况&#xff0c;用于统计交易策略的适用情况&#xff0c;以便程序回测 短线核心&#xff1a;不参与任何级别的调整&#xff0c;采用龙空龙模式 一支股票 10%的时候可以操作&#xff0c; 90%的时间适合空仓等待 二进三&#xff1a; 进级率中 75% 最常用…

Springboot 整合 Elasticsearch(三):使用RestHighLevelClient操作ES ①

&#x1f4c1; 前情提要&#xff1a; Springboot 整合 Elasticsearch&#xff08;一&#xff09;&#xff1a;Linux下安装 Elasticsearch 8.x Springboot 整合 Elasticsearch&#xff08;二&#xff09;&#xff1a;使用HTTP请求来操作ES 目录 一、Springboot 整合 Elasticsea…

应用案例 | Softing dataFEED OPC Suite助力挤出机械自动化系统OPC UA升级

某知名挤出机械整体方案供应商在其最新自动化系统中采用了Softing dataFEED OPC Suite作为标准的OPC UA通信方案&#xff0c;不仅可采集多个西门子S7-1200控制器数据&#xff0c;而且为终客户提供了可靠、高性能的挤出机械自动化解决方案。 一 背景 多年前&#xff0c;该挤出机…