wordpress插件无法安装插件/莆田网站建设优化
Linux环境中实现并发TCP/IP服务器。多线程在解决方案中提供了并发性。由于并发性,它允许多个客户端同时连接到服务器并与服务器交互。
Linux多线程编程概述
许多应用程序同时处理多项杂务。服务器应用程序处理并发客户端;交互式应用程序通常在处理后台计算时处理用户输入;计算密集型应用程序利用多个处理器的功能。共同的主题是使用多个控制线程来提供处理并发活动的上下文,无论是在一个处理器上多路复用、在多个处理器上并行执行,还是利用具有“超线程技术”的处理器以及AMD和Intel的新双核处理器的设施。
协调这些线程的执行涉及同步对共享数据结构的访问,确保程序行为良好且具有确定性,而不管其组件线程的相对执行速度如何。多线程程序和单线程程序一样,必须处理异常和与外界的交互。尽管在这样的程序中可能有许多并发活动,但程序作为一个整体应该对这样的外部输入做出清晰的响应。
线程的实现方式有很多种,包括用户级库、内核和各种组合。大多数Linux实现目前将每个线程视为使用克隆系统调用创建的单独进程(尽管每个线程都与其队列共享其地址空间)。
C/C++ 多线程并发服务器知识点
- 多线程并发服务器思路
1. socket(),创建监听套接字
2. bind(),绑定监听套接字
3. setsockopt(),设置端口复用
4. listen(),监听状态,用来被动接受来自其他主动套接字的连接请求,并设置监听上限
5. pthread_attr_init()、pthread_attr_setdetachstate()、pthread_create(),在创建时指定属性
6. pthread_rwlock_wrlock()、pthread_rwlock_unlock(),并发程序引起的共享内存问题
...
Linux C/C++ 多线程TCP/UDP服务器 (监控系统状态)
目的:使用TCP/IP实现多线程客户端服务器。它允许多个客户端同时连接到服务器并与服务器交互。处理多线程TCP/UDP服务器监控系统状态:监控CPU负载、RAM使用情况、磁盘空间使用情况和可用网络接口。
服务器:
启动服务器并接受来自客户端的连接。在接受客户机连接后,它分派一个线程与客户机交互。
...
int main(int argc, char *argv[])
{if (argc != 4){printf ("Usage: %s <TCP/UDP> <port> <max_connections>\n", argv[0]);return 0;}if (strncmp ("TCP", argv[1], 3) == 0){printf ("Using TCP");protocol = TCP;}else if (strncmp ("UDP", argv[1], 3) == 0){printf ("Using UDP");protocol = UDP;}else{printf ("Unknown protocol: %s\n", argv[1]);printf ("Usage: %s <TCP/UDP> <port> <max_connections>\n", argv[0]);return 0;}const int port = atoi (argv[2]);if (!port){printf ("Wrong port number: %s\n", argv[2]);printf ("Usage: %s <TCP/UDP> <port> <max_connections>\n", argv[0]);return 0;}const int max_connections = atoi (argv[3]);if (!max_connections){printf ("Wrong max_connections number: %s\n", argv[3]);printf ("Usage: %s <TCP/UDP> <port> <max_connections>\n", argv[0]);return 0;}printf (" on port %i with no more than %i clients\n", port, max_connections);/* Assign signal handlers to signals. */if (signal (SIGPIPE, SIG_IGN) == SIG_ERR){perror ("signal");exit (EXIT_FAILURE);}if (signal (SIGTERM, signal_handler) == SIG_ERR){perror ("signal");exit (EXIT_FAILURE);}if (signal (SIGINT, signal_handler) == SIG_ERR){perror ("signal");exit (EXIT_FAILURE);}pthread_attr_t pthread_attr;pthread_arg_t *pthread_arg;pthread_t pthread;//为属性对象分配了动态内存空间if (pthread_attr_init (&pthread_attr) != 0){perror("pthread_attr_init");exit (EXIT_FAILURE);}//设置线程分离状态if (pthread_attr_setdetachstate (&pthread_attr, PTHREAD_CREATE_DETACHED) != 0){perror("pthread_attr_setdetachstate");exit (EXIT_FAILURE);}// 开始观测//指定已初始化的读写锁pthread_rwlock_init (&rwlock, NULL);if (pthread_create (&pthread, &pthread_attr, pthread_sysinfo, NULL) != 0){perror("pthread_create");exit (EXIT_FAILURE);}struct addrinfo hints;struct addrinfo *result, *rp;int socket_fd;memset(&hints, 0, sizeof(struct addrinfo));hints.ai_family = AF_UNSPEC;hints.ai_socktype = (protocol == TCP) ? SOCK_STREAM : SOCK_DGRAM;hints.ai_flags = AI_PASSIVE;hints.ai_protocol = 0;hints.ai_canonname = NULL;hints.ai_addr = NULL;hints.ai_next = NULL;int s = getaddrinfo(NULL, argv[2], &hints, &result);if (s != 0){fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(s));exit(EXIT_FAILURE);}for (rp = result; rp != NULL; rp = rp->ai_next){socket_fd = socket(rp->ai_family, rp->ai_socktype,rp->ai_protocol);if (socket_fd == -1)continue;if (bind(socket_fd, rp->ai_addr, rp->ai_addrlen) == 0)break; /* Success */close (socket_fd);}if (rp == NULL) /* No address succeeded */{fprintf(stderr, "Could not bind\n");exit (EXIT_FAILURE);}freeaddrinfo (result);if (protocol == UDP){struct timeval timeout = {5, 0};//设置端口复用setsockopt (socket_fd, SOL_SOCKET, SO_RCVTIMEO, (char*)&timeout, sizeof(struct timeval));for (;; udp_reply (socket_fd));}if (listen (socket_fd, BACKLOG) == -1){perror ("listen");exit (EXIT_FAILURE);}while (protocol == TCP){pthread_arg = (pthread_arg_t *) malloc (sizeof *pthread_arg);if (!pthread_arg){perror ("malloc");exit (EXIT_FAILURE);}socklen_t client_address_len = sizeof pthread_arg->client_address;int tcp_socket_fd = accept (socket_fd, (struct sockaddr *)&pthread_arg->client_address,&client_address_len);connections++;if (tcp_socket_fd == -1){perror ("accept");free (pthread_arg);exit (EXIT_FAILURE);}else if (connections > max_connections){close (tcp_socket_fd);connections--;free (pthread_arg);continue;}printf ("New TCP connection accepted: now there are %i clients\n", connections);pthread_arg->new_socket_fd = tcp_socket_fd;if (pthread_create (&pthread, &pthread_attr, pthread_routine_tcp, (void *)pthread_arg) != 0){perror("pthread_create");free (pthread_arg);exit (EXIT_FAILURE);}}return 0;
}
...
void *pthread_sysinfo ()
{char *s = system_state_report ();strcpy (system_state, s);free (s);for (;;){if (connections > 0 || protocol == UDP){s = system_state_report ();pthread_rwlock_wrlock (&rwlock);strcpy (system_state, s);pthread_rwlock_unlock (&rwlock);free (s);}}return NULL;
}void signal_handler (int signal_number)
{/* Exit cleanup code here. */// close (socket_fd);exit (EXIT_SUCCESS);
}
...
char *system_state_report ()
{json_t *root = json_loads (BLANC_JSON_REPORT, 0, NULL);cpu_usage (json_object_get(root, "CPU, %"));ram_usage (json_object_get(root, "RAM"));storage_usage (json_object_get(root, "Storage"));net_usage (json_object_get(root, "Network"));time_stamp (root);char *s = json_dumps (root, 0);json_decref (root);return s;
}int cpu_usage (json_t *cpu_state)
{char buff[TXT_BUFFER_SIZE][TXT_BUFFER_SIZE];int ncpu = get_nprocs ();FILE* fp = fopen(STAT_PATH,"r");for (int i = 0; i < ncpu + 1; i++){fgets(buff[i], TXT_BUFFER_SIZE, fp);}fclose(fp);sleep(TIME_LAG);fp = fopen(STAT_PATH,"r");for (int i = 0; i < ncpu + 1; i++){fgets(buff[i + ncpu + 1], TXT_BUFFER_SIZE, fp);}fclose(fp);for (int i = 0; i < ncpu + 1; i++){long long sum = 0, lastSum = 0;long long idle, lastIdle;char* token = strtok(buff[i], " ");for (int col = 0; token != NULL;){token = strtok (NULL, " ");if (token != NULL){lastSum += atoll (token);if (col == 3)lastIdle = atoll (token);col++;}}
...int cpu_usage_pct = (1000 *((sum - lastSum) - (idle - lastIdle)) / (sum - lastSum) + 5) / 10;json_t *json_cpu_pct;json_cpu_pct = json_integer(cpu_usage_pct);json_array_append (cpu_state, json_cpu_pct);json_decref (json_cpu_pct);}return 0;
}...
客户端:
与服务器交互。通常,会使用write将消息中的消息发送到服务器,并使用read从服务器接收消息并将其存储在消息中。
...
int main(int argc, char *argv[])
{
...if (argc < 4){fprintf (stderr, "Usage: %s <host> <port> <update_time (seconds)>\n", argv[0]);exit(EXIT_FAILURE);}const int time_lag = atoi (argv[3]);if (!time_lag){fprintf( stderr, "Impossible time lag: %s\n", argv[3]);exit(EXIT_FAILURE);}memset(&hints, 0, sizeof(struct addrinfo));hints.ai_family = AF_UNSPEC; /* Allow IPv4 or IPv6 */hints.ai_socktype = 0; /* Any type: TCP/UDP */hints.ai_flags = 0;hints.ai_protocol = 0; /* Any protocol */s = getaddrinfo(argv[1], argv[2], &hints, &result);if (s != 0){fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(s));exit(EXIT_FAILURE);}for (rp = result; rp != NULL; rp = rp->ai_next){sfd = socket(rp->ai_family, rp->ai_socktype,rp->ai_protocol);if (sfd == -1)continue;if (connect(sfd, rp->ai_addr, rp->ai_addrlen) != -1)break;close(sfd);}if (rp == NULL){fprintf (stderr, "Could not connect to server %s at port: %s\n", argv[1], argv[2]);exit(EXIT_FAILURE);}freeaddrinfo(result);// Server interaction.for (;; sleep (time_lag)){char msg[BUF_SIZE];char s[BUF_SIZE];bzero (msg, BUF_SIZE);write (sfd, "report", 6);int server_response = read (sfd, msg, BUF_SIZE);if (server_response <= 0){printf ("Connection is closed by server\n");break;}status (msg, s);printf ("%s\n", s);}...
}int status (const char *src, char *report)
{
...int ncpu = json_array_size (cpu_status);int tot_cpu_usage = json_integer_value (tot_cpu_load);char buff[BUF_SIZE];sprintf (report, "Total usage of %2i CPUs: %3i%%, ", ncpu - 1, tot_cpu_usage);int mem_tot = json_integer_value (json_object_get (ram_status, "Total" ));int mem_free = json_integer_value (json_object_get (ram_status, "Free" ));int mem_buff = json_integer_value (json_object_get (ram_status, "Buffers"));int mem_cach = json_integer_value (json_object_get (ram_status, "Cached" ));int mem_not_used = mem_free + mem_buff + mem_cach;int mem_used = mem_tot - mem_not_used;sprintf(buff, "Memory: %.1f MB used, %.1f MB free", mem_used/1024.0, mem_not_used/1024.0);
...
}
If you need the complete source code, please add the WeChat number (c17865354792)
运行结果:
打开两个客户端连接服务器,最后再同时断开连接服务器。
在客户端的请求消息报告中,作为响应,服务器给出系统当前状态的描述。
总结
多线程在解决方案中提供了并发性。由于并发性,客户端不必等待轮到他们,可以立即得到服务。当服务器有一个线程来处理新连接。接受这样的连接后,将创建一个新线程,负责与给定客户端的所有通信。最后要讲的是,熟悉多线程编程是一项重要的个人技能,只有掌握了多线程编程,才能更合理地选择使用或不使用多线程。
Welcome to follow WeChat official account【程序猿编码】
相关文章:

Linux C/C++ 多线程TCP/UDP服务器 (监控系统状态)
Linux环境中实现并发TCP/IP服务器。多线程在解决方案中提供了并发性。由于并发性,它允许多个客户端同时连接到服务器并与服务器交互。 Linux多线程编程概述 许多应用程序同时处理多项杂务。服务器应用程序处理并发客户端;交互式应用程序通常在处理后台…...

【JavaScript】JavaScript基本使用方法
如何回复程序员发来的短信:Hello world —hello nerd. 前言: 大家好,我是程序猿爱打拳。今天我给大家讲解的是初识JavaScript中基本组成成分、引入方法、输入输出语句,并用源码与效果图的方式展示给大家。 目录 1.JavaScript组成…...

Python数据容器、list列表、tuple元组、str字符串、数据容器(序列)切片、set集合、dict字典、字符串大小比较
数据来源 01 数据容器 为什么学习数据容器 数据容器 总结 02 列表 1)列表定义 为什么需要列表 列表的定义语法 列表的定义方式 演示 """ 演示数据容器之:list列表 语法:[元素,元素,......] """ # 定义一个列表list my_list …...

Python urllib
Python urllib Python urllib 库用于操作网页 URL,并对网页的内容进行抓取处理。 本文主要介绍 Python3 的 urllib。 urllib 包 包含以下几个模块: urllib.request - 打开和读取 URL。urllib.error - 包含 urllib.request 抛出的异常。urllib.parse …...

Centos7安装Python3
前言系统版本:Centos7.6python版本: python 3.10.4下载python下载链接:直通车找到对应版本的python安装包,这里以python 3.10.4为例点击3.10.4版本的链接,拉到最下面找到Files中对应的linux安装包鼠标右键复制下载链接登录linux系…...

[U3D ShaderGraph] 全面学习ShaderGraph节点 | 第四课 | Input/Lighting
📣📣📣本专栏所有内容在完结之前全部为试读模式,专栏完结之后会取消试读模式,如果感觉内容还不错的话请支持一下📣📣📣 ShaderGraph是可视化的着色器编辑工具。您可以使用此工具以可视方式创建着色器。 本专栏可以让你更了解ShaderGraph中每个节点的功能,更自如的…...

SpringBoot升级到3.0
SpringBoot 3.0出来有一段时间了,一直没时间来整理,这次来看一下吧。 Spring Boot 可以轻松创建独立的、生产级的基于 Spring 的应用程序,您可以“直接运行”。 SpringBoot升级到3.01. SpringBoot的维护时间线2. pom添加3. 打包大小对比4. 升…...

JavaWeb8-线程安全问题
目录 1.概念 1.1.单线程 1.2.多线程 2.导致线程不安全的5个因素 ①抢占式执行(首要原因) ②多个线程同时修改了同一个变量 ③非原子性操作 ④内存可见性 ⑤指令重排序 线程优点:加速程序性能。线程缺点:存在安全问题。 1…...

进程切换-
实验课之前有一些问题 中断机制 第一个问题: interrupt的两个状态源头: 外中断多由随机中断(异步中断)造成,如鼠标点击,键盘输入; 内终端多由故障终端:程序运行异常,硬件…...

python--matplotlib(2)
前言 Matplotlib画图工具的官网地址是 http://matplotlib.org/ Python环境下实现Matlab制图功能的第三方库,需要numpy库的支持,支持用户方便设计出二维、三维数据的图形显示,制作的图形达到出版级的标准。 实验环境 Pycharm2020.2.5社区版,w…...

【李忍考研传】五、信心
这天,何隐一来到图书馆就一脸兴奋地对李忍说:“晚上告诉你一个好消息。”李忍又期待又迷惑。“小何今天是咋的了?买彩票中了二十?”虽然李忍很想知道何隐在卖什么关子,但是既然晚上就能知道,那就忍忍吧。 …...

Web 页面之间传递参数的几种方法
Web 页面之间传递参数的方法有很多种,下面列出一些常见的方法以及它们的代码示例。 一、前端直接传递参数 1、URL 参数传递(query string):通过 URL 的查询字符串(即问号后面的参数)将参数传递给页面。可…...

Android实例仿真之二
目录 三 从无入手 第一阶段 第二阶段 第三阶段 第四阶段 第五阶段 第六阶段 第七阶段 八 举两个典型例子: 九 逆向工程 三 从无入手 这节标题叫从无入手,什么意思呢?如果没有Android这个实例存在,你要做一个类似Android…...

day47【代码随想录】动态规划之买卖股票的最佳时机III、买卖股票的最佳时机IV、最佳买卖股票时机含冷冻期、买卖股票的最佳时机含手续费
文章目录前言一、买卖股票的最佳时机III(力扣123)二、买卖股票的最佳时机IV(力扣188)三、最佳买卖股票时机含冷冻期(力扣309)四、买卖股票的最佳时机含手续费(力扣714)股票买卖问题总…...

网络数据包接收流程
1. 网络数据包接收流程简述 典型的以太网卡网络包接收流程如下: 1.网络包通过物理介质传到接收端的phy芯片; 2.phy芯片通过RGMII协议传到MAC芯片rx queue fifo中; 3.MAC芯片通过专用DMA将网络包搬运到网卡驱动程序预先分配好的rx ringbuffer中…...

CSAPP学习笔记——虚拟内存(二)
案例研究 Intel Core i7 该处理底层的Haswell微体系结构允许64位的虚拟和物理地址空间,而现在的Core i7实现支持48位(256TB)虚拟地址空间和52位(4PB)物理地址空间,这对目前来说已经完全够用了。ÿ…...

面试sql
创建表 create table Student ( Sno varchar(20) primary key,Sname varchar(20) UNIQUE,Ssex varchar(2),Sbirthday date,class varchar(20) )create table Course ( Cno varchar(20) primary key,Cname varchar(20) UNIQUE,Tno varchar(20) )create table Score ( …...

Python编程自动化办公案例(2)
作者简介:一名在校计算机学生、每天分享Python的学习经验、和学习笔记。 座右铭:低头赶路,敬事如仪 个人主页:网络豆的主页 目录 前言 一.前期代码 二.实现批量读取 1.os库 2.实现思路 (1&#…...

Vulnhub 渗透练习(七)—— FRISTILEAKS: 1.3
环境搭建 下载链接 virtualbox 打开靶机设置为 host-only,攻击机同样。 具体可点此处 信息收集 开了个 80 端口。 用的是 apache 2.2.15 ,这个版本有个解析漏洞。 目录 根据首页的图片猜测 /fristi/ 目录(不过我没想到 -_-&#x…...

阶段二10_面向对象高级_分类分包思想和案例环境搭建
一.分类思想 1.分类思想概念: 分工协作,专人干专事 2.信息管理系统分类[案例] Student 类-------------------->标准学生类,封装键盘录入的学生信息(id , name , age , birthday) StudentDao 类-----------------&…...

关于打印工具print-js的使用
https://www.jianshu.com/p/f6f09dd9f7db第一步 安装组件//安装print-js npm install print-js --save //删除print-js npm uninstall print-js //安装固定版本 npm install print-js版本号 --save // 全局安装 npm install print-js --save -g第二步 引入组件安装成功后&#…...

Doxygen使用
文章目录简介Doxygen的安装Doxygen的配置生成配置文件常用配置Doxygen注释头文件注释:函数的注释:Doxygen文档生成reference简介 Doxygen 是一个流行的用于生产代码文档的工具,关于它的介绍可以参考官网:https://www.doxygen.nl/index.html。 我使用Dox…...

MySQL数据库调优————表结构设计优化
三范式 第一范式 字段具有原子性,即数据库表的每一个字段都是不可分割的原子数据项,不能是集合、数组、记录等非原子数据项当实体中的每个属性有多个值时,必须拆分为不同的属性 第二范式 满足第一范式的基础上,要求每一行数据…...

set对象和map对象
1 Set对象 介绍: Set数据结构类似数组,但所有成员的值唯一。 Set本身为一个构造函数,用来生成 Set数据结构,使用 add方法来添加新成员。 let a new Set(); [1,2,2,1,3,4,5,4,5].forEach(x>a.add(x)); for(let k of a){ console.log(k…...

stream()流的使用
文章目录引入流流的操作中间操作终端操作流的使用谓词筛选筛选各异的元素流的切片截断流跳过元素映射流的扁平化查找和匹配归约元素求和、最大值和最小值数值流构建流由值构建流由数组创建流引入流 java api提供的一种利用声明式的方式处理数据集合的一个东西,可以…...

C++学习笔记-常量
在程序执行过程中,其值不能改变的量称为常量(Constant)。普通常量的类型是根据数据的书写形式来决定的。如 100 是整型常量,0.5 是实型常量,‘q’ 是字符型常量,“qianfeng” 是字符串常量。 常量是固定值,在程序执行期…...

JavaScript系列之实现继承的几种方式
文章の目录一、借助父构造函数继承属性1、实现方式2、优点3、缺点二、原型链继承1、实现方式2、优点3、缺点三、组合继承四、ES6继承的实现方式参考写在最后一、借助父构造函数继承属性 1、实现方式 先定义一个父构造函数(this指向为window);再定义一个子构造函数…...

java面试准备
1.自我介绍: 2.基础 : 1.集合 : java容器中分为collection 和map两大类 collection 分为list集合(有序且重复的),set集合(无序,不可重复) list集合分为arrayList集合 : 查询快,增删慢,它是基于数组结构的,对数据的增删是在数组的尾部进行添加或删除的,其效率相对于LinkedList…...

kafka-6-python单线程操作kafka
使用Python操作Kafka:KafkaProducer、KafkaConsumer Python kafka-python API的帮助文档 1 kafka tools连接 (1)/usr/local/kafka_2.13-3.4.0/config/server.properties listeners PLAINTEXT://myubuntu:9092 advertised.listenersPLAINTEXT://192.168.1.8:2909…...

【Spring教程】1.Spring概述
1、概述 1.1、Spring是什么? Spring 是一款主流的 Java EE 轻量级开源框架 ,Spring 由“Spring 之父”Rod Johnson 提出并创立,其目的是用于简化 Java 企业级应用的开发难度和开发周期。Spring的用途不仅限于服务器端的开发。从简单性、可测…...