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

这篇具有很好参考价值的文章主要介绍了重写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模型进行协程的定制化修改,如图所示。

重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现),重写Sylar基于协程服务器,服务器,开源,c++,后端,架构,sylar,网络编程

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函数的伪代码:

    重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现),重写Sylar基于协程服务器,服务器,开源,c++,后端,架构,sylar,网络编程

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

    startAccept函数的伪代码:

    重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现),重写Sylar基于协程服务器,服务器,开源,c++,后端,架构,sylar,网络编程

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

    handleClient函数伪代码:

    重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现),重写Sylar基于协程服务器,服务器,开源,c++,后端,架构,sylar,网络编程

HTTP服务器的实现

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

handleClient函数重写如下:

重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现),重写Sylar基于协程服务器,服务器,开源,c++,后端,架构,sylar,网络编程

感兴趣的同学,可以阅读一下本文实现的源码: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)


本章完结文章来源地址https://www.toymoban.com/news/detail-832980.html

到了这里,关于重写Sylar基于协程的服务器(7、TcpServer & HttpServer的设计与实现)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 重写Nacos服务发现:多个服务器如何跨命名空间,访问公共服务?

    在开发某个公共应用时,笔者发现该公共应用的数据是所有测试环境(假设存在 dev/dev2/dev3)通用的。 这就意味着只需部署一个应用,就能满足所有测试环境的需求;也意味着所有测试环境都需要调用该公共应用,而不同测试环境的应用注册在不同的 Nacos 命名空间。 如果所

    2024年02月05日
    浏览(35)
  • 2310C++协程超传服务器

    原文 告别 异步 回调模型,写代码更简单.同样也是跨平台, 仅头文件 的,包含头文件即可用,来看看它的用法. 提供 getpost 服务 coro_http_server 提供了三个 http 服务,通过 set_http_handler 注册的,注册了两个 http 处理函数:一个是 普通 函数,一个是 协程 函数. 注册为 普通函数 时,会在 i

    2024年02月06日
    浏览(23)
  • 一、重写muduo网络库之服务器编程及测试

    目录 一、基于muduo网络库开发服务器程序的基本步骤 1、组合TcpServer对象 2、创建EventLoop事件循环对象的指针 3、明确TCPServer构造函数需要的参数,输出ChatServer的构造函数 4、在当前服务器类的构造函数当中,注册处理连接的回调函数和处理读写事件的回调函数 5、设置合适的

    2024年02月04日
    浏览(30)
  • 使用Swoole协程实现 WebRTC 信令服务器

    一、 什么是WebRTC WebRTC技术是激烈的开放的Web战争中一大突破-Brendan Eich, inventor of JavaScript。 简单来说,WebRTC 是一个音视频处理+及时通讯的开源库。在实时通信中,音视频的采集和处理是一个很复杂的过程。比如音视频流的编解码、降噪和回声消除等。由Google发起开源,其中

    2024年03月26日
    浏览(38)
  • Go重写Redis中间件 - GO实现TCP服务器

    首先新建一个项目go-redis,将config和lib包放到项目中,config.go用来解析配置,比如端口、功能、DB数;lib包有两个文件夹,分别是logger和sync,其中logger.go是一个日志框架,sync包中的bool.go包装了atomic操作,因为atomic原生没有bool类型,所以将uint32类型改造成bool型的atomic,wait.g

    2024年02月15日
    浏览(60)
  • Unity 的协程的原理

    Unity是一款非常强大的游戏引擎,它支持多种编程语言,其中最常用的语言是C#。在Unity中,协程是一种非常强大的功能,它可以让我们在游戏中实现各种各样的效果。本文将详细介绍Unity协程的原理,并给出示例代码详解。 对啦!这里有个游戏开发交流小组里面聚集了一帮热

    2024年02月02日
    浏览(31)
  • golang 协程的实现原理

    要理解协程的实现, 首先需要了解go中的三个非常重要的概念, 它们分别是 G ,  M 和 P , 没有看过golang源代码的可能会对它们感到陌生, 这三项是协程最主要的组成部分, 它们在golang的源代码中无处不在. G (goroutine) G是goroutine的头文字, goroutine可以解释为受管理的轻量线程, gorout

    2024年02月10日
    浏览(31)
  • 【Kotlin】协程的字节码原理

    前言 协程是Koltin语言最重要的特性之一,也是最难理解的特性。网上关于kotlin协程的描述也是五花八门,有人说它是轻量级线程,有人说它是无阻塞式挂起,有人说它是一个异步框架等等,众说纷芸。甚至还有人出了书籍专门介绍kotlin协程。 笔者刚开始接触这个概念也是一

    2024年01月18日
    浏览(22)
  • [Kotlin Tutorials 21] 协程的取消

    本文讨论协程的取消, 以及实现时可能会碰到的几个问题. 本文属于合辑: https://github.com/mengdd/KotlinTutorials 取消的意义: 避免资源浪费, 以及多余操作带来的问题. 基本特性: cancel scope的时候会cancel其中的所有child coroutines. 一旦取消一个scope, 你将不能再在其中launch新的coroutine. 一

    2024年02月08日
    浏览(32)
  • Kotlin协程的JVM实现源码分析(下)

    协程 根据 是否保存切换 调用栈 ,分为: 有栈协程(stackful coroutine) 无栈协程(stackless coroutine) 在代码上的区别是:是否可在普通函数里调用,并暂停其执行。 Kotlin协程,必须在挂起函数中调用和恢复,属于 无栈协程 。 常见的语言,协程实现: 有栈协程 :Go、Lua 无栈

    2024年01月23日
    浏览(30)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包