C++实现进程端口网络数据接收系统设计示例程序

一、问题描述

最近做了一道简单的系统设计题，大概描述如下：
1.一个进程可以绑定多个端口，用于监听接收网络中的数据，但是一个端口只能被一个进程占用
2.1 <= pid <= 65535, 1 <= port <= 100000, 1 <= topNum <= 5, 0 <= packetLen < 1000
类接口函数声明如下，要求实现其中每个函数，满足程序要求。

class NetWorkRecvSystem
{
public:NetWorkRecvSystem();// 将某个端口和进程绑定bool BindPort(int pid, int port);// 解除端口port的绑定，如果port未被当前系统中的进程占用，则返回falsebool UnBindPort(int port);// 在端口port上接收到字节数为packetLen长度的网络数据// 如果当前端口已被解绑或未被进程占用，则直接返回0// 否则该端口对应的进程的接收数据总长度累加上当前的dataLen，返回最后的总长度int RecvNetData(int port, int dataLen);// 统计总接收数据长度排名前topNum的进程列表// 按照如下规则进行排序输出：// 1.先按照进程的总数据接收长度从大到小降序排序// 2.如果两个进程的数据接收总长度相等，则按照进程pid从小到大升序// 最后返回前topNum个进程的列表// 注意：数据长度为0的进程不输出，如果所有进程都没有接收到数据，则返回空列表{}std::vector<int> statTopNum(int topNum);
};

举例1：
输入：
NetWorkRecvSystem sys; // 创建一个系统变量
sys.BindPort(12345, 80);
sys.BindPort(67890, 3306);
sys.BindPort(12345, 8080);
sys.statTopNum(2); // 由于当前进程只做端口绑定，还未接收到数据，所以返回空列表 []
sys.RecvNetData(80, 100); // 端口80上接收到100字节的网络数据，此时进程12345的总数据接收长度为100
sys.RecvNetData(3306, 300); // 端口3306上接收到300字节的网络数据，此时进程67890的总数据接收长度为300
sys.statTopNum(1); // 由于此时进程67890的总长度为300，大于进程12345的总数据接收长度100，所以返回[67890]
sys.RecvNetData(80,200); // 123456 -> 300, 67890 -> 300
sys.BindPort(34567, 3306); // false
sys.BindPort(34567, 21);
sys.RecvNetData(21,400); // 34567 -> 400，此时123456 -> 300, 67890 -> 300
sys.statTopNum(5); // [34567, 123456, 67890]
sys.UnBindPort(21);
sys.statTopNum(1); // [34567]

系统设计

做系统设计这类题目，首选要读懂题意，其次再选择合适的数据结构用于保存数据，我首先想到用一个std::map<int, ProcessItem>的接口来保存每个进程的网络端口和数据包接收信息，其中ProcessItem结构如下：

struct ProcessItem
{int processId = -1;		// 进程的pid，唯一标识std::set<int> ports;	// 进程所占用的端口集合，一个进程可占用多个不同的端口int packetLen = 0;		// 进程所有端口接收到的总报文字节数
};

后面实际写代码过层中发现std::map是个红黑树结构，不太好排序，而且会有些数据冗余；只用std::vector<ProcessItem> procItemVec;数组就能满足要求，而且结合C++ STL algorithm对std::vector排序很方便。

还有一个要注意的点，对std::vector循环遍历时，如果要erase删除某个元素，要注意迭代器失效的问题，这个可以参考我之前的一篇博客：C++ vector迭代器失效

C++代码实现：

NetWorkSystem.h头文件

#include <vector>
#include <set>using std::vector;
using std::set;struct ProcessItem
{int processId = -1;		// 进程的pid，唯一标识std::set<int> ports;	// 进程所占用的端口集合，一个进程可占用多个不同的端口int packetLen = 0;		// 进程所有端口接收到的总报文字节数
};class NetWorkSystem
{
public:NetWorkSystem();~NetWorkSystem();// 将某个端口和进程绑定bool BindPort(int pid, int port);// 解除端口port的绑定，如果port未被当前系统中的进程占用，则返回falsebool UnBindPort(int port);// 在端口port上接收到字节数为packetLen长度的网络数据// 如果当前端口已被解绑或未被进程占用，则直接返回0// 否则该端口对应的进程的接收数据总长度累加上当前的dataLen，返回最后的总长度int RecvNetPacketData(int port, int packetLen);// 统计总接收数据长度排名前topNum的进程列表// 按照如下规则进行排序输出：// 1.先按照进程的总数据接收长度从大到小降序排序// 2.如果两个进程的数据接收总长度相等，则按照进程pid从小到大升序// 最后返回前topNum个进程的列表// 注意：数据长度为0的进程不输出，如果所有进程都没有接收到数据，则返回空列表{}std::vector<int> statTopNum(int topNum);private:std::vector<ProcessItem> procItemVec;	// 数据，用来保存进程和端口映射的数组
};

NetWorkSystem.cpp实现文件：

#include "NetWorkSystem.h"
#include <algorithm>NetWorkSystem::NetWorkSystem()
{
}NetWorkSystem::~NetWorkSystem()
{
}bool NetWorkSystem::BindPort(int pid, int port)
{if (pid <= 0 || port <= 0) {return false;}// 如果端口port已被其他进程占用，则不处理，直接返回falsefor (auto procIter : procItemVec) {if (procIter.ports.count(port) != 0) {return false;}}auto iter = std::find_if(procItemVec.begin(), procItemVec.end(), [pid](const ProcessItem item) {return pid == item.processId;});// 如果之前有进程，则将其插入到对应进程的ports集合中（集合可以去重）if (iter != procItemVec.end()) {iter->ports.insert(port);} else {// 之前没有该进程，则新建一项，初始化进程信息，并放入到数组中ProcessItem procItem;procItem.processId = pid;std::set<int> portSet = { port };procItem.ports = portSet;procItem.packetLen = 0;procItemVec.push_back(procItem);}return true;
}bool NetWorkSystem::UnBindPort(int port)
{if (port <= 0) {return false;}// 如果端口port被其他进程占用，则从对应进程的端口集合中解绑，直接返回truefor (auto procIter : procItemVec) {auto portIter = procIter.ports.find(port);// 找到对应的端口portif (portIter != procIter.ports.end()) {// 将该端口中对应进程的端口集合中移除procIter.ports.erase(port);return true;}}// 如果没找到该端口，则返回falsereturn false;
}int NetWorkSystem::RecvNetPacketData(int port, int packetLen)
{if (port <= 0 || packetLen <= 0) {return 0;}for (auto procIter = procItemVec.begin(); procIter != procItemVec.end(); procIter++) {// 找到对应的端口if (procIter->ports.count(port) != 0) {procIter->packetLen += packetLen;return procIter->packetLen;}}return 0;
}// 统计接收网络数据包总长度前topNum的进程列表
std::vector<int> NetWorkSystem::statTopNum(int topNum)
{std::vector<int> pidList;// 1. 先缓存进程信息列表（对缓存数据进行处理，防止原始数据procItemVec被弄脏）auto procItemVecTemp = procItemVec;// 2. 移除那些网络数据包为0的进程项for (auto iter = procItemVecTemp.begin(); iter != procItemVecTemp.end();) {if (iter->packetLen == 0) {iter = procItemVecTemp.erase(iter);	// 注意：vector在循环时做erase操作很容易导致迭代器失效问题} else {iter++;}}// 3. 如果procItemVecTemp长度为0，即所有进程都没有接收到数据包，则返回空列表if (procItemVecTemp.size() == 0) {return std::vector<int>();}// 4. 对第3步处理后的进程信息数据按照规则进行排序// 规则1： 先根据进程的packetLen长度从大到小降序// 规则2: 如果两个进程项的packetLen相等，则按照进程processId从小到大升序std::sort(procItemVecTemp.begin(), procItemVecTemp.end(), [](const ProcessItem item1, const ProcessItem item2) {if (item1.packetLen == item2.packetLen) {return item1.processId < item2.processId;}return item1.packetLen > item2.packetLen;});// 5. 只输出procItemVecTemp中排名topNum的进程pid列表int processCnt = topNum;for (auto procIter = procItemVecTemp.begin(); procIter != procItemVecTemp.end() && processCnt > 0; procIter++) {pidList.push_back(procIter->processId);if (processCnt-- <= 0) {break;}}return pidList;
}

main.cpp

#include <iostream>
#include "NetWorkSystem.h"void PrintVector(std::vector<int> nums)
{std::cout << "[";for (auto iter = nums.begin(); iter != nums.end(); iter++) {if (iter != nums.end() - 1) {std::cout << *iter << ","} else {std::cout << *iter;}}std::cout << "]" << std::endl;
}void NetWorkSystem_test_001()
{std::vector<int> pidListResult = {};NetWorkSystem sys;	// 创建一个系统变量sys.BindPort(12345, 80);sys.BindPort(67890, 3306);sys.BindPort(12345, 8080);std::cout << "--------------- 111 start ----------------------------" << std::endl;pidListResult = sys.statTopNum(2);		// 由于当前进程只做端口绑定，还未接收到数据，所以返回空列表 []PrintVector(pidListResult);std::cout << "--------------- 111 end ----------------------------" << std::endl;sys.RecvNetPacketData(80, 100);	// 端口80上接收到100字节的网络数据，此时进程12345的总数据接收长度为100sys.RecvNetPacketData(3306, 300); // 端口3306上接收到300字节的网络数据，此时进程67890的总数据接收长度为300std::cout << "--------------- 222 start ----------------------------" << std::endl;pidListResult = sys.statTopNum(1);	// 由于此时进程67890的总长度为300，大于进程12345的总数据接收长度100，所以返回[67890]PrintVector(pidListResult);std::cout << "--------------- 222 end ----------------------------" << std::endl;sys.RecvNetPacketData(80, 200); // 123456 -> 300, 67890 -> 300sys.BindPort(34567, 3306); // falsesys.BindPort(34567, 21);sys.RecvNetPacketData(21, 400); // 34567 -> 400，此时123456 -> 300, 67890 -> 300std::cout << "--------------- 333 start ----------------------------" << std::endl;pidListResult = sys.statTopNum(5);  // [34567, 123456, 67890]PrintVector(pidListResult);std::cout << "--------------- 333 end ----------------------------" << std::endl;sys.UnBindPort(21);std::cout << "--------------- 444 start ----------------------------" << std::endl;pidListResult = sys.statTopNum(1); // [34567]PrintVector(pidListResult);std::cout << "--------------- 444 end ----------------------------" << std::endl;
}int main(int argc, char* argv[])
{NetWorkSystem_test_001();
}

代码运行结果如下图所示：
代码运行结果

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

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

相关文章

C++:vector增删查改模拟实现

C++:vector增删查改模拟实现

C:vector增删查改模拟实现 前言一、迭代器1.1 非const迭代器&#xff1a;begin()、end()1.2 const迭代器&#xff1a;begin()、end() 二、构造函数、拷贝构造函数、赋值重载、析构函数模拟实现2.1 构造函数2.1.1 无参构造2.1.2 迭代器区间构造2.1.3 n个值构造 2.2 拷贝构造2.3 …
阅读更多...
vue路由导航守卫（全局守卫、路由独享守卫、组件内守卫）

vue路由导航守卫（全局守卫、路由独享守卫、组件内守卫）

目录 一、什么是Vue路由导航守卫&#xff1f; 二、全局守卫 1、beforeEach 下面是一个beforeEach的示例代码&#xff1a; 2、beforeResolve 下面是一个beforeResolve的示例代码&#xff1a; 3、afterEach 下面是一个afterEach的示例代码&#xff1a; 三、路由独享守卫…
阅读更多...
044：vue中引用json数据的方法

044：vue中引用json数据的方法

第044个 查看专栏目录: VUE ------ element UI 专栏目标 在vue和element UI联合技术栈的操控下&#xff0c;本专栏提供行之有效的源代码示例和信息点介绍&#xff0c;做到灵活运用。 &#xff08;1&#xff09;提供vue2的一些基本操作&#xff1a;安装、引用&#xff0c;模板使…
阅读更多...
多相Buck的工作原理

多相Buck的工作原理

什么是多相Buck电源&#xff1f; 多相电源控制器是一种通过同时控制多个电源相位的设备&#xff0c;以提供稳定的电力供应。相位是指电源中的电流和电压波形。多相控制器的设计旨在最大程度地减小电力转换系统的纹波&#xff0c;并提高整体能效。它通常包含一系列的功率级联&a…
阅读更多...
结构化布线系统

结构化布线系统

满足下列需求&#xff1a; 1.标准化&#xff1a;国际、国家标准。 2.实用性&#xff1a;针对实际应用的需要和特点来建设系统。 3.先进性&#xff1a;采用国际最新技术。5-10年内技术不落后。 4.开放性&#xff1a;整个系统的开放性。 5.结构化、层次化&#xff1a;易于管理和维…
阅读更多...
Matplotlib数据可视化

Matplotlib数据可视化

绘图基础语法 &#xff11;　创建画布并且创建子图 首先创建一个空白的画布&#xff0c;并且可以将画布分为几个部分&#xff0c;这样就可以在同一附图上绘制多个图像。 plt.figure 创建一个空白画布&#xff0c;可以指定画布大小、像素 figure.add_subplot 创建并且选中子…
阅读更多...
【web安全】文件读取与下载漏洞

【web安全】文件读取与下载漏洞

前言 菜某整理仅供学习&#xff0c;有误请赐教。 概念 个人理解&#xff1a;就是我们下载一个文件会传入一个参数&#xff0c;但是我们可以修改参数&#xff0c;让他下载其他的文件。因为是下载文件&#xff0c;所以我们可以看到文件里面的源码&#xff0c;内容。 文件读取…
阅读更多...
swiftUi——颜色

swiftUi——颜色

在SwiftUI中&#xff0c;您可以使用Color结构来表示颜色。Color可以直接使用预定义的颜色&#xff0c;例如.red、.blue、.green等&#xff0c;也可以使用自定义的RGB值、十六进制颜色代码或者系统提供的颜色。 1. 预定义颜色 Text("预定义颜色").foregroundColor(.…
阅读更多...
Swing程序设计（9）复选框，下拉框

Swing程序设计（9）复选框，下拉框

文章目录 前言一、复选框二、下拉框总结 前言 该篇文章简单介绍了Java中Swing组件里的复选框组件、列表框组件、下拉框组件&#xff0c;这些在系统中都是常用的组件。 一、复选框 复选框&#xff08;JCheckBox&#xff09;在Swing组件中的使用也非常广泛&#xff0c;一个方形方…
阅读更多...
hadoop安装与配置-shell脚本一键安装配置（集群版）

hadoop安装与配置-shell脚本一键安装配置（集群版）

文章目录 前言一、安装准备1. 搭建集群 二、使用shell脚本一键安装1. 复制脚本2. 增加执行权限3. 分发脚本4. 执行脚本5. 加载用户环境变量 三、启动与停止1. 启动/停止hadoop集群(1) 复制hadoop集群启动脚本(2) 增加执行权限(3) 启动hadoop集群(4) 停止hadoop集群(5) 重启hado…
阅读更多...
智慧社区前景无限，科技引领未来发展

智慧社区前景无限，科技引领未来发展

社区是城镇化发展的标志&#xff0c;作为人类现代社会的生活的基本圈子&#xff0c;是人类生活离不开的地方&#xff0c;社区人口密度大、车辆多&#xff0c;管理无序&#xff0c;社区的膨胀式发展多多少少带来一定的管理上的缺失。社区作为智慧城市建设的重要一环&#xff0c;…
阅读更多...
编译基于LIO-SAM的liorf“Large velocity, reset IMU-preintegration!“

编译基于LIO-SAM的liorf“Large velocity, reset IMU-preintegration!“

使用LIO-SAM修改的代码liorf&#xff08;因自己使用的IMU传感器是 6-axis ouster&#xff09;&#xff1a; LIO-SAM代码连接&#xff1a; https://github.com/TixiaoShan/LIO-SAM liorf代码连接&#xff1a; https://github.com/YJZLuckyBoy/liorf 编译运行出现错误&#…
阅读更多...
eve-ng山石网科HillStone镜像部署

eve-ng山石网科HillStone镜像部署

HillStone 部署 author&#xff1a;leadlife data&#xff1a;2023/12/4 mains&#xff1a;EVE-ng HillStone 镜像部署 - use hillstone-sg6000 default&#xff1a;hillstone/hillstone 传输 scp hillstone-sg6000.zip root192.168.3.130:/opt/unetlab/addons/qemu/部署 cd …
阅读更多...
echarts绘制一个环形图

echarts绘制一个环形图

其他echarts&#xff1a; echarts绘制一个柱状图&#xff0c;柱状折线图 echarts绘制一个饼图 echarts绘制一个环形图2 效果图&#xff1a; 代码&#xff1a; <template><div class"wrapper"><!-- 环形图 --><div ref"doughnutChart…
阅读更多...
C++STL的string(超详解)

C++STL的string(超详解)

文章目录 前言C语言的字符串 stringstring类的常用接口string类的常见构造string (const string& str);string (const string& str, size_t pos, size_t len npos); capacitysize和lengthreserveresizeresize可以删除数据 modify尾插插入字符插入字符串 inserterasere…
阅读更多...
如何将腾讯混元大模型AI接入自己的项目里(中国版本ChatGPT)

如何将腾讯混元大模型AI接入自己的项目里(中国版本ChatGPT)

如何将腾讯混元大模型AI接入自己的项目里 一、腾讯混元大模型API二、使用步骤1、接口2、请求参数3、请求参数示例4、接口 返回示例 三、 如何获取appKey和uid1、申请appKey:2、获取appKey和uid 四、重要说明 一、腾讯混元大模型API 基于腾讯混元大模型AI的智能文本对话AI机器人…
阅读更多...
TypeScript 的修饰符（modifier）和装饰器（decorator）

TypeScript 的修饰符（modifier）和装饰器（decorator）

装饰器是一种特殊类型的声明&#xff0c;它能够被附加到类声明....上。 装饰器使用 expression这种形式
阅读更多...
使用消息队列遇到的问题—kafka

使用消息队列遇到的问题—kafka

目录 1 分区2 消费者3 Kafka 如何保证消息的消费顺序&#xff1f;3.1 方案一3.2 方案二 4 消息积压 在项目中使用kafka作为消息队列&#xff0c;核心工作是创建生产者—包装数据&#xff1b;创建消费者----包装数据。 欠缺一些思考&#xff0c;特此梳理项目中使用kafka遇到的一…
阅读更多...
浅析以太网接口及串口转以太网技术

浅析以太网接口及串口转以太网技术

浅析以太网接口 以太网相关接口主要包括&#xff1a;MII/RMII/SMII以及GMII/RGMII/SGMII接口。 一、MII接口 MII&#xff08;Media Independent Interface&#xff09;介质无关接口或称为媒体独立接口&#xff0c;它是IEEE-802.3定义的以太网行业标准。它包括一个数据接口和…
阅读更多...
Python 小红书评论区采集 小红薯xhs精准用户获客

Python 小红书评论区采集 小红薯xhs精准用户获客

成品图 评论接口https://edith.xiaohongshu.com/api/sns/web/v2/comment/page?note_id笔记id&cursor光标 初次使用cursor为空,该接口为GET&#xff0c;需要x-s,x-t签名验证 子评论接口https://edith.xiaohongshu.com/api/sns/web/v2/comment/sub/page?note_id%s&r…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023