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

2024-02-05 04:44

本文主要是介绍重写Sylar基于协程的服务器(7、TcpServer HttpServer的设计与实现),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

重写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)


本章完结

这篇关于重写Sylar基于协程的服务器(7、TcpServer HttpServer的设计与实现)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/679775

相关文章

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中,括号匹配是一个常见问题,尤其是在

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下:需要在

ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法

《ElasticSearch+Kibana通过Docker部署到Linux服务器中操作方法》本文介绍了Elasticsearch的基本概念,包括文档和字段、索引和映射,还详细描述了如何通过Docker... 目录1、ElasticSearch概念2、ElasticSearch、Kibana和IK分词器部署

部署Vue项目到服务器后404错误的原因及解决方案

《部署Vue项目到服务器后404错误的原因及解决方案》文章介绍了Vue项目部署步骤以及404错误的解决方案,部署步骤包括构建项目、上传文件、配置Web服务器、重启Nginx和访问域名,404错误通常是... 目录一、vue项目部署步骤二、404错误原因及解决方案错误场景原因分析解决方案一、Vue项目部署步骤

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本

Linux流媒体服务器部署流程

《Linux流媒体服务器部署流程》文章详细介绍了流媒体服务器的部署步骤,包括更新系统、安装依赖组件、编译安装Nginx和RTMP模块、配置Nginx和FFmpeg,以及测试流媒体服务器的搭建... 目录流媒体服务器部署部署安装1.更新系统2.安装依赖组件3.解压4.编译安装(添加RTMP和openssl模块

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque