找工作小项目:day16-重构核心库、使用智能指针(3)

day16-重构核心库、使用智能指针(3)

最后将使用这个库的方式进行展示。

1、客户端

在while ((o = getopt(argc, argv, optstring)) != -1)所有的操作都是获取参数的操作,threads 、msgs 和wait 分别指线程数、消息长度以及等待时间。
创建一个长度为threads的线程池,绑定任务(这种方式常用于回调函数的绑定,可以将某个函数与特定的参数值绑定,形成一个新的函数对象,方便在后续使用),将任务不断加入线程池中进行处理。

int main(int argc, char *argv[]) {int threads = 100;int msgs = 100;int wait = 0;int o = -1;const char *optstring = "t:m:w:";while ((o = getopt(argc, argv, optstring)) != -1) {switch (o) {case 't':threads = std::stoi(optarg);break;case 'm':msgs = std::stoi(optarg);break;case 'w':wait = std::stoi(optarg);break;case '?':printf("error optopt: %c\n", optopt);printf("error opterr: %d\n", opterr);break;default:break;}}ThreadPool *poll = new ThreadPool(threads);std::function<void()> func = std::bind(OneClient, msgs, wait);for (int i = 0; i < threads; ++i) {poll->Add(func);}delete poll;return 0;
}

OneClient作为任务函数创建了一个socket作为客户端并与服务器进行连接,将连接中的读/写缓存进行初始化并新建连接,开始不断从内核进行写读。

void OneClient(int msgs, int wait) {Socket *sock = new Socket();sock->Create();sock->Connect("127.0.0.1", 1234);Connection *conn = new Connection(sock->fd(), nullptr);sleep(wait);int count = 0;while (count < msgs) {conn->set_send_buf("I'm client!");conn->Write();if (conn->state() == Connection::State::Closed) {conn->Close();break;}conn->Read();std::cout << "msg count " << count++ << ": " << conn->read_buf()->c_str() << std::endl;}delete sock;delete conn;
}

2、服务器

首先创建sever服务器,在这个过程中完成了MainReactor、创建socket、绑定、监听、创建一个线程池并创建多个子 Reactor 等一系列动作。

当程序接收到SIGINT信号时,即用户按下Ctrl+C键时,会执行所注册的信号处理函数。在这个例子中,信号处理函数的作用是释放服务器对象的内存、输出提示信息并正常退出程序。

设置连接发生时的回调函数以及接收数据的回调函数

int main() {TcpServer *server = new TcpServer();Signal::signal(SIGINT, [&] {delete server;std::cout << "\nServer exit!" << std::endl;exit(0);});server->onConnect([](Connection *conn) { std::cout << "New connection fd: " << conn->socket()->fd() << std::endl; });server->onRecv([](Connection *conn) {std::cout << "Message from client " << conn->read_buf()->c_str() << std::endl;conn->Send(conn->read_buf()->c_str());});server->Start();delete server;return 0;
}

主Reactor在主线程中运行,专门负责监听和分发新的连接请求,从而实现了整个服务器的高效事件处理。
当服务器启动时:
1、主Reactor开始监听新的连接请求。
2、每当有新的连接到达时,主Reactor接受连接并将其分配给某个子Reactor。
3、子Reactor在自己的线程中运行,不断地处理与该连接相关的读写事件。
4、由于所有的 Loop 方法都在独立的线程中运行,因此它们可以并发地处理各自的事件,而不会互相阻塞。
子Reactor处理的事件在线程池的线程中,而主Reactor处理的事件在主线程中。各自会被EventLoop不断轮询,直到停止。

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

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

相关文章

【数据结构(邓俊辉)学习笔记】二叉搜索树02——查找、插入和删除

文章目录 1.概述2. 查找2.1 查找&#xff1a;算法2.2 查找&#xff1a;理解2.3 查找&#xff1a;实现2.4 查找&#xff1a;语义 3. 插入3.1 插入&#xff1a;算法3.2 插入&#xff1a;实现 4. 删除4.1 删除&#xff1a;框架4.2 删除&#xff1a;单分支4.3 删除&#xff1a;双分…

Pyqt QCustomPlot 简介、安装与实用代码示例(一)

目录 简介安装实用代码示例带有填充的简单衰减正弦函数及其红色的指数包络线具有数据点的 sinc 函数、相应的误差条和 2--sigma 置信带几种散点样式的演示展示 QCustomPlot 在设计绘图方面的多功能性 结语 所有文章除特别声明外&#xff0c;均采用 CC BY-NC-SA 4.0 许可协议。转…

RERCS系统开发实战案例-Part05 FPM Application的Feeder Class搜索组件的实施

1、通过事务码 SE24对Feeder Class实施 1&#xff09;接口页签的简单说明&#xff1a; ① IF_FPM_GUIBB&#xff1a;通用UI构建块&#xff0c;整个UIBB模块的基础接口&#xff1b; ② IF_FPM_GUIBB_SEARCH&#xff1a;通用搜索UI构建块&#xff0c;搜索组件UIBB的基础接口&…

期末复习GGG-----查找子串

郭的 char *search( char *s, char *t ){int i0;while(s[i]){int j0;if(s[i]t[0]){while(s[ij]t[j]&&t[j]){j;}if(t[j]\0)return si;}i;}return NULL; } AI的 #include <stdio.h> #include <string.h> #define MAXS 30char *search(char *s, char *t);in…

React项目-Cesium地图初始化

一、环境描述 React集成Cesium地图需要注意软件兼容性问题&#xff0c;可以从官网或者百度文章查询React和Cesium地图的版本兼容性&#xff0c; 1、软件版本 &#xff08;1&#xff09;create-react-app创建项目&#xff1b; &#xff08;2&#xff09;React版本&#xff1a;1…

ctfshow web七夕杯

web签到 执行命令没有回显&#xff0c;我们直接写文件就可以了 有字符长度限制 ls />a nl /*>a访问url/api/a下载文件 easy_calc <?phpif(check($code)){eval($result."$code".";");echo($result); }function check(&$code){$num1…

Golang | Leetcode Golang题解之第164题最大间距

题目&#xff1a; 题解&#xff1a; type pair struct{ min, max int }func maximumGap(nums []int) (ans int) {n : len(nums)if n < 2 {return}minVal : min(nums...)maxVal : max(nums...)d : max(1, (maxVal-minVal)/(n-1))bucketSize : (maxVal-minVal)/d 1// 存储 (…

aasist-bladedisc 音频反欺骗算法模型

AASIST 论文 参考ASIST: Audio Anti-Spoofing using Integrated Spectro-Temporal Graph Attention Networks https://arxiv.org/pdf/2110.01200.pdf 模型结构 aasist是一种开源的音频反欺诈的模型&#xff0c;主要的模型结构如下所示&#xff1a; 算法原理 环境配置 Dock…

git配置1-不同的项目使用不同用户名或邮箱

1. 全局用户名和邮箱 1.1. 设置1.2. 存储1.3. 查看 2. 针对指定项目单独设置 2.1. 设置2.2. 存储2.3. 查看 1. 全局用户名和邮箱 1.1. 设置 git config --global user.name 张三 git config --global user.email zhangsanexample.com1.2. 存储 git的全局配置一般会存在hom…

Hi3861 OpenHarmony嵌入式应用入门--总引导连接

这篇没有内容&#xff0c;只是根据内容先后顺序进行连接汇总。 Hi3861 OpenHarmony嵌入式应用入门--鸿蒙开发环境搭建_hi3861开发环境-CSDN博客 Hi3861 OpenHarmony嵌入式应用入门--基于HI-12F开发板烧写程序-CSDN博客 Hi3861 OpenHarmony嵌入式应用入门--启动流程-CSDN博客…

CVE-2023-38836(文件上传+命令执行)

简介 BoidCMS v.2.0.0 存在文件上传漏洞&#xff0c;远程攻击者可通过添加 GIF 头部绕过 MIME 类型检查&#xff0c;执行任意代码。 过程 打开靶场 对网站进行目录扫描 发现后台&#xff0c;登录弱口令账号密码 admin/password 发现文件上传位置 根据简介提示&#xff0c;…

CentOS 7.9检测硬盘坏区、实物定位(三)

系列文章目录 CentOS 7.9上创建JBOD&#xff08;一&#xff09; CentOS 7.9上创建的JBOD阵列恢复&#xff08;二&#xff09; 文章目录 系列文章目录前言一、在系统中找到硬盘对应的盘符二、使用命令定位实物1.badblocks检测坏块2.对2T以上的硬盘检测&#xff08;对本篇非必要…

我用chatgpt写了一款程序

众所周知&#xff0c;Chatgpt能够帮助人们写代码&#xff0c;前几天苏音试着完全用Chatgpt写一款Python程序 有一句话我很赞同&#xff0c;未来能代替人的不是AI&#xff0c;是会使用AI的人。 最终&#xff0c;写下来效果还不错&#xff0c;完全提升了我的办公效率。 开发前…

Linux Centos7.5 开放指定端口

在Linux中开放特定端口通常涉及配置防火墙规则或网络访问控制。以下是基本步骤&#xff1a; 使用firewalld开放端口 如果你的系统使用firewalld作为防火墙管理工具&#xff0c;可以按照以下步骤操作&#xff1a; 检查当前firewalld状态&#xff1a; sudo firewall-cmd --stat…

PCI 电源管理和设备驱动程序方案

方案 1&#xff1a;关闭设备 1.设备驱动程序&#xff1a;保存专有设备状态。 2.PCI 驱动程序&#xff1a;保存即插即用配置&#xff0c;禁用设备 (中断和 BAR) &#xff0c;并使用 PCI-PM 寄存器将设备置于 D3 中。 3.ACPI 驱动程序&#xff1a;运行 ASL 代码 (_PS3 和 _OFF&a…

0X0-基于Sklearn的机器学习入门:聚类(上)

本节及后续章节将介绍深度学习中的几种聚类算法&#xff0c;所选方法都在Sklearn库中聚类模块有具体实现。本节为上篇&#xff0c;将介绍几种相对基础的聚类算法&#xff0c;包括K-均值算法和均值漂移算法。 目录 X.1 聚类概述 X.1.1 聚类的种类 X.1.2 Sklearn聚类子模块 …

设计模式1

1、面向对象三大特性&#xff1a;封装、继承、多态 2、什么是接口&#xff1f; 3、面向对象的SOLID五大原则 4、简单工厂模式 5、工厂方法模式

网络安全:数据库安全性

文章目录 网络安全&#xff1a;数据库安全性引言数据库安全性的重要性常见的数据库安全威胁数据库安全性的最佳实践数据加密访问控制审计和监控 结语 网络安全&#xff1a;数据库安全性 引言 在前两篇文章中&#xff0c;我们讨论了SQL注入的概念和防范措施。本篇文章将聚焦于…

Python数据分析与建模库-03数据分析处理库Pandas-1.数据读取

该视频主要讲述了pandas库在数据处理中的重要性。 首先介绍了pandas库是基于numpy库封装了一些操作&#xff0c;简化了数据处理过程。然后通过读取CSV文件的例子&#xff0c;演示了如何使用pandas的read_csv函数将数据读入&#xff0c;并展示了数据类型和数据格式。 接着介绍…

HTML中的<iframe>标签及其属性

<iframe>标签在HTML中用于嵌入另一个HTML页面。它提供了一种在当前页面内展示外部内容的方式&#xff0c;而无需离开当前页面。以下是<iframe>的一些常用属性&#xff1a; src&#xff1a;指定要嵌入的页面的URL。width 和 height&#xff1a;设置iframe的尺寸。n…