<winsock>重叠IO模型
基于事件判断io完成
send程序
#include <stdio.h>
#include <winsock2.h>#pragma comment(lib, "Ws2_32.lib")
#pragma warning(disable : 4996)int main()
{WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0){printf("WSAStartup 失败\n");system("pause");return 1;}// 创建 重叠模型的套接字SOCKET HSocket = WSASocket(PF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);if (HSocket == INVALID_SOCKET){printf("WSASocket 失败\n");WSACleanup();system("pause");return -1;}//和往常一样创建客户端连接sockaddr_in SendAddr;memset(&SendAddr, 0, sizeof(SendAddr));SendAddr.sin_family = AF_INET;SendAddr.sin_port = htons(4567); // 服务器端口SendAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); // 服务器 IP本地还回地址if (connect(HSocket, (LPSOCKADDR)&SendAddr, sizeof(SendAddr)) == SOCKET_ERROR){printf("WSASocket 失败\n");WSACleanup();system("pause");return -1;}//创建一个初始无信号手动重置的事件对象WSAEVENT evobj = WSACreateEvent();//创建一个WSAOVERLAPPED 结构体变量WSAOVERLAPPED overlapped;memset(&overlapped, 0, sizeof(overlapped));overlapped.hEvent = evobj;//保存待传输的数据大小 和数据存储的地址WSABUF dataBuf;char msg[] = "网络编程";dataBuf.buf = msg;dataBuf.len = strlen(msg) + 1;//保存实际发送字节数DWORD sendedBytes = 0;//开始传输数据//如果不返回SOCKET_ERROR,说明数据已经传输完成了if (WSASend(HSocket, &dataBuf, 1, &sendedBytes, 0, &overlapped, NULL) == SOCKET_ERROR){ //判断错误码是不是WSA_IO_PENDING,说明数据没有传输完成if (WSAGetLastError() == WSA_IO_PENDING){puts("正在后台传输数据中");//永久等待 一个事件WSAWaitForMultipleEvents(1, &evobj, TRUE, WSA_INFINITE, FALSE);//事件有信号了,用这个函数获得io处理的结果.如果fwait设置为true,将等待io的完成,函数阻塞;如果设置为false并且调用时io的未完成 ,函数立即返回falseBOOL isok= WSAGetOverlappedResult(HSocket, &overlapped, &sendedBytes, FALSE, NULL);if(!isok){printf("WSAGetOverlappedResult 失败 %d\n",WSAGetLastError());}}else{printf("WSASend 失败 %d\n", WSAGetLastError());}}printf("发送了%d 个字节\n", sendedBytes);WSACloseEvent(evobj);closesocket(HSocket);WSACleanup();return 0;
}
recvicer程序
#include <stdio.h>
#include <winsock2.h>
#pragma comment(lib, "Ws2_32.lib")
#pragma warning(disable : 4996)
#define BUFFER_SIZE 1024
int main(int argc, char* argv[])
{WSADATA initsock;if (WSAStartup(MAKEWORD(2, 2), &initsock) != 0){printf("WSAStartup失败 ");return -1;}//创建重叠模型套接字SOCKET s = WSASocket(PF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);if (s == INVALID_SOCKET){printf("socket失败");return -1;}
#pragma region 经典起手式 设置端口和ip 并绑定服务器套接字,进入监听,并允许连接//设置ip和端口sockaddr_in servAddr;servAddr.sin_family = AF_INET;servAddr.sin_port = htons(4567);servAddr.sin_addr.S_un.S_addr = INADDR_ANY;//绑定套接字if (bind(s, (LPSOCKADDR)&servAddr, sizeof(servAddr)) == SOCKET_ERROR){printf("bind失败");closesocket(s);WSACleanup();return -1;}//进入监听if (listen(s, 5) == SOCKET_ERROR){printf("listen失败%d\n",WSAGetLastError());closesocket(s);WSACleanup();return -1;}sockaddr_in clintAddr;int lenOfclintAddr= sizeof(clintAddr);SOCKET hClintSock = accept(s, (LPSOCKADDR)&clintAddr, &lenOfclintAddr);if (hClintSock == INVALID_SOCKET){printf("accept失败%d\n", WSAGetLastError());closesocket(s);WSACleanup();return -1;}
#pragma endregion//创建手动重置初始无信号的事件对象,将地址保存到OVERLAPPED结构变量中WSAEVENT evObj = WSACreateEvent();OVERLAPPED overlapped;memset(&overlapped, 0, sizeof(overlapped));overlapped.hEvent = evObj;//保存数据的缓冲区WSABUF dataBuf;char buf[BUFFER_SIZE] = { 0 };dataBuf.len = BUFFER_SIZE;dataBuf.buf = buf;//WSARecv函数返回时,接收的数据字节数DWORD recvBytes = 0;//传输特性 DWORD flags = 0;if (WSARecv(hClintSock, &dataBuf, 1, &recvBytes, &flags, &overlapped, NULL) == SOCKET_ERROR){if (WSAGetLastError() == WSA_IO_PENDING){puts("后台接收数据中");WSAWaitForMultipleEvents(1, &evObj, true, WSA_INFINITE, false);WSAGetOverlappedResult(hClintSock, &overlapped, &recvBytes, FALSE, NULL);}else{printf("WSARecv失败%d\n", WSAGetLastError());WSACloseEvent(evObj);closesocket(s);WSACleanup();return -1;}}printf("接收到消息:%s\n", buf);WSACloseEvent(evObj);closesocket(s);WSACleanup();return 0;
}
基于apc的回调函数通知io完成 的recvicer
#include <stdio.h>
#include <winsock2.h>
#pragma comment(lib, "Ws2_32.lib")
#pragma warning(disable : 4996)
#define BUFFER_SIZE 1024
//WSARecv函数返回时,接收的数据字节数
DWORD g_recvBytes = 0;
char g_buf[BUFFER_SIZE];
void CompRoutine(IN DWORD dwError,IN DWORD cbTransferred,IN LPWSAOVERLAPPED lpOverlapped,IN DWORD dwFlags
);
int main(int argc, char* argv[])
{WSADATA initsock;if (WSAStartup(MAKEWORD(2, 2), &initsock) != 0){printf("WSAStartup失败 ");system("pause");return -1;}//创建重叠模型套接字SOCKET s = WSASocket(PF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);if (s == INVALID_SOCKET){printf("socket失败");system("pause");return -1;}
#pragma region 经典起手式 设置端口和ip 并绑定服务器套接字,进入监听,并允许连接//设置ip和端口sockaddr_in servAddr;servAddr.sin_family = AF_INET;servAddr.sin_port = htons(4567);servAddr.sin_addr.S_un.S_addr = INADDR_ANY;//绑定套接字if (bind(s, (LPSOCKADDR)&servAddr, sizeof(servAddr)) == SOCKET_ERROR){printf("bind失败");closesocket(s);WSACleanup();system("pause");return -1;}//进入监听if (listen(s, 5) == SOCKET_ERROR){printf("listen失败%d\n", WSAGetLastError());closesocket(s);WSACleanup();system("pause");return -1;}sockaddr_in clintAddr;int lenOfclintAddr = sizeof(clintAddr);SOCKET hClintSock = accept(s, (LPSOCKADDR)&clintAddr, &lenOfclintAddr);if (hClintSock == INVALID_SOCKET){printf("accept失败%d\n", WSAGetLastError());closesocket(s);WSACleanup();system("pause");return -1;}
#pragma endregion//这个事件只是为了让当前线程进入可警报状态WSAEVENT evObj = WSACreateEvent();OVERLAPPED overlapped;memset(&overlapped, 0, sizeof(overlapped));//保存数据的缓冲区WSABUF dataBuf;dataBuf.len = BUFFER_SIZE;dataBuf.buf = g_buf;//传输特性 DWORD flags = 0;if (WSARecv(hClintSock, &dataBuf, 1, &g_recvBytes, &flags, &overlapped,(LPWSAOVERLAPPED_COMPLETION_ROUTINE)CompRoutine) == SOCKET_ERROR){if (WSAGetLastError() == WSA_IO_PENDING){puts("后台接收数据中");}}//只是为了假装自己进入了等待状态,,,,,APC函数将唤醒 这个线程//因为我在等待/*DWORD ret=WSAWaitForMultipleEvents(1, &evObj, FALSE, WSA_INFINITE, TRUE);if (ret == WAIT_IO_COMPLETION){printf("io传输已完成");}*/DWORD ret = SleepEx(INFINITE, TRUE);if (ret == WAIT_IO_COMPLETION){printf("io传输已完成");}WSACloseEvent(evObj);closesocket(s);WSACleanup();system("pause");return 0;
}
//本程序 将会由于调用约定错误 而引发c0005异常
// vs中设置的调用约定默认为 __cdecl (/Gd)
void CompRoutine(IN DWORD dwError,IN DWORD cbTransferred,IN LPWSAOVERLAPPED lpOverlapped,IN DWORD dwFlags
)
{if (dwError!=0){printf("完成回调函数失败\n");}else{g_recvBytes = cbTransferred;printf("接收到的消息:%s",g_buf);}
}
相关文章:
<winsock>重叠IO模型
基于事件判断io完成 send程序 #include <stdio.h> #include <winsock2.h>#pragma comment(lib, "Ws2_32.lib") #pragma warning(disable : 4996)int main() {WSADATA wsaData;if (WSAStartup(MAKEWORD(2, 2), &wsaData) ! 0){printf("WSAStart…...
Android Tools | 如何使用Draw.io助力Android开发:从UI设计到流程优化
Android Tools | 如何使用Draw.io助力Android开发:从UI设计到流程优化 1. 引言 在Android开发中,视觉化设计与流程管理至关重要。虽然开发工具如Android Studio强大,但它并不适用于所有设计场景。Draw.io是一款免费的在线绘图工具ÿ…...
Java 每日一刊(第5期):变量守护者
前言 这里是分享 Java 相关内容的专刊,每日一更。 本期将为大家带来以下内容: 量子数据宇宙的变量守护者第一章:能源错配与基本数据类型第二章:引用类型与通讯网络的崩溃第三章:作用域冲突与系统崩溃终章࿱…...
【C++二分查找】2517. 礼盒的最大甜蜜度
本文涉及的基础知识点 C二分查找 贪心(决策包容性) LeetCode 2517. 礼盒的最大甜蜜度 给你一个正整数数组 price ,其中 price[i] 表示第 i 类糖果的价格,另给你一个正整数 k 。 商店组合 k 类 不同 糖果打包成礼盒出售。礼盒的 甜蜜度 是礼…...
【详解】数据库E-R图——医院计算机管理系统
题目 某医院病房计算机管理中需要如下信息: 科室:科室名,科室地址,科室电话,医生姓名 病房:病房号,床位号,所属科室名 医生:工作证号,姓名,性别&a…...
分类预测|基于改进的灰狼IGWO优化支持向量机SVM的数据分类预测matlab程序 改进策略:Cat混沌与高斯变异
分类预测|基于改进的灰狼IGWO优化支持向量机SVM的数据分类预测matlab程序 改进策略:Cat混沌与高斯变异 文章目录 一、基本原理原理流程1. **定义目标函数**2. **初始化GWO**3. **评估适应度**4. **更新狼的位置**5. **更新狼的等级**6. **重复迭代**7. **选择最佳解…...
圆锥曲线练习
设 A ( x 1 , y 1 ) , B ( x 2 , y 2 ) A\left( x_{1}, y_{1} \right), B\left( x_{2}, y_{2} \right) A(x1,y1),B(x2,y2) l : y k ( x 2 ) l: y k\left( x2 \right) l:yk(x2) 显然 y 0 y0 y0符合题意 当 k ≠ 0 k\neq 0 k0 联立 l l l和 C C C ( k 2 1 2 ) x…...
STM32时钟树
1 什么是时钟 2 时钟数简图...
NX—UI界面生成的文件在VS上的设置
UI界面保存生成的三个文件 打开VS创建项目,删除自动生成的cpp文件,将生成的hpp和cpp文件拷贝到项目的目录下,并且在VS项目中添加现有项目。 修改VS的输出路径,项目右键选择属性,链接器中的常规,文件路径D:…...
Wine容器内程序执行sh脚本问题研究
问题背景 wpf程序在wine环境执行sh脚本,不能等待脚本执行完成自动退出的问题进行了研究,需求很简单,在wpf程序使用cmd,或者bat ,又或者是直接执行sh脚本,想到脚本执行完成才处理后面的逻辑。但是实际验证过…...
《深度学习》OpenCV轮廓检测 模版匹配 解析及实现
目录 一、模型匹配 1、什么是模型匹配 2、步骤 1)提取模型的特征 2)在图像中查找特征点 3)进行特征匹配 4)模型匹配 3、参数及用法 1、用法 2、参数 1)image:待搜索对象 2)templ&am…...
Java XML
1、XML文件介绍 配置文件:用来保存设置的一些东西。 拿IDEA来举例,比如设置的背景图片,字体信息,字号信息和主题信息等等。 (1)以前是用txt保存的,没有任何优点,而且不利于阅读&a…...
好用的视频压缩工具有哪些?这4款千万不要错过
视频压缩的方法有很多种,像我们手机里的视频剪辑工具,手机和电脑自带的压缩功能,在线压缩网站,专业压缩软件压缩等等。不同的场景和需求下大家可以选择不同的工具,但是如果碰到需要大量和经常压缩视频的话,…...
【Python爬虫系列】_016.关于登录和验证码
我 的 个 人 主 页:👉👉 失心疯的个人主页 👈👈 入 门 教 程 推 荐 :👉👉 Python零基础入门教程合集 👈👈 虚 拟 环 境 搭 建 :👉&…...
基于opencv实现双目立体匹配点云距离
双目相机或两个单目相机。 一、相机标定 MATLAB软件,打开双目标定app。 点击add images,弹出加载图像的窗口,分别导入左图和右图,设置黑白格长度(标定板的长度一般为20)。 点击确定,弹出加载…...
RabbitMQ高级篇,进阶内容
强烈建议在看本篇博客之前快速浏览文章:RabbitMQ基础有这一篇就够了 RabbitMQ高级篇 0. 前言1. 发送者的可靠性1.1 生产者重试机制1.2 生产者确认机制1.3 实现生产者确认 2. MQ的可靠性2.1 MQ持久化2.2 LazyQueue 3. 消费者的可靠性3.1 消费者确认机制3.2 失败重试策…...
STM32重定义printf,实现串口打印
在“usart.c”文件中加入以下代码 #ifdef __GNUC__#define PUTCHAR_PROTOTYPE int __io_putchar(int ch) #else#define PUTCHAR_PROTOTYPE int fputc(int ch, FILE *f) #endifPUTCHAR_PROTOTYPE{HAL_UART_Transmit(&huart1 , (uint8_t *)&ch, 1, 0xFFFF);return ch; }…...
项目进度
变为负进度了,还是要用baseservlet,我就又重新写了一部分,看了好几遍视频,突然就想明白了,感觉每次要上课,就时间不连续思路总是断,今天晚自习算是搞懂了怎么写了,就是代码有点多&am…...
Android的内核
Android的内核是基于Linux的长期支持版本的“Android通用内核(ACK)”。 Android作为一个广泛使用的操作系统,其根基在于内核的设计和功能。下面将深入探讨Android内核的各个方面,从其基本结构到与Linux内核的关系,再到内核的版本管理及在设备…...
Github Wiki 超链接 转 码云Gitee Wiki 超链接
Github Wiki 超链接 转 码云Gitee Wiki 超链接 Github 是 :[[相对路径]] Gitee 是 :[链接文字](./相对路径) 查找:\[\[(.*?)\]\] 替换:[$1]\(./$1\) 或替换:**[$1]\(./$1\)** (码云的超链接,很…...
【第二十一章 SDIO接口(SDIO)】
第二十一章 SDIO接口 目录 第二十一章 SDIO接口(SDIO) 1 SDIO 主要功能 2 SDIO 总线拓扑 3 SDIO 功能描述 3.1 SDIO 适配器 3.2 SDIOAHB 接口 4 卡功能描述 4.1 卡识别模式 4.2 卡复位 4.3 操作电压范围确认 4.4 卡识别过程 4.5 写数据块 4.6 读数据块 4.7 数据流…...
macOS多出来了:Google云端硬盘、YouTube、表格、幻灯片、Gmail、Google文档等应用
文章目录 问题现象问题原因解决办法 问题现象 macOS启动台(Launchpad)多出来了:Google云端硬盘、YouTube、表格、幻灯片、Gmail、Google文档等应用。 问题原因 很明显,都是Google家的办公全家桶。这些应用并不是通过独立安装的…...
【项目实战】通过多模态+LangGraph实现PPT生成助手
PPT自动生成系统 基于LangGraph的PPT自动生成系统,可以将Markdown文档自动转换为PPT演示文稿。 功能特点 Markdown解析:自动解析Markdown文档结构PPT模板分析:分析PPT模板的布局和风格智能布局决策:匹配内容与合适的PPT布局自动…...
linux 下常用变更-8
1、删除普通用户 查询用户初始UID和GIDls -l /home/ ###家目录中查看UID cat /etc/group ###此文件查看GID删除用户1.编辑文件 /etc/passwd 找到对应的行,YW343:x:0:0::/home/YW343:/bin/bash 2.将标红的位置修改为用户对应初始UID和GID: YW3…...
select、poll、epoll 与 Reactor 模式
在高并发网络编程领域,高效处理大量连接和 I/O 事件是系统性能的关键。select、poll、epoll 作为 I/O 多路复用技术的代表,以及基于它们实现的 Reactor 模式,为开发者提供了强大的工具。本文将深入探讨这些技术的底层原理、优缺点。 一、I…...
基于matlab策略迭代和值迭代法的动态规划
经典的基于策略迭代和值迭代法的动态规划matlab代码,实现机器人的最优运输 Dynamic-Programming-master/Environment.pdf , 104724 Dynamic-Programming-master/README.md , 506 Dynamic-Programming-master/generalizedPolicyIteration.m , 1970 Dynamic-Programm…...
【数据分析】R版IntelliGenes用于生物标志物发现的可解释机器学习
禁止商业或二改转载,仅供自学使用,侵权必究,如需截取部分内容请后台联系作者! 文章目录 介绍流程步骤1. 输入数据2. 特征选择3. 模型训练4. I-Genes 评分计算5. 输出结果 IntelliGenesR 安装包1. 特征选择2. 模型训练和评估3. I-Genes 评分计…...
华硕a豆14 Air香氛版,美学与科技的馨香融合
在快节奏的现代生活中,我们渴望一个能激发创想、愉悦感官的工作与生活伙伴,它不仅是冰冷的科技工具,更能触动我们内心深处的细腻情感。正是在这样的期许下,华硕a豆14 Air香氛版翩然而至,它以一种前所未有的方式&#x…...
LangChain知识库管理后端接口:数据库操作详解—— 构建本地知识库系统的基础《二》
这段 Python 代码是一个完整的 知识库数据库操作模块,用于对本地知识库系统中的知识库进行增删改查(CRUD)操作。它基于 SQLAlchemy ORM 框架 和一个自定义的装饰器 with_session 实现数据库会话管理。 📘 一、整体功能概述 该模块…...
WebRTC从入门到实践 - 零基础教程
WebRTC从入门到实践 - 零基础教程 目录 WebRTC简介 基础概念 工作原理 开发环境搭建 基础实践 三个实战案例 常见问题解答 1. WebRTC简介 1.1 什么是WebRTC? WebRTC(Web Real-Time Communication)是一个支持网页浏览器进行实时语音…...
