005 仿muduo实现高性能服务器组件_通信连接管理

​🌈个人主页:Fan_558
🔥 系列专栏:仿muduo
📒代码仓库: 项目代码
🌹关注我💪🏻带你学更多知识

文章目录

  • 前言
  • Channel模块
    • 设计原因
    • 整体设计
    • 代码如下
  • Connection模块
    • 设计原因
    • 整体设计
    • 代码如下
  • 小结

前言

本文的核心模块是Connection模块,该模块实现了对一个通信套接字的整体管理,未来获取到新连接,每一个新连接都会设置一个connection进行管理,connection模块中包含了我们对连接的操作,以及对可读可写错误任意事件的设置

Channel模块

设计原因

当一个描述符已经监控了可写事件,如果我们又要去写入数据到发送缓冲区,没有必要再去监控一次可写事件,已经设置了就不需要重复设置,否则系统也会有消耗的,为了减少该消耗,所以我们就需要对描述符监控的事件进行管理,只需要判断是否已经监控了某个事件,没有就去监控一下,已经监控了就不需要再次监控了 并且在该模块当中设置触发对应事件的回调函数

整体设计

在这里插入图片描述
Channel模块的主要作用:一是对监控事件的管理(可以判断是否可读可写,也可以对一个事件解除、添加可读/可写监控),二是在此模块设置许多对应事件的回调机制(具体的业务函数由用户传入)
函数接口:
在这里插入图片描述

代码如下

在这里插入图片描述

Connection模块

设计原因

设计原因:再一次进行封装,使操作更加简便
Connection模块是对Buffer模块,Socket模块,Channel模块的⼀个整体封装,实现了对⼀个通信套接字的整体的管理,每⼀个进⾏数据通信的套接字(也就是accept获取到的新连接)都会使⽤Connection进⾏管理。
一个连接有任何的事件该怎么处理都是由这个模块来进行处理的,因为组件的设计者也不知道使用者要如何处理事件,因此只是提供一些事件回调函数,再由使用者设置具体的业务处理

怎么理解connection模块也是对Buffer模块,Socket模块,Channel模块的⼀个整体封装?

我们需要对触发了什么事件设置相应的回调,像HandleRead读事件回调需要涉及将socket中的数据放入到接收缓冲区,如果读取数据出错了就需要涉及到连接的操作,比如关闭连接
读入到缓冲区后我们就需要对缓冲区的数据进行处理—调用_message_cb_usr处理数据
因此事件的回调函数我们需要用到多个模块结合,恰恰connection模块也是对Buffer模块,Socket模块,Channel模块的⼀个整体封装

整体设计

在这里插入图片描述

事件回调函数的设置:
这里的函数是设置回给Channel模块可读可写关闭错误事件的

HandleRead、HandleWrite、HandleClose、HandleError

设置对于连接操作的各种回调:
这些对连接操作的各种回调(建立连接、数据处理、关闭连接、任意事件、移除服务器内部管理的连接信息)
都是由服务端进行设置的,比如一个游戏服务端,当你上线了,可能会跳出一大堆签到的东西,当你关闭游戏
的时候,可能会出现让你确定是否关闭的消息,因此对连接的操作的回调还是得由具体的用户设置

EstablishedCallBack _established_cb_usr;
MessageCallBack _message_cb_usr;
ClosedCallBack _closed_cb_usr;
AnyEventCallBack _anyevent_cb_usr;
ClosedCallBack _close_cb_svr;

对连接的管理操作:
这里要设置为私有的(private),因为这些函数是对连接的操作存在线程安全问题
EstablishedPriv、ReleasePriv、ShutdownPriv、CloseInactiveReleasePriv、StartInacyiveReleasePriv
因此这里也会给一系列公有接口Shutdown、CloseInactiveRelease…
这些公有接口的设计就需要把对连接的操作(比如EstablishedPriv,ReleasePriv)压入任务队列里(由EventLoop模块提供压入任务队列的接口)

代码如下

在这里插入图片描述

小结

本文就到这里结束了,如果本文存在疏漏或错误的地方,还请您能够指出,另外地,欢迎在评论区中交流

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/49531.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Florence2:Advancing a unified representation for a variety of vision tasks

Florence-2模型:开启统一视觉基础模型的新篇章_florence -2-CSDN博客文章浏览阅读1.1k次,点赞108次,收藏109次。Florence-2是由微软Azure AI团队开发的一款多功能、统一的视觉模型。它通过统一的提示处理不同的视觉任务,表现出色且优于许多大型模型。Florence-2的设计理念是…

用Postman Flows打造你的专属API:外部公开,轻松上手!

引言 Postman Flows 是一个使用 GUI 进行无代码 API 调用流程创建的服务。这篇文章我尝试使用 Flows 来构建将 Momento Topic 中的数据保存到 TiDB 的保存 API,因此想分享一些使用过程中的技巧等。 实现内容 将从 Momento Topics 配发的 JSON 数据保存到 TiDB 中。…

C++ 栈( stack )学习

目录 1.栈 2.模拟栈 1.1.入栈( push ) 1.2.出栈( pop ) 1.3.获取栈顶元素( top ) 3.直接使用栈( stack ) 3.1.导入头文件并创建栈 3.2.栈的操作 3.2.1.入栈( push ) 3.2.2.出栈( pop ) 3.2.3.获取栈顶元素( top ) 3.2.4.获取栈中元素个数( size ) 3.2.5.判断栈是否…

代码随想录算法训练营day8 | 344.反转字符串、541.反转字符串 II、卡码网:54.替换数字

文章目录 344.反转字符串思路 541.反转字符串 II思路 卡码网:54.替换数字思路复习:字符串 vs 数组 总结 今天是字符串专题的第一天,主要是一些基础的题目 344.反转字符串 建议: 本题是字符串基础题目,就是考察 revers…

docker挂载部署reids6.2.1

1.拉取镜像 docker pull redis:6.2.12.创建挂在目录(根据自己要求修改具体目录) mkdir -p /home/admin/redis/{data,conf}3.在/home/admin/redis/conf目录下创建redis.conf文件 cd /home/admin/redis/conf touch redis.conf4.复制下面文本到redis.conf…

浅析JWT原理及牛客出现过的相关面试题

原文链接:https://kixuan.github.io/posts/f568/ 对jwt总是一知半解,而且项目打算写个关于JWT登录的点,所以总结关于JWT的知识及网上面试考察过的点 参考资料: Cookie、Session、Token、JWT_通俗地讲就是验证当前用户的身份,证明-…

不断把别人“装”进我们的灵魂口袋

嘿,朋友们!今天我们来聊聊一种超酷的能量——本色示人。这不是什么秘密武器,但它比任何超能力都来得实在。 第一部分:本色示人,能量界的“超级赛亚人” 1.1 坦诚的超能力 想象一下,如果你的内心强大到可以…

Window部署Ollama+Qwen2.0+Open-WebUI

文章目录 Windows下安装Docker安装Docker检查是否安装成功, 出现版本即为安装成功安装Ollama启动 Ollama 并拉取模型(选做) 修改默认地址和端口(选做) Ollama 进行跨域配置安装open-webui Windows下安装Docker 准备条件 开启Hyper-V,在“启用或关闭Windows功能”里…

C语言 #指针数组 #数组指针 #数组参数、指针参数

文章目录 前言 一、指针数组 1、概念: 2、指针数组有什么用呢? 二、数组指针 1、数组指针的定义 2、数组名与 &数组名 的区别 3、数组指针如何初始化? 4、数组指针的用法 三、根据代码区分 指针数组 和 数组指针 四、数组参数、指针参数 …

Shell编程之正则表达式与文本三剑客

目录 一、正则表达式 1.引言--什么是正则表达式 1.1正则表达式的功能 2.基础正则表达式(BRE) 2.1特殊字符 2.2定位符 2.3非打印字符 3.扩展正则表达式(ERE) 4.元字符操作的案列 二、命令小工具 1.cut:列截取工具 2.sort排序 …

【Android】使用ViewPager2与TabLayout实现顶部导航栏+页面切换

【Android】使用ViewPager2与TabLayout实现顶部导航栏+页面切换 TabLayout与ViewPager2概述 TabLayout TabLayout 是 Android 支持库中的一个组件,它是 Design 支持库的一部分。TabLayout 提供了一个水平的标签页界面,允许用户在不同的视图…

CogVideo 实测,智谱「清影」AI视频生成,全民免费,连 API 都开放了!

不得不说,AI 视频生成界最近非常火热~ 前有快手「可灵」开放内测,一下子带火了老照片修复,全网刷屏: 怕是你还没拿到内测资格,被称为 “国货之光” 的「可灵」就结束了免费无限量模式。每天只有66点的免费额度&#x…

鸿蒙(API 12 Beta2版)【创建NDK工程】

创建NDK工程 下面通过DevEco Studio的NDK工程模板,来演示如何创建一个NDK工程。 说明 不同DevEco Studio版本的向导界面、模板默认参数等会有所不同,请根据实际工程需要,创建工程或修改工程参数。 通过如下两种方式,打开工程创…

2024-07-27 Unity Excel —— 使用 EPPlus 插件读取 Excel 文件

文章目录 1 前言2 项目地址3 使用方法3.1 写入 Excel3.2 读取 Excel3.3 读写 csv 文件 4 ExcelSheet 代码 1 前言 ​ 前几日,一直被如何在 Unity 中读取 Excel 的问题给困扰,网上搜索相关教程相对古老(4、5 年以前了)。之前想用 …

【openavis】明厨亮灶算法仓

明厨亮灶算法仓主要用于学校食堂,餐厅等饮食卫生安全监管场景,目前包含的算法如下: 算法类型 算法卡片 明厨亮灶算法仓 老鼠检测 垃圾桶未盖 厨师服检测 厨师帽检测 口罩检测 手套检测 动火离人 1. 算法规格介绍: 算…

基于STM32瑞士军刀--【FreeRTOS开发】学习笔记(一)|| RISC / 底层代码执行步骤 / 汇编指令

本篇文章基于韦东山老师讲课笔记和自己理解编写。 RISC ARM芯片属于精简指令集计算机(RISC:Reduced Instruction Set Computing),它所用的指令比较简单,有如下特点: ① 对内存只有读、写指令 ② 对于数据的运算是在CPU内部实现 …

你在找提升效率的解决方案还是追求效果的解决方案

企业在寻求“解决方案”时,最好先想清楚,你是想提升某项工作的效率,还是要改善某项工作的效果? 提升效率的解决方案主要是为了在保证质量的前提下提升某项确定工作的完成速度。以政务解决方案为例:当任何人都能通过移…

HAL STM32 SPI/ABZ/PWM方式读取MT6816磁编码器数据

HAL STM32 SPI/ABZ/PWM方式读取MT6816磁编码器数据 📚MT6816相关资料(来自商家的相关资料): 资料:https://pan.baidu.com/s/1CAbdLBRi2dmL4D7cFve1XA?pwd8888 提取码:8888📍驱动代码编写&…

某量JS逆向

https://chat.sensetime.com/wb/chat 目录 一、发起请求 二、观察发现只有入参 __data__ 进行了加密,返回是明文 三、 观察JS调用栈 四、从JS中搜索 __data__ 五、使用XHR对Ajax请求进行断点 六、再次发起请求就会断点拦住请求 七、对XHR入口分析 八、逐个…

【C++】选择结构- 嵌套if语句

嵌套if语句的语法格式&#xff1a; if(条件1) { if(条件1满足后判断是否满足此条件) {条件2满足后执行的操作} else {条件2不满足执行的操作} } 下面是一个实例 #include<iostream> using namespace std;int main4() {/*提示用户输入一个高考分数&#xff0c;根据分…