白骑士的C++教学实战项目篇 4.3 多线程网络服务器

系列目录

上一篇:白骑士的C++教学实战项目篇 4.2 学生成绩管理系统

        在这一节中,我们将实现一个多线程网络服务器项目,通过该项目,我们将学习套接字编程的基础知识以及如何使用多线程处理并发连接。此外,我们还将实现一个简单的客户端来与服务器进行通信。

项目简介

        多线程网络服务器是一种可以同时处理多个客户端请求的服务器。通过多线程技术,我们可以使服务器在处理一个客户端请求时,不阻塞其他客户端的连接请求。本项目将涉及以下内容:

  • 套接字编程基础
  • 多线程处理
  • 客户端与服务器的实现

套接字编程基础

        套接字(Socket)是网络编程的基础,它提供了在网络上进行数据通信的机制。在C++中,我们可以使用POSIX标准库(如 ‘sys/socket.h‘、‘arpa/inet.h‘ 等)来进行套接字编程。下面是一个基本的服务器和客户端通信的示例。

服务器端代码

#include <iostream>
#include <unistd.h>
#include <netinet/in.h>
#include <string.h>
#include <thread>const int PORT = 8080;void handleClient(int clientSocket) {char buffer[1024] = {0};read(clientSocket, buffer, 1024);std::cout << "Message from client: " << buffer << std::endl;send(clientSocket, buffer, strlen(buffer), 0);close(clientSocket);
}int main() {int serverFd, clientSocket;struct sockaddr_in address;int opt = 1;int addrlen = sizeof(address);// 创建服务器端套接字if ((serverFd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {perror("socket failed");exit(EXIT_FAILURE);}// 设置套接字选项if (setsockopt(serverFd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {perror("setsockopt failed");exit(EXIT_FAILURE);}address.sin_family = AF_INET;address.sin_addr.s_addr = INADDR_ANY;address.sin_port = htons(PORT);// 绑定套接字if (bind(serverFd, (struct sockaddr*)&address, sizeof(address)) < 0) {perror("bind failed");exit(EXIT_FAILURE);}// 监听连接if (listen(serverFd, 3) < 0) {perror("listen failed");exit(EXIT_FAILURE);}while (true) {std::cout << "Waiting for connections...\n";if ((clientSocket = accept(serverFd, (struct sockaddr*)&address, (socklen_t*)&addrlen)) < 0) {perror("accept failed");exit(EXIT_FAILURE);}std::thread clientThread(handleClient, clientSocket);clientThread.detach(); // 将线程分离,以便独立运行}close(serverFd);return 0;
}

客户端代码

#include <iostream>
#include <unistd.h>
#include <arpa/inet.h>
#include <string.h>const int PORT = 8080;int main() {int sock = 0;struct sockaddr_in serv_addr;char* message = "Hello from client";char buffer[1024] = {0};// 创建客户端套接字if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {std::cerr << "Socket creation error" << std::endl;return -1;}serv_addr.sin_family = AF_INET;serv_addr.sin_port = htons(PORT);// 将IP地址转换为二进制格式if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0) {std::cerr << "Invalid address/ Address not supported" << std::endl;return -1;}// 连接服务器if (connect(sock, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) < 0) {std::cerr << "Connection failed" << std::endl;return -1;}send(sock, message, strlen(message), 0);std::cout << "Message sent" << std::endl;read(sock, buffer, 1024);std::cout << "Message from server: " << buffer << std::endl;close(sock);return 0;
}

多线程处理

        在上述服务器代码中,我们使用了 ‘std::thread‘ 来为每个客户端连接创建一个新线程,并使用 ‘detach‘ 将其分离,使线程能够独立运行而不阻塞主线程。这种方式可以有效地处理多个客户端的并发连接。

客户端与服务器的实现

        我们已经实现了基本的客户端和服务器通信。为了使系统更健壮,可以考虑添加以下功能:

  • 异常处理:处理各种可能的网络异常,如连接失败、读写失败等。
  • 日志记录:记录客户端连接和断开时间、传输的数据等信息。
  • 并发控制:限制同时连接的客户端数量,防止服务器过载。

完整代码示例

#include <iostream>#include <unistd.h>#include <netinet/in.h>#include <string.h>
#include <thread>
#include <vector>
#include <mutex>const int PORT = 8080;std::mutex coutMutex;void handleClient(int clientSocket) {char buffer[1024] = {0};read(clientSocket, buffer, 1024);{std::lock_guard<std::mutex> lock(coutMutex);std::cout << "Message from client: " << buffer << std::endl;}send(clientSocket, buffer, strlen(buffer), 0);close(clientSocket);
}int main() {int serverFd, clientSocket;struct sockaddr_in address;int opt = 1;int addrlen = sizeof(address);// 创建服务器端套接字if ((serverFd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {perror("socket failed");exit(EXIT_FAILURE);}// 设置套接字选项if (setsockopt(serverFd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {perror("setsockopt failed");exit(EXIT_FAILURE);}address.sin_family = AF_INET;address.sin_addr.s_addr = INADDR_ANY;address.sin_port = htons(PORT);// 绑定套接字if (bind(serverFd, (struct sockaddr*)&address, sizeof(address)) < 0) {perror("bind failed");exit(EXIT_FAILURE);}// 监听连接if (listen(serverFd, 3) < 0) {perror("listen failed");exit(EXIT_FAILURE);}while (true) {std::cout << "Waiting for connections...\n";if ((clientSocket = accept(serverFd, (struct sockaddr*)&address, (socklen_t*)&addrlen)) < 0) {perror("accept failed");exit(EXIT_FAILURE);}std::thread clientThread(handleClient, clientSocket);clientThread.detach();}close(serverFd);return 0;
}

        通过以上代码,我们实现了一个简单的多线程网络服务器,能够同时处理多个客户端的连接请求。这个项目不仅帮助我们掌握了套接字编程的基础知识,还了解了多线程处理的基本方法。

总结

        多线程网络服务器项目使我们掌握了网络编程和多线程处理的基本知识。通过实践套接字编程和多线程技术,我们可以开发出更高效、更稳定的网络应用程序。

下一篇:白骑士的C++教学附加篇 5.1 C++开发工具​​​​​​​

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

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

相关文章

路由数据获取及封装方法

数据库设计 自联表 定义tree字段 public class LabelValue{public int label { get; set; }public string? value { get; set; }public List<LabelValue> children { get; set; }}获取路由方法 public Response<object> getMenuList() {Response<object>…

利用patch-package补丁,解决H5预览PDF时电子签章不显示问题

利用patch-package补丁&#xff0c;解决H5预览PDF时电子签章不显示问题 一、问题描述 在生产环境中&#xff0c;遇到了一个紧急的技术问题&#xff1a;用户在移动端H5页面上查看电子票时&#xff0c;PDF文件预览功能正常&#xff0c;但其中的电子签章未能正常显示。这一问题直…

Linux网络——TcpServer

一、UDP 与 TCP 在现实生活中&#xff0c;Udp 类似于发传单&#xff0c;Tcp 类似于邮局的挂号信服务。 1.1 UDP&#xff08;用户数据报协议&#xff09; 无连接&#xff1a;发放传单时&#xff0c;你不需要提前和接受传单的人建立联系&#xff0c;直接把传单发出去。不可靠&…

0718vscode问答

终于来到 qt # Question 多态 # Answer 多态是面向对象编程中的一个重要概念&#xff0c;指的是同一个接口可以有多种不同的实现方式。多态性允许我们使用一个统一的接口来处理不同类型的对象&#xff0c;从而提高代码的灵活性和可扩展性。 在Java中&#xff0c;多态可以通过以…

处理.git文件夹过大出现臃肿问题

1、问题背景 在软件开发过程中&#xff0c;版本控制是一个至关重要的环节。Git 作为一种流行的分布式版本控制系统&#xff0c;被广泛应用于各种项目中。然而&#xff0c;近期我们发现在进行项目发版时&#xff0c;Git 克隆项目的时间显著增加&#xff0c;严重影响了发版的效率…

stm32入门-----EXTI外部中断(下——实践篇)

目录 前言 一、硬件介绍 1.对射红外线传感器 2.旋转编码器 二、EXTI外部中断C编程 1.开启RCC时钟 2.配置GPIOK口初始化 3.配置AFIO 4.配置EXIT 5.配置NVIC 三、EXIT外部中断项目实操 1.对射红外传感器计数 2.选择编码器计数 前言 本期接着上一期的内容继续学习stm3…

DHCP中继实验

一、什么是DHCP中继? 1、使得一个DHCP服务器同时为多个网段服务称为DHCP中继技术。 2、配置DHCP中继的网络设备可以在不同网段上从DHCP总服务器获取IP地址分配给下面的各个主机。 3、路由器和交换机都可充当中继。DHCP中继在两个网段间代理客户端和服务器请求,中继服务器需要…

SEO需要了解的8大html标签

做SEO久了就会发现SEO不是一项单一的技术&#xff0c;它需要你懂得很多东西&#xff0c;绝不是文章外链那么简单&#xff0c;至少你要懂得基本的标html标签。 1、title标签 标题是搜索引擎重要的参考标签&#xff0c;占有举足轻重的权重。建议不要在标题标签出现过多的关键词…

postman双击打不开的解决方案

postman双击打不开的解决方案 深入再深入 于 2022-05-09 15:45:56 发布 阅读量3.1k 收藏 2 点赞数 4 文章标签&#xff1a; postman 版权 右键属性 安装路径 更新版本 回滚 问题排查 关键词由CSDN通过智能技术生成 解决方案&#xff1a; 右键-属性&#xff0c;复制安装路…

Git 代码管理面试59题(一)

1. 简述Github和Gitlab的区别&#xff1f; 参考回答&#xff1a; Github是一个基于git实现在线代码托管的仓库&#xff0c;向互联网开放&#xff0c;企业版要收钱。gitlab类似 github&#xff0c;一般用于在企业内搭建git私服&#xff0c;要自己搭环境。GitHub如果使用私有仓…

【数据集处理工具】根据COCO数据集的json标注文件实现训练与图像的文件划分

根据COCO数据集的json标注文件实现训练与图像的文件划分 一、适用场景&#xff1a;二、COCO数据集简介&#xff1a;三、场景细化&#xff1a;四、代码优势&#xff1a;五、代码 一、适用场景&#xff1a; 适用于一个常见的计算机视觉项目应用场景&#xff0c;特别是当涉及到使…

【漏洞复现】泛微e-cology9 WorkflowServiceXml SQL注入漏洞

文章目录 前言漏洞描述影响范围 漏洞复现nuclei脚本 安全修复 前言 泛微协同管理应用平台e-cology是一套兼具企业信息门户、知识文档管理、工作流程管理、人力资源管理、客户关系管理、项目管理、财务管理、资产管理、供应链管理、数据中心功能的企业大型协同管理平台。 漏洞…

裸金属服务器

裸金属服务器&#xff08;Bare Metal Server&#xff09;是一种提供物理服务器硬件的云计算服务&#xff0c;与传统的虚拟化技术相对。在裸金属服务中&#xff0c;用户直接访问和控制物理服务器的硬件资源&#xff0c;而不通过虚拟化层。以下是裸金属服务器的一些关键特点&…

Oracle(9)什么是SGA(System Global Area)?

SGA&#xff08;System Global Area&#xff0c;系统全局区&#xff09;是Oracle数据库实例中的一块共享内存区&#xff0c;用于存储数据库实例运行时所需的数据和控制信息。SGA在实例启动时分配&#xff0c;实例关闭时释放。 主要组成部分 SGA由多个内存结构组成&#xff0c…

FFmpeg播放视频

VS2017FFmpeg6.2.r113110SDL2.30.5 1.下载 ShiftMediaProject/FFmpeg 2.下载SDL2 3.新建VC控制台应用 3.配置include和lib 4.把FFmpeg和SDL的dll 复制到工程Debug目录下&#xff0c;并设置调试命令 5.复制一下mp4视频到工程Debug目录下&#xff08;复制一份到*.vcxproj同一目录…

Qt 实战(6)事件 | 6.3、自定义事件

文章目录 一、自定义事件1、自定义事件类型2、创建自定义事件类3、发送自定义事件4、处理自定义事件5、总结 前言&#xff1a; Qt 是一个跨平台的 C 图形用户界面应用程序开发框架&#xff0c;它广泛用于开发 GUI程序&#xff08;注意&#xff1a;GUI的全称是Graphical User In…

系统架构设计师教程 第3章 信息系统基础知识-3.5 专家系统-解读

系统架构设计师教程 第3章 信息系统基础知识-3.5 专家系统(ES) 3.5.1 人工智能3.5.1.1 人工智能的特点3.5.1.2 人工智能的主要分支3.5.2 ES的概念3.5.2.1 ES 概述3.5.2.2 与传统程序的区别3.5.3 ES的特点3.5.4 ES的组成3.5.4.1 知识库3.5.4.2 综合数据库3.5.4.3 推理机3.5.4.…

Maven settings.xml 私服上传和拉取配置

公司内部自行开发的依赖包需要上传到maven私服时&#xff0c;可以在项目的pom.xml中配置&#xff0c;也可以在本地计算机的maven目录settings.xml中配置。本文讲述的是如何在settings.xml中进行配置。 场景&#xff1a;有两个maven私服&#xff0c;其中一个为公司的&#xff0…

21-22集 ESP32-IDF开发教程编译运行机器人对话工程-《MCU嵌入式AI开发笔记》

21集 ESP32-IDF开发教程-《MCU嵌入式AI开发笔记》 之前我们用了windows系统搭建了ESP-IDF的开发环境&#xff0c; 我们还是参考这个官方文档https://docs.espressif.com/projects/esp-idf/zh_CN/release-v5.1/esp32s3/get-started/index.html 同时我们也参考之前讲到的&#…

GIT--git clone fatal [文件过大或网络不稳定] [大型仓库]

GIT--git clone fatal 1 介绍1.1 原因分类1.2 文件过大或网络不稳定 2 分析3 操作3.1 指定克隆深度【浅克隆】3.2 分批次下载3.3 增大Git的HTTP POST缓冲区大小3.4 配置git的最低速度和最低速度时间(单位&#xff1a;秒)3.5 压缩3.6 过滤下载 git filter branch3.7 仅克隆一个分…