DELPHI中完成端口(IOCP)的简单分析(4)
2024-10-19 06:19:28
DELPHI中完成端口(IOCP)的简单分析(4)
在我以前写的文章中,一直说的是如何接收数据。但是对于如何发送数据却一点也没有提到。因为从代码量上来说接收的代码要比发送多很多。今天我就来写一下如何使用IOCP发送数据。
function TNetControl.SendSpecifyData(const Socket: TSocket; Data: array of char;
DataLen: Integer): Boolean;
DataLen: Integer): Boolean;
const
DATA_BUFSIZE = 1024; //这里定义一个发送数据的缓存长度,只要和接收的一直就可以
var
PerIoData: LPPER_IO_OPERATION_DATA ;
SendBytes, RecvBytes: DWORD;
Flags: DWORD ;
LenStr:String;
SendBuf:array [0..DATA_BUFSIZE] of char;
begin
try
//由于粘包的关系,所以在需要发送的数据前面加入4位这次发送数据的长度。(详见我的前一篇文章)
PerIoData: LPPER_IO_OPERATION_DATA ;
SendBytes, RecvBytes: DWORD;
Flags: DWORD ;
LenStr:String;
SendBuf:array [0..DATA_BUFSIZE] of char;
begin
try
//由于粘包的关系,所以在需要发送的数据前面加入4位这次发送数据的长度。(详见我的前一篇文章)
SetArrayLength(DataLen,LenStr) ;
Fillchar(SendBuf,sizeof(SendBuf),#0);
strmove(SendBuf,Pointer(LenStr),4);
strmove(SendBuf+4,Data,DataLen);
Fillchar(SendBuf,sizeof(SendBuf),#0);
strmove(SendBuf,Pointer(LenStr),4);
strmove(SendBuf+4,Data,DataLen);
//在这里申请一个发送数据的"单IO数据结构"
PerIoData := LPPER_IO_OPERATION_DATA(GlobalAlloc(GPTR, sizeof(PER_IO_OPERATION_DATA)));
if (PerIoData = nil) then
begin
Result:=false;
exit;
end;
ZeroMemory(@PerIoData.Overlapped, sizeof(OVERLAPPED));
//设置发送标记
PerIoData := LPPER_IO_OPERATION_DATA(GlobalAlloc(GPTR, sizeof(PER_IO_OPERATION_DATA)));
if (PerIoData = nil) then
begin
Result:=false;
exit;
end;
ZeroMemory(@PerIoData.Overlapped, sizeof(OVERLAPPED));
//设置发送标记
PerIoData.BytesRECV := 0;
PerIoData.DataBuf.len := DataLen+4;
PerIoData.DataBuf.buf:=@SendBuf;
PerIoData.BytesSEND := DataLen+4;
Flags := 0;
PerIoData.DataBuf.len := DataLen+4;
PerIoData.DataBuf.buf:=@SendBuf;
PerIoData.BytesSEND := DataLen+4;
Flags := 0;
//使用WSASend函数将数据发送
if (WSASend(Socket, @(PerIoData.DataBuf), 1, @SendBytes, 0,@(PerIoData.Overlapped), nil) = SOCKET_ERROR) then
begin
if (WSAGetLastError() <> ERROR_IO_PENDING) then
begin
//最近在检查代码的时候发现以前这里只是使用Exit来退出是不正确的。这里需要删除申请的单IO数据结构,否子会出现内存泄露。 (2008年3月24日)
if (WSASend(Socket, @(PerIoData.DataBuf), 1, @SendBytes, 0,@(PerIoData.Overlapped), nil) = SOCKET_ERROR) then
begin
if (WSAGetLastError() <> ERROR_IO_PENDING) then
begin
//最近在检查代码的时候发现以前这里只是使用Exit来退出是不正确的。这里需要删除申请的单IO数据结构,否子会出现内存泄露。 (2008年3月24日)
//Exit;
//表示发送失败,以后也不会有处理在工作者线程处出现。
if PerIoData <> nil then
begin
GlobalFree(DWORD(PerIoData));
end;
Result:=false;
Exit;
end;
end;
Result:=true;
except
Result:=false;
end;
end;
if PerIoData <> nil then
begin
GlobalFree(DWORD(PerIoData));
end;
Result:=false;
Exit;
end;
end;
Result:=true;
except
Result:=false;
end;
end;
使用IOCP发送数据的代码就这些,但是这里需要说明一些问题。
1:读者一定发送我们在申请了“单IO数据结构”以后并没有对它进行释放。这是因为我们使用的是异步函数WSASend来进行发送数据,只有当我们确定将数据发送出去以后才可以将我们申请的这个结构释放。这就引出了第二个问题。
2:如何判断我们发送的数据已经发送。向我以前的文章中所说的“IOCP可以接受来自客户端的数据和自己发送出去的数据”,而区分这个数据是来自客户端还是自己发送出去的区分就是使用PerIoData.BytesRECV 和PerIoData.BytesSEND 如果PerIoData.BytesSEND >0则表示这个数据是自己发送出去的。现在咱们来回顾一下以前的代码,找出释放“单IO数据结构”的地方。
在第二篇文章我写了这样的代码。
//当我们判断出来接受的数据是我们发送出去的数据的时候,在这里我们清空我们申请的内存空间
else
begin
GlobalFree(DWORD(PerIoData));
end;
else
begin
GlobalFree(DWORD(PerIoData));
end;
这里就是我们释放“单IO数据结构”的地方。
到此我已经将整个的IOCP从创建、初始化、接收和发送简单的描述了一下。如果读者根据我写的思路或者代码就可以编写出以后稳定的基于IOCP的网络程序。
最新文章
- UVALive 2453 Wall (凸包)
- 通过HttpListener实现简单的Http服务
- EL总结
- GIT FLOW 时序图
- innerHtml innerText textContent兼容性问题
- nginx 安装及代理配置。
- android studio svn不显示问题
- 在Apache中开启虚拟主机
- #Leet Code# Unique Path(todo)
- tomcat+spring+https
- 把自己的程序打成jar包,让别人调用
- iOS开发之 用第三方类库实现ScrollView
- Windows Server 2016-部署额外域控制器
- angular2-7中的变化监测
- php-fpm无法使用系统环境变量的解决方法
- javaScript系列 [02]-javaScript对象探析
- HAProxy + Keepalived + Flume 构建高性能高可用分布式日志系统
- postgre
- IIS ashx
- 前端 JS,localStorage/sessionStorage、cookie 及 url 等实现前台数据共享、传输
热门文章
- Winscp使用sudo user登录
- 魔术方法__get()、__set()和__call()的用法
- doctest --- 一个改善python代码质量的工具
- 物联网架构成长之路(26)-Docker构建项目用到的镜像2
- 修改Egret引擎代码的方法
- 【Spark深入学习 -13】Spark计算引擎剖析
- mybatis中设置打印sql语句application.yml
- C语言 &#183; FBI树
- 卷积神经网络(Convolutional Neural Network, CNN)简析
- apache2.4 httpd.conf httpd-vhost.conf配置