C语言中socket模块、线程

socket编程

windows下TCP协议

测试环境基于Win10 x64，Visual Studio

服务端代码1. 初始化Winsock库；2. 创建套接字；3. 配置服务端地址；4. 绑定套接字；5. 监听连接；6. 接收连接；7. 发送数据给客户端；8. 关闭连接。

#define _CRT_SECURE_NO_WARNINGS 1
#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>
#include <Winsock2.h>#pragma comment(lib, "ws2_32.lib")		// 因为用到了Winsock库，所以需要引入这个lib文件int main()
{// 初始化Winsock库WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)			// 初始化Winsock库，保证正确加载和卸载库{printf("初始化Winsock失败\n");return 0;}// 创建套接字SOCKET serverSocket = socket(AF_INET, SOCK_STREAM, 0);	// 0代表默认协议if (serverSocket == INVALID_SOCKET){printf("创建套接字失败\n");WSACleanup();return 0;}// 配置服务端地址struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = INADDR_ANY;				// INADDR_ANY为通配地址，0.0.0.0serverAddr.sin_port = htons(8080);// 绑定套接字if (bind(serverSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR){printf("绑定失败\n");closesocket(serverSocket);WSACleanup();return 0;}// 监听连接if (listen(serverSocket, 10) == SOCKET_ERROR){printf("监听失败\n");closesocket(serverSocket);WSACleanup();return 1;}// 接收连接SOCKET clientSocket = accept(serverSocket, NULL, NULL);if (clientSocket == INVALID_SOCKET){printf("连接失败\n");closesocket(serverSocket);WSACleanup();}printf("连接已建立\n");// 发送数据给客户端const char* message = "Hello, I'm Server!";send(clientSocket, message, (int)strlen(message), 0);// 关闭套接字closesocket(clientSocket);closesocket(serverSocket);WSACleanup();return 1;
}

客户端代码1. 初始化Winsock库；2. 创建套接字；3. 配置服务端地址；4. 连接到服务器；5. 发送数据；6. 接收服务端返回数据；7. 关闭套接字。

#define _CRT_SECURE_NO_WARNINGS 1
#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>
#include <Winsock2.h>#pragma comment(lib, "ws2_32.lib")		// 因为用到了Winsock库，所以需要引入这个lib文件int main()
{// 初始化Winsock库WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {printf("初始化Winsock失败\n");return 1;}// 创建套接字SOCKET clientSocket = socket(AF_INET, SOCK_STREAM, 0);if (clientSocket == INVALID_SOCKET) {printf("创建套接字失败\n");WSACleanup();return 1;}// 配置服务端地址struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); // 服务端IP地址serverAddr.sin_port = htons(8080); // 服务端端口号// 连接到服务端if (connect(clientSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {printf("连接失败\n");closesocket(clientSocket);WSACleanup();return 1;}// 发送数据printf("已成功连接至服务器\n");// 接收服务端发送的数据char buffer[1024];int bytesRead = recv(clientSocket, buffer, sizeof(buffer), 0);if (bytesRead > 0) {buffer[bytesRead] = '\0';printf("服务器: %s\n", buffer);}// 关闭套接字closesocket(clientSocket);WSACleanup();return 1;
}

windows下UDP协议

服务端1. 初始化Winsock库；2. 创建套接字；3. 配置服务端地址；4. 绑定套接字；5. 接收数据；6. 返回数据给客户端；7. 关闭套接字。

#define _CRT_SECURE_NO_WARNINGS 1
#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>
#include <Winsock2.h>#pragma comment(lib, "ws2_32.lib")		// 因为用到了Winsock库，所以需要引入这个lib文件int main()
{// 初始化Winsock库WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)			// 初始化Winsock库，保证正确加载和卸载库{printf("初始化Winsock失败\n");return 0;}// 创建套接字SOCKET serverSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);if (serverSocket == INVALID_SOCKET){printf("创建套接字失败\n");WSACleanup();return 0;}// 配置服务端地址struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = INADDR_ANY;				// INADDR_ANY为通配地址，0.0.0.0serverAddr.sin_port = htons(8080);// 绑定套接字if (bind(serverSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR){printf("绑定失败\n");closesocket(serverSocket);WSACleanup();return 0;}// 接收数据char buffer[1024];struct sockaddr_in clientAddr;int clientAddrSize = sizeof(clientAddr);int bytesRead = recvfrom(serverSocket, buffer, sizeof(buffer), 0, (struct sockaddr*)&clientAddr, &clientAddrSize);if (bytesRead > 0){buffer[bytesRead] = '\0';printf("客户端： %s\n", buffer);// 发送数据给客户端const char* message = "Hello from server!";sendto(serverSocket, message, (int)strlen(message), 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr));}// 关闭套接字closesocket(serverSocket);WSACleanup();return 1;
}

客户端1. 初始化Winsock库；2. 创建套接字；3. 配置服务端地址；4. 发送数据给服务端；5. 接收服务端发送的数据；6. 关闭套接字。

#define _CRT_SECURE_NO_WARNINGS 1
#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>
#include <Winsock2.h>#pragma comment(lib, "ws2_32.lib")		// 因为用到了Winsock库，所以需要引入这个lib文件int main()
{// 初始化Winsock库WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {printf("初始化Winsock失败\n");return 1;}// 创建套接字SOCKET clientSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);if (clientSocket == INVALID_SOCKET) {printf("创建套接字失败\n");WSACleanup();return 1;}// 配置服务端地址struct sockaddr_in serverAddr;serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); // 服务端IP地址// serverAddr.sin_addr.s_addr = INADDR_BROADCAST;  // 如果给其他主机发消息，用这个serverAddr.sin_port = htons(8080); // 服务端端口号，这里最好只用htons，因为它针对16位的主机字节，端口一般都是16位// 发送数据给服务端const char* message = "服务端你好，我是客户端！\n";sendto(clientSocket, message, strlen(message), 0, (struct sockaddr*)&serverAddr, sizeof(serverAddr));// 接收服务端发送的数据char buffer[1024];struct sockaddr_in fromAddr;int fromAddrSize = sizeof(fromAddr);int bytesRead = recvfrom(clientSocket, buffer, sizeof(buffer), 0, (struct sockaddr*)&fromAddr, &fromAddrSize);if (bytesRead > 0) {buffer[bytesRead] = '\0';printf("服务器: %s\n", buffer);}// 关闭套接字closesocket(clientSocket);WSACleanup();return 1;}

贴一个自己项目当中用到的实例，该代码是用来和另一台主机通信的，通信要求如下1. 目标设备接收数据的端口是65001；2. 目标设备接收到数据后会有返回；3. 目标设备只接收18个字节的数据包；4. 目标设备只接收从65000端口发的数据，并且后续返回的数据也会返回到65000端口

#define _WINSOCK_DEPRECATED_NO_WARNINGS#include <stdio.h>
#include <winsock2.h>#pragma comment(lib, "ws2_32.lib") // 链接到Winsock库
#define ENTER_CODE 0xEB90149Fint main() {WSADATA wsaData;SOCKET udpSocket;// 初始化Winsockif (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) {printf("初始化 Winsock 失败.\n");return -1;}// 创建UDP套接字udpSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);if (udpSocket == INVALID_SOCKET) {printf("创建 socket 失败 : %d\n", WSAGetLastError());WSACleanup();return -1;}// 设置广播int on = 1;setsockopt(udpSocket, SOL_SOCKET, SO_BROADCAST, (char*)&on, sizeof(on));// 设置本地地址struct sockaddr_in localaddr;memset((char*)&localaddr, 0, sizeof(localaddr));localaddr.sin_family = AF_INET;localaddr.sin_port = htons(65000);localaddr.sin_addr.s_addr = inet_addr("192.168.10.1");// 将套接字绑定到本地地址if (bind(udpSocket, (struct sockaddr*)&localaddr, sizeof(localaddr)) == SOCKET_ERROR) {printf("绑定失败， error code : %d\n", WSAGetLastError());}// 设置服务器地址struct sockaddr_in serverAddr;int serverAddrSize = sizeof(serverAddr);memset((char*)&serverAddr, 0, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_addr.s_addr = INADDR_BROADCAST;serverAddr.sin_port = htons(65001);// 将数据填充到buff中，注意网络字节序的转换unsigned char send_buff[200] = {0x00};int a = ENTER_CODE;memcpy(send_buff, &a, 4);// 为数据接收做准备unsigned char recv_buff[1072];struct sockaddr_in clientAddr;int clientAddrSize = sizeof(clientAddr);int recvSize;memset(recv_buff, 0, sizeof(recv_buff));while (1){// 发送数据sendto(udpSocket, (char*)send_buff, 18, 0, (struct sockaddr*)&serverAddr, serverAddrSize);if (sendto(udpSocket, (char *)send_buff, 18, 0, (struct sockaddr*)&serverAddr, serverAddrSize) == SOCKET_ERROR) {printf("数据发送失败， error code : %d\n", WSAGetLastError());}else { printf("发送成功 "); }for (int i = 0; i < 10; i++){printf(" %02X ", send_buff[i]);}printf("\n");Sleep(500);recvSize = recvfrom(udpSocket, (char*)recv_buff, sizeof(recv_buff), 0, (struct sockaddr*)&clientAddr, &clientAddrSize);if (recvSize == SOCKET_ERROR) {printf("接收数据失败， error code : %d\n", WSAGetLastError());}else if (recvSize > 0) {printf("接收到的数据: ");for (int i = 0; i < recvSize; i++) {printf("%02X ", recv_buff[i]);}printf("\n");}}// 清理closesocket(udpSocket);WSACleanup();return 0;
}

进程和线程

Windows下多线程

#define _CRT_SECURE_NO_WARNINGS 1#include <stdio.h>
#include <windows.h>
#include <time.h>DWORD WINAPI threadFunction(LPVOID lpParam)
{int flag = 0;while (1){printf("线程功能\n");if (flag > 10) { break; }else { flag += 1; }Sleep(100);}return 0;
}DWORD WINAPI threadFunction2(LPVOID lpParam)
{int flag = 0;while (1){printf("线程功能2222222\n");if (flag > 15) { break; }else { flag += 1; }Sleep(100);}return 0;
}int main()
{HANDLE t1;				// 创建句柄HANDLE t2;				// 创建句柄/*LPVOID pParam1;			// 参数指针LPVOID pParam2;			// 参数指针*/// 创建线程t1 = CreateThread(NULL,				// 默认安全性,在大多数情况下，这个参数设置为NULL0,					// 指定线程的堆栈大小,如果这个参数设为0，那么系统会为新线程分配默认的堆栈大小threadFunction,		// 是一个函数指针，指向线程要执行的代码NULL,				// 线程函数的参数0,					// 指定如何创建线程,这个参数被设置为0，这意味着线程将立即开始执行NULL				// 这个参数是一个输出参数，它接收新线程的ID);// 创建线程2t2 = CreateThread(NULL,				// 默认安全性,在大多数情况下，这个参数设置为NULL0,					// 指定线程的堆栈大小,如果这个参数设为0，那么系统会为新线程分配默认的堆栈大小threadFunction2,	// 是一个函数指针，指向线程要执行的代码NULL,				// 线程函数的参数0,					// 指定如何创建线程,这个参数被设置为0，这意味着线程将立即开始执行NULL				// 这个参数是一个输出参数，它接收新线程的ID);if (t1 == NULL | t2 == NULL){printf(stderr, "线程创建失败\n");return 0;}// 等待线程结束WaitForSingleObject(t1, INFINITE);WaitForSingleObject(t2, INFINITE);// 关闭线程句柄CloseHandle(t1);CloseHandle(t2);return 1;
}

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

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

相关文章

使用global mapper将分块DSM/DOM合并导出

使用global mapper将分块DSM/DOM合并导出

使用global mapper将分块DSM/DOM合并导出 使用context capture生产dom/dsm时通常因为内存问题而选择分块生产&#xff0c;那么得到的dsm/dom则是一块一块的&#xff0c;如下&#xff1a; 那么为了合并成一张影像&#xff0c;可以使用强大的地图软件 Global Mapper&#xff0c…
阅读更多...
番外篇-区块链基础知识入门

番外篇-区块链基础知识入门

今天聊聊番外篇之Web3、区块链的基础知识~ 1. 区块链是如何工作的&#xff1f; Hash算法 将输入的数据映射为一个固定长度的字符串字符串是64长度&#xff0c;16进制&#xff08;2^4&#xff09;&#xff0c;4 * 64 256【SHA256】hash演示&#xff1a;https://andersbrownwo…
阅读更多...
android 9 reboot流程

android 9 reboot流程

机器出现开机 自动进入fastboot模式。可能是init 那个进程挂了 然后调用了 RebootSystem(ANDROID_RB_RESTART2, “bootloader”); 函数进入重启流程&#xff0c;然后重启后进入fastboot 浅读一下reboot流程和怎么进入的fastboot 比如说是那个进程挂了调用了这个函数&#xff0c…
阅读更多...
实现目标检测中的数据格式自由（labelme json、voc、coco、yolo格式的相互转换）

实现目标检测中的数据格式自由（labelme json、voc、coco、yolo格式的相互转换）

在进行目标检测任务中&#xff0c;存在labelme json、voc、coco、yolo等格式。labelme json是由anylabeling、labelme等软件生成的标注格式、voc是通用目标检测框&#xff08;mmdetection、paddledetection&#xff09;所支持的格式&#xff0c;coco是通用目标检测框&#xff0…
阅读更多...
cosmos及特定应用程序的区块链

cosmos及特定应用程序的区块链

特定应用程序的区块链,简单来说&#xff0c;一个区块链就是一个专门的应用程序。为了实现某一特定的去中心化应用而专门实现一个区块链。 传统的用智能合约构建去中心化应用不行吗&#xff1f; 灵活性不足&#xff1a;智能合约本质上受到虚拟机本身的限制。例如&#xff0c;以…
阅读更多...
BLHeli_S 代码分析---BLHeli.asm头部声明文件分析

BLHeli_S 代码分析---BLHeli.asm头部声明文件分析

BLHeli_S 代码之 A.inc 分析 指令含义及作用 $NOMOD51使编译器不使能预定义的8051符号&#xff0c;避免产生重复定义的错误 示例代码1 IF BESCNO XP_3A_Main MODE EQU 0 ; Choose mode. Set to 0 for main motor $include (XP_3A.inc) ; Select XP 3A pinout ENDIF…
阅读更多...
【Spring Boot】SpringBoot maven 项目创建图文教程

【Spring Boot】SpringBoot maven 项目创建图文教程

创建一个Spring Boot项目并使用Maven进行构建是一项相对简单的任务。以下是使用IntelliJ IDEA创建Spring Boot Maven项目的详细教程&#xff1a; 步骤 1&#xff1a;安装 IntelliJ IDEA 确保你已经安装了最新版本的 IntelliJ IDEA。你可以从官方网站下载并安装。 步骤 2&am…
阅读更多...
基于SpringBoot+Redis的前后端分离外卖项目-苍穹外卖微信小程序端(十一)

基于SpringBoot+Redis的前后端分离外卖项目-苍穹外卖微信小程序端(十一)

加入redis缓存 1. 缓存菜品1.1 问题说明1.2 实现思路1.3 代码开发1.4 功能测试 2. 缓存套餐2.1 Spring Cache2.1.1 介绍2.1.2 常用注解2.1.3 入门案例 2.2 具体实现思路2.3 代码开发 1. 缓存菜品 1.1 问题说明 用户端小程序展示的菜品数据都是通过查询数据库获得&#xff0c;…
阅读更多...
Spring学习之——代理模式

Spring学习之——代理模式

Proxy代理模式 介绍 为其他对象提供一种代理以控制对这个对象的访问。在某些情况下&#xff0c;一个对象不适合或者不能直接引用另一个对象&#xff0c;而代理对象可以在客户端和目标对象之间起到中介的作用 2. 组成 抽象角色&#xff1a;通过接口或抽象类声明真实角色实现的…
阅读更多...
cfa一级考生复习经验分享系列（十九）

cfa一级考生复习经验分享系列（十九）

关于考试时间 机考一共180题&#xff0c;分上下两场&#xff0c;中间可以休息30分钟&#xff0c;我是直接一口气做完的&#xff0c;如果觉得要休息的可以考完上半场跟监考老师示意一下&#xff0c;也可以不休息&#xff0c;不过好像连续做了多长时间会强制休息。 关于考题分布…
阅读更多...
MySQL一主一从读写分离

MySQL一主一从读写分离

​ MySQL主从复制 一、主从复制概念 主从复制是指将主数据库的DDL和DML操作通过二进制日志传到从服务器中&#xff0c;然后在从服务器上对这些日志重新执行也叫重做&#xff0c;从而使得从数据库和主库的数据保持同步。 MySQL支持一台主库同时向多台从库进行赋值&#xff0c;从…
阅读更多...
20240110-Python实现读取当前文件夹下所有视频名称和时长并生成一张表

20240110-Python实现读取当前文件夹下所有视频名称和时长并生成一张表

代码 import os import cv2 import csv# 获取当前文件夹路径 folder_path os.getcwd() # 如果当前文件夹就是目标文件夹可以直接使用 ./&#xff0c;否则修改为目标文件夹的路径# 获取当前文件夹中所有视频文件的名称 video_files [f for f in os.listdir(folder_path) if …
阅读更多...
腾讯云对象存储COS计算文件的大小

腾讯云对象存储COS计算文件的大小

properties配置类 TencentCos.APPIDxxxxx TencentCos.SecretIdxxxxxxx TencentCos.SecretKeyxxxxxx TencentCos.testBucketxxxxxx TencentCos.CosPathhttps://xxxxxxxx.cos.ap-chengdu.myqcloud.com TencentCos.regionap-chengdu读取properties中的配置 import lombok.AllArg…
阅读更多...
响应式编程Reactor优化Callback回调地狱

响应式编程Reactor优化Callback回调地狱

1. Reactor是什么 Reactor 是一个基于Reactive Streams规范的响应式编程框架。它提供了一组用于构建异步、事件驱动、响应式应用程序的工具和库。Reactor 的核心是 Flux&#xff08;表示一个包含零到多个元素的异步序列&#xff09;和 Mono表示一个包含零或一个元素的异步序列…
阅读更多...
kubeSphere DevOps自定义容器环境JDK11

kubeSphere DevOps自定义容器环境JDK11

kubeSphere DevOps自定义容器环境JDK11 &#x1f342;前言&#x1f342;增加JDK11容器环境&#x1f341;检查是否成功 &#x1f342;不生效的原因排查&#x1f341;按步骤执行如下命令 &#x1f342;前言 kubeSphere 版本v3.1.1 遇到问题:kubeSphere默认支持容器只有JDK8,目前…
阅读更多...
Ubuntu22.04，Nvidia4070配置llama2

Ubuntu22.04，Nvidia4070配置llama2

大部分内容参考了这篇非常详细的博客&#xff0c;是我最近看到的为数不多的保姆级别的教学博客&#xff0c;建议大家去给博主点个赞【Ubuntu 20.04安装和深度学习环境搭建 4090显卡】_ubuntu20.04安装40系显卡驱动-CSDN博客 本篇主要是基于这篇博客结合自己配置的过程中一些注…
阅读更多...
DC电源模块技术的未来发展趋势

DC电源模块技术的未来发展趋势

BOSHIDA DC电源模块技术的未来发展趋势 随着科技的不断发展&#xff0c;DC电源模块技术也在不断演进。以下是DC电源模块技术未来发展的一些趋势&#xff1a; 1. 高效能&#xff1a;未来DC电源模块的效能将得到进一步提高。通过改进转换拓扑结构、优化控制算法和使用高效能元器…
阅读更多...
Kafka 除了用作消息队列还能干吗？

Kafka 除了用作消息队列还能干吗？

Kafka 除了用作消息队列还能干吗&#xff1f; 本文转自 公众号 ByteByteGo&#xff0c;如有侵权&#xff0c;请联系&#xff0c;立即删除 Kafka 最初是为大规模处理日志而构建的。它可以保留消息直到过期&#xff0c;并让各个消费者按照自己的节奏提取消息。 与其之前的竞品不…
阅读更多...
CPT203-Software Engineering 笔记

CPT203-Software Engineering 笔记

Week 1 -- Introduction failure reason professional software development*** maintain, security, efficiency, acceptability two kinds***: generic, customized software deterioration 软件退化 reduce changes/ side effects after changes software engineering …
阅读更多...
01.10

01.10

257.二叉树的所有路径 思路 一开始题目看错&#xff0c;以为是二叉树根到每个节点的路径&#xff0c;后来改正是到每个叶子节点路径。 深度优先搜索&#xff1a;二叉树所有路径&#xff0c;那么只需遍历其左右子树的路径列表&#xff0c;然后再将该节点的值放入路径即可。如…
阅读更多...
最新文章

Copyright @ 2022~2023