DevC++ 用C语言的多线程 实现简单的客户端和服务器

知识来源一：

使用Dev-C++实现简单的客户端和服务器-CSDN博客

此先生的博客使用的是win32 SDK来创建多线程，然后鄙人对这个版本的多线程细节不明。于是又重新用C语言的线程替代win32API,以此继续学习服务器代码。

知识来源二：DevC++ 多线程创建与删除与exe文件脱离DevC++运行中发现dll文件和exe文件的关系-CSDN博客

这是C语言多线程简单样例。

然后在这两个基础上优化知识来源一的服务端代码，过程中查询函数，然后复制博客链接和截取解释，产生了知识来源三如下，作为函数忘了可以怎么开发了，就翻回去参考的，集成小文案。

知识来源三：

DevC++ socket嵌套字实现局域网客户端服务端函数详解注释-CSDN博客

优化功能说明：

客户端命令： log_out : 切断客户端在服务器的联系

消息反馈功能：客户端输入消息后，服务端发送反馈消息，说明可以服务端可以直接利用已经建立的链接传输消息，不用再另外建一新联系。

增加过程提示：函数执行过程中printf运行阶段，是当时改线程创建忘新建线程的bug加的测试点。

效果如图

零起点的顺序是，先看知识来源二的文章，玩玩里面的代码demo，键盘命令创建取消线程。然后看本节文章，对着知识点三，把本节文章的单线程服务器注释取消掉，删掉多线程部分。理解一个服务器一个客户端的联系的建立，然后再看看多线程代码，读读注释，用自己的话再说说，然后自己独立写写多线程服务器代码，写20min要是写不动了就仔细描述自己怎么写不出来的，是不会无中生有，连猜也猜不出来通信需要什么凭证，还是说是函数参数忘了默认值。然后再看看参考代码，理解自己是通过怎样的观察，在限定的时间里发现自己重复中却不能重复出新的思路。避免死磕，发现规模重复不能产生新意就回归，在现有的参考标准里的继续学习，临摹思路与代码。然后再试试能不能整活加点料，实现新功能。

完整代码如下，如果服务器代码编译的exe文件点击运行时，提示缺少libwinpthread-1.dll文件，有bug原理与解决方案，详情刚才的知识来源二：DevC++ 多线程创建与删除与exe文件脱离DevC++运行中发现dll文件和exe文件的关系-CSDN博客

服务端，有小的注释。

#include <stdio.h>
#include <winsock2.h>
#include<pthread.h>
#include<string.h>
#include<conio.h>
#pragma comment(lib,"ws2_32.lib")


//这两个注释块是win32API函数写的的多线程函数，用于对照c语言多线程 

//typedef struct ThreadNode
//{
//	int index;
//	HANDLE ThreadId;
//	SOCKET Client;
//	struct ThreadNode * next;
//	ThreadNode()
//	{
//		index = 0;
//		this->next = NULL;
//	}
//}hThread;

typedef struct ThreadNode {
	int index;
	pthread_t* Thread;
	SOCKET Client;
	struct ThreadNode * next;
	ThreadNode() {
		index = 0;
		this->next = NULL;
	}
} hThread;

hThread *clientHeadNote, *clientEndNote;
hThread * addClient() {
	hThread * ClientNote = new hThread();
	return ClientNote;
}

//DWORD WINAPI ThreadClient(LPVOID param)
//{
//	if(clientEndNote == NULL)
//	{
//		printf("empty Link\n");
//		return 0;
//	}
//	char revData[255];
//	SOCKET sClient = clientEndNote->Client;
//	while(1)
//	{
//			//接收数据
//	    int ret = recv(sClient, revData, 255, 0);
//	    if(ret > 0)
//	    {
//	        revData[ret] = 0x00;
//	        printf(revData);
//	        puts(0);
//	    }
//	}
//	closesocket(sClient);
//}

//每个建立链接的客户端分配一个函数，每个线程运行一个这样的函数 
void* ThreadClient(void*) {
	if (clientEndNote == NULL) {
		printf("empty Link\n");
		return 0;
	}
	char revData[255];
	SOCKET sClient = clientEndNote->Client;
	printf("client logged in \n");
	while (1) {
		//接收数据
		int ret = recv(sClient, revData, 255, 0);
		if (ret > 0) {
			revData[ret] = 0x00;
			printf(revData);
//			puts(0);
			printf("\n");
//				    新功能：加入客户端控制签退
			if (strcmp("log_out", revData) == 0) {
				char a[255];
				strcpy(a, "已注销\n");
				send(sClient, a, 255, 0);
//				反馈：向客户端sClienr发送“已注销”消息，发送长度为255个字节，0是指不阻塞。
//				printf("签退成功\n");
				closesocket(sClient);
				printf("签退成功\n");

			} else {
				char a[255];
				strcpy(a, "服务器已收到消息\n");
				send(sClient, a, 255, 0);
			}
		}
	}
	closesocket(sClient);
}




int main(int argc, char* argv[]) {
	//初始化WSA
	WORD sockVersion = MAKEWORD(2, 2);
	WSADATA wsaData;
	if (WSAStartup(sockVersion, &wsaData) != 0) {
		return 0;
	}

	//创建套接字
	SOCKET slisten = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (slisten == INVALID_SOCKET) {
		printf("socket error !");
		return 0;
	}

	//绑定IP和端口
	sockaddr_in sin;
	sin.sin_family = AF_INET;
	sin.sin_port = htons(8888);
//	端口和客户端端口要相同，否则链接建立不上 
//		sin.sin_port = htons(8880);
	sin.sin_addr.S_un.S_addr = INADDR_ANY;
//	这个是any指的是不限制访问IP


//	sin.sin_addr.S_un.S_addr =htonl(INADDR_ANY);
//	char loa[16] = "192.168.15.189";
//	sin.sin_addr.S_un.S_addr = inet_addr(loa);


//	把sin强制类型转换为sockadd,sin原来是sockaddr_in类型
//	初始化slisten,加载上面代码设置的属性。 
	if (bind(slisten, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR) {
		printf("bind error !");
	}

	//开始监听
	if (listen(slisten, 5) == SOCKET_ERROR) {
		printf("listen error !");
		return 0;
	}


//	以上可以认为是建立服务器联系的固定格式


//下面注释部分是单线程的服务器，就是只能接受一个客户端的服务器 

	//循环接收数据
//	SOCKET sClient;
//	sockaddr_in remoteAddr;
//	int nAddrlen = sizeof(remoteAddr);
//	char revData[255];

	接受消息拉到外部，建立联系就一直接受
//	printf("等待连接...\n");
//	sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen);
//	if (sClient == INVALID_SOCKET) {
//		printf("accept error !");
	            continue;
//	}
//	printf("接受到一个连接：%s \r\n", inet_ntoa(remoteAddr.sin_addr));
//
//
//	while (true) {
//		//接收数据
//		int ret = recv(sClient, revData, 255, 0);
		ret是数据长度 sclient是数据来源 revdata是数据，255是长度上限，0是不阻塞
//		if (ret > 0) {
//			revData[ret] = 0x00;
//			printf(revData);
//			printf("\n");
//		}
//		//发送数据
//		char a[100]="服务器已收到消息\n";
		scanf("%s", a);
//		send(sClient, a, strlen(a), 0);
//	}
//
//	closesocket(slisten);
//	WSACleanup();
//	return 0;


//这里是多线程服务器，接受多个客户端，可以对比单线程看看多了什么，哪些函数的位置调整了
 
	sockaddr_in remoteAddr;
	int nAddrlen = sizeof(remoteAddr);

	while (true) {
		printf("等待连接...\n");
		SOCKET sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen);
		if (sClient == INVALID_SOCKET) {
			printf("accept error !");
			continue;
		}

		printf("接受到一个连接：%s \r\n", inet_ntoa(remoteAddr.sin_addr));
		if (clientHeadNote == NULL) {
			clientHeadNote = addClient();
//			printf("node creat\n");
			clientEndNote = clientHeadNote;
		}
//		clientEndNote->Client = sClient;
//		clientEndNote->ThreadId = CreateThread(NULL, 0, ThreadClient, NULL, 0, NULL);


//	必须要先创建给end节点，然后再创建线程，因为线程的参数通过全局变量传入，而不是通过线程生成函数传入 
//	原来线程参数除了 pthread_create()还能通过全局变量传参数
		hThread* clientnode = (hThread*)malloc(sizeof(hThread));
		clientnode->Client = sClient;
		clientnode->next = NULL;
		clientHeadNote->next = clientnode;
		clientEndNote = clientnode;
		printf("endnode is created\n");
		clientnode->Thread = (pthread_t*)malloc(sizeof(pthread_t));
		clientnode->index = pthread_create(clientnode->Thread, NULL, ThreadClient, NULL);
		printf("线程创建成功\n");
		
		 
	}

	printf("server is closing\n"); 
	hThread * p;
	while (clientHeadNote) { //释放占用的内存空间
//	    	CloseHandle(clientHeadNote->ThreadId);
		p = clientHeadNote;
		clientHeadNote = clientHeadNote->next;
		delete p;
	}

	closesocket(slisten);
	WSACleanup();
	return 0;
}

客户端，但是注释更零散

#include <WINSOCK2.H>
#include <STDIO.H>
#include<pthread.h>
#pragma  comment(lib,"ws2_32.lib")


 
//格式和服务端一样
int main(int argc, char* argv[]) {
	WORD sockVersion = MAKEWORD(2, 2);
	WSADATA data;
	if (WSAStartup(sockVersion, &data) != 0) {
		return 0;
	}

	SOCKET sclient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (sclient == INVALID_SOCKET) {
		printf("无效的 socket !");
		return 0;
	}

	sockaddr_in serAddr;
	serAddr.sin_family = AF_INET;
	//表示使用IPv4地址协议
//    https://blog.csdn.net/u012736362/article/details/130392547
	serAddr.sin_port = htons(8888);
	
	
//    puts("请输入对方的IP地址");

	char loa[16] = "127.0.0.1";
//	就是当服务器的电脑的IP , win建+r 输入cmd，打开命令行，输入再直接 ipconfig/all可查看IP。 

// IP是读取目标机器的IP，由于一台电脑当服务器和客户端，127.0.0.1是自回路，自己发送给自己
	serAddr.sin_addr.S_un.S_addr = inet_addr(loa);
//    IP赋值

//链接发消息
	if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR) {
		//主动连接服务器
		printf("连接错误 !");
		closesocket(sclient);
		return 0;
	}
	puts("连接成功!!");
	puts("你现在可以向服务器发送信息：");
	
	while (1) {
		char sendData[100];
//		gets(sendData);
		scanf("%s",sendData);
		send(sclient, sendData, strlen(sendData), 0);
//		send(sclient, sendData, 255, 0);
//		匹配长度 255个字节

//		Sleep(1500);
//		if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR) {
//			//主动连接服务器
//			printf("连接错误 !");
//			closesocket(sclient);
//			return 0;
//		}
//		puts("连接成功!!");
//		puts("你现在可以向服务器发送信息：");

		char recData[255];
		int ret = recv(sclient, recData, 255, 0);
//		接收服务端消息 
		if (ret > 0) {
			recData[ret] = 0x00;
			printf(recData);
		}

	}
//    char recData[255];
//    int ret = recv(sclient, recData, 255, 0);
//    if(ret > 0)
//    {
//        recData[ret] = 0x00;
//        printf(recData);
//    }

	closesocket(sclient);
	WSACleanup();
	return 0;
}

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

dotnet命令创建C#项目，VSCode打开

dotnet命令创建C#项目，VSCode打开

在命令行中创建项目并运行 1.首先安装.net 下载地址:.NET | 构建。测试。部署。 2.在 cmd 控制台输入 dotnet --vesion 检查版本号是否正常 3.我用git bash环境输入命令创建项目 // 创建文件夹 mkdir MyVSCode // 进入该文件夹 cd MyVSCode/ // 创建控制台项目 dotnet …
阅读更多...
【华为OD机试真题2023CD卷 JAVAJS】两个字符串间的最短路径问题

【华为OD机试真题2023CD卷 JAVAJS】两个字符串间的最短路径问题

华为OD2023（C&D卷）机试题库全覆盖，刷题指南点这里 两个字符串间的最短路径问题 知识点数组动态规划字符串 时间限制：1s 空间限制：256MB 限定语言：不限 题目描述： 给定两个字符串，分别为字符串A与字符串B。例如A字符串为ABCABBA，B字符串为CBABAC可以得到下图m*n的二…
阅读更多...
【JavaSE】Java进阶知识一（泛型详解，包括泛型方法，协变，逆变，擦除机制）

【JavaSE】Java进阶知识一（泛型详解，包括泛型方法，协变，逆变，擦除机制）

目录 泛型 1. 什么是泛型 2.泛型方法 3.通配符上界&#xff08;泛型的协变&#xff09; 4.通配符下界&#xff08;泛型的逆变&#xff09; 5.泛型的编译&#xff08;擦除机制&#xff09; 泛型 泛型&#xff1a;就是让一个类能适用于多个类型&#xff0c;就是在封装数据结…
阅读更多...
四、ensp配置ftp服务器实验

四、ensp配置ftp服务器实验

文章目录 实验内容实验拓扑操作步骤配置路由器为ftp server 实验内容 本实验模拟企业网络。PC-1为FTP 用户端设备&#xff0c;需要访问FTP Server&#xff0c;从服务器上下载或上传文件。出于安全角度考虑&#xff0c;为防止服务器被病毒文件感染&#xff0c;不允许用户端直接…
阅读更多...
【什么是反射机制？为什么反射慢？】

【什么是反射机制？为什么反射慢？】

✅ 什么是反射机制&#xff1f;为什么反射慢&#xff1f; ✅典型解析✅拓展知识仓✅反射常见的应用场景✅反射和Class的关系 ✅典型解析 反射机制指的是程序在运行时能够获取自身的信息。在iava中&#xff0c;只要给定类的名字&#xff0c;那么就可以通过反射机制来获得类的所有…
阅读更多...
npm的常用使用技巧

npm的常用使用技巧

npm是一个强大的工具&#xff0c;可以帮助你管理Node.js项目中的依赖项。以下是一些有用的npm使用技巧&#xff1a; 使用npm install命令&#xff1a;这个命令可以安装项目的依赖项。如果你想安装一个特定的版本&#xff0c;你可以使用npm install <package><version…
阅读更多...
【FPGA】分享一些FPGA视频图像处理相关的书籍

【FPGA】分享一些FPGA视频图像处理相关的书籍

在做FPGA工程师的这些年&#xff0c;买过好多书&#xff0c;也看过好多书&#xff0c;分享一下。 后续会慢慢的补充书评。 【FPGA】分享一些FPGA入门学习的书籍【FPGA】分享一些FPGA协同MATLAB开发的书籍 【FPGA】分享一些FPGA视频图像处理相关的书籍 【FPGA】分享一些FPGA高速…
阅读更多...
基于Hexo+GitHub Pages 的个人博客搭建

基于Hexo+GitHub Pages 的个人博客搭建

基于HexoGitHub Pages 的个人博客搭建 步骤一&#xff1a;安装 Node.js 和 Git步骤二&#xff1a;创建Github Pages 仓库步骤二&#xff1a;安装 Hexo步骤三&#xff1a;创建 Hexo 项目步骤四&#xff1a;配置 Hexo步骤五&#xff1a;创建新文章步骤六&#xff1a;生成静态文件…
阅读更多...
Appium Server 启动失败常见原因及解决办法

Appium Server 启动失败常见原因及解决办法

Error: listen EADDRINUSE: address already in use 0.0.0.0:4723 如下图&#xff1a; 错误原因&#xff1a;Appium 默认的4723端口被占用 解决办法&#xff1a; 出现该提示&#xff0c;有可能是 Appium Server 已启动&#xff0c;关闭已经启动的 Appium Server 即可。472…
阅读更多...
推荐给前端开发的 5 款 Chrome 扩展

推荐给前端开发的 5 款 Chrome 扩展

工欲善其事&#xff0c;必先利其器。Chrome 可能是前端开发中使用最多的浏览器。在日常开发中&#xff0c;下列几款 Chrome 扩展也许能让你的开发工作事半功倍 &#x1f680; Vue.js devtools ⚙️ vue 官方专为 vue 应用开发的调试工具。 通过使用它&#xff0c;你可以快速查看…
阅读更多...
4.svn版本管理工具使用

4.svn版本管理工具使用

1. 什么是SVN 版本控制 它可以记录每一次文件和目录的修改情况，这样就可以借此将数据恢复到以前的版本，并可以查看数据的更改细节！ Subversion（简称SVN）是一个自由开源的版本控制系统。在Subversion管理下，文件和目录可以超越时空 SVN的优势 统一的版本号 Subversi…
阅读更多...
prometheus二进制安装

prometheus二进制安装

1、在需要安装prometheus的目录下执行wget命令下载软件到本地&#xff0c;如我的路径是/opt/module/prometheus wget https://github.com/prometheus/prometheus/releases/download/v2.34.0/prometheus-2.34.0.linux-amd64.tar.gz正在解析主机 objects.githubusercontent.com …
阅读更多...
Fireblock：为Dapp实现可编程隐私

Fireblock：为Dapp实现可编程隐私

1. 引言 Fireblock network为Cosmos生态应用链。并于2023年10月宣布完成pre-seed轮250万美金融资。 其定位为实现&#xff1a; 有条件解密可编程隐私 Fireblock使用的密码学方案有&#xff1a; distributed key generation&#xff08;DKG&#xff09;Identity-based encry…
阅读更多...
华为云Stack 8.X 流量模型分析（二）

华为云Stack 8.X 流量模型分析（二）

二、流量模型分析相关知识 1.vNIC ​ 虚拟网络接口卡(vNIC)是基于主机物理 NIC 的虚拟网络接口。每个主机可以有多个 NIC&#xff0c;每个 NIC 可以是多个 vNIC 的基础。 ​ 将 vNIC 附加到虚拟机时&#xff0c;Red Hat Virtualization Manager 会在虚拟机之间创建多个关联的…
阅读更多...
MySQL创建member表失败

MySQL创建member表失败

最近在做一个项目&#xff0c;在台式机上可以跑通&#xff0c;也测试了各个已完成的接口&#xff0c;提交到了GitHub后想着用宿舍的电脑跑一下&#xff0c;在测试member表相关接口时就出错了。报了SQL语法错误&#xff0c;但SQL语句很简单&#xff0c;就根据手机号查询不至于出…
阅读更多...
Redux与React环境准备、实现counter（及传参）、异步获取数据

Redux与React环境准备、实现counter（及传参）、异步获取数据

环境说明&#xff1a; 一&#xff1a;说明 在React中使用redux&#xff0c;官方要求安装两个其他插件&#xff1a;Redux Toolkit和react-redux 1. Redux ToolKit(RTK) - 官方推荐编写Redux逻辑的方式&#xff0c;是一套工具的集合集&#xff0c;简化书写方式 &#xff08;简化…
阅读更多...
【ps】新手 学 PS一本通

【ps】新手 学 PS一本通

第一章 添加图像边框 1. 导入一张图片 2.选择 图像-画布大小 例&#xff1a;原图&#xff1a;720x820 填写画布大小&#xff1a;820x920 可以增加一个100x100的边框。 画布扩展颜色是扩展的颜色。 标尺工具 视图>标尺 或者使用 CTRL R 网格工具 视图-显示-网格 …
阅读更多...
JavaOOP篇----第十五篇

JavaOOP篇----第十五篇

系列文章目录 文章目录 系列文章目录前言一、有没有可能两个不相等的对象有相同的hashcode二、拷贝和浅拷贝的区别是什么?三、static都有哪些用法?前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站，这篇文章男女通…
阅读更多...
【BBuf的CUDA笔记】十，Linear Attention的cuda kernel实现解析

【BBuf的CUDA笔记】十，Linear Attention的cuda kernel实现解析

欢迎来 https://github.com/BBuf/how-to-optim-algorithm-in-cuda 踩一踩。 0x0. 问题引入 Linear Attention的论文如下&#xff1a; Transformers are RNNs: Fast Autoregressive Transformers with Linear Attention&#xff1a;https://arxiv.org/pdf/2006.16236.pdf 。官方…
阅读更多...
【docker】安装mysql

【docker】安装mysql

查看可用的 mysql版本 docker search mysql拉取 MySQL最新镜像 docker pull mysql:latest 查看镜像 docker images 运行容器 docker run -it -d --name mysql-demo -m 500m -p 3309:3306 -v /test1/mysql/data:/var/lib/mysql -v /test1/mysql/config:/etc/mysql/conf.d -…
阅读更多...
最新文章

Copyright @ 2022~2023