分享
 
 
 

TCP网络程序设计-完成端口之应用

王朝vc·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

一、运行程序

开发环境mdac2.7,vc6 sp5,win2000

如果你的mdac版本是旧请升级或者重新编译。服务器端的数据库access,用ado来操作的。客户端用csv格式的文件系统的。将SMSServer和SMSClient放在同一个机器上,因为编译时我将IP设置成了127.0.0.1,SMSServerDB与SMSServer放在同一个目录。源代码是按1字节对其编译,静态连接的,程序并没有在网络负担大,SOCKET连接数量大的条件下测试过。

二、数据结构和通讯协议及处理实现

服务器端是采用完成端口异步模式,客户端是同步的SOCKET类实现的。

服务器端有侦听线程,工作线程组成。

typedef struct _SessionPack

{

WORD CommandID; // 命令ID

WORD DataLength; // Data数据长度

WORD DataItems; // 数据区数据项数,即Data中有效的结构体的个数

char Data[1]; // 数据区

}SESSIONPACK,*PSESSIONPACK;

前三个字段相当于包头,Data是有效数据首地址。根据需要分配。结构体定义

在packet.h文件中,协议定义在protocol.h文件中。一个SessionPack不要超过4k。CIocpFrame是完成端口的封装类,业务逻辑都在CIocpFrame::Proecssjob中处理,其中几个数据库操作的函数在server.h中。PER_HANDLE_DATA,PER_IO_OPERATION_DATA这两个结构详细请见完成端口。

客户端发送大量数据处理,例如,上传通讯录

for(int j=0;j<nGroup;j++)

{

Sleep(100);

if(j!=nGroup-1)//还没有到最后一组

{

PSESSIONPACK pPack=(PSESSIONPACK)new char[sizeof(SESSIONPACK)+sizeof(LINK)*MAXLINK-1];//一组数据分配大约4k空间一起发送

PLINK pData=(PLINK)pPack->Data;

memset(pPack,0,sizeof(SESSIONPACK)+sizeof(LINK)*MAXLINK-1);//MAXLINK是LINK结构体个数

pPack->DataLength=sizeof(LINK)*MAXLINK;

pPack->DataItems=MAXLINK;//告诉服务器有几个LINK要处理

pPack->CommandID=COMMAND_UPLOAD_LINK;

for(int i=0;i<MAXLINK;i++)

{

file://往pData中赋值

file://下一条数据

pData++;

}

g_pClient->Send(pPack,sizeof(SESSIONPACK)+sizeof(LINK)*MAXLINK-1,0);

delete pPack;

}//ifj

else//最后一组可能不到MAXLINK个LINK结构体

{

int iLeft=parser.m_nRows-j*MAXLINK;

PSESSIONPACK pPack=(PSESSIONPACK)new char[sizeof(SESSIONPACK)+sizeof(LINK)*iLeft-1];

PLINK pData=(PLINK)pPack->Data;

memset(pPack,0,sizeof(SESSIONPACK)+sizeof(LINK)*iLeft-1);

pPack->DataLength=sizeof(LINK)*iLeft;

pPack->DataItems=iLeft;

pPack->CommandID=COMMAND_UPLOAD_LINK;

for(int i=0;i<iLeft;i++)

{

file://往pData中赋值

file://下一条数据

pData++;

}

g_pClient->Send(pPack,sizeof(SESSIONPACK)+sizeof(LINK)*iLeft-1,0);

delete pPack;

}

}

//服务器接受数据

PLINK pBody;

pBody=(PLINK)pPack->Data;

for(int i=0;i<DataItem;i++)

{

SaveLink(pBody);//往数据库插纪录

pBody++;

}

memset(pConText,0,sizeof(PER_IO_OPERATION_DATA));//这句话是否有问题?

pConText->DataBuf.len=DATA_BUFSIZE;

pConText->DataBuf.buf=pConText->Buffer;

pConText->OperationType=RECV_POST;

Flags = 0;

if (WSARecv(sClient, &(pConText->DataBuf), 1, &RecvBytes, &Flags,

&(pConText->Overlapped), NULL) == SOCKET_ERROR)

{

if (WSAGetLastError() != ERROR_IO_PENDING)

dwRet=PROCESS_FAIL;

}

服务器向客户端发送大量数据 例如 下载通讯录

原理与客户端大量发送类似,不过在服务器发送大最后一个包时要将命令字设置成COMMAND_DOWNLOAD_LINK_EXIT通知客户端数据发送结束,请不要在接收了。客户端请求时需将本地数据的最大id存放在有效数据区以告诉服务器,避免重复查询。

三、完成端口介绍

主要用到3个函数和一个OVERLAPPED的结构

每当有一个连接上来,就将它与完成端口关联,完成端口实际上就是一个重叠IO的队列,当队列中某一个对象有信号时,GetQueuedCompletionStatus就返回了,并将这个重叠IO及与之对应的单据柄数据传出,在我的程序里这个单句柄数据就是客户端套接字,这时你就可以对缓冲区数据操作了。

HANDLE CreateIoCompletionPort(

HANDLE FileHandle,//用于完成端口的设备的句柄

HANDLE ExistingCompletionPort,//完成端口句柄,如果是NULL则生成一个新的

ULONG_PTR CompletionKey,//单据柄数据

DWORD NumberOfConcurrentThreads//允许最大的工作线程的数量

);//这个函数主要的功能就是生成完成端口,或者将某句柄与完成端口关联

BOOL GetQueuedCompletionStatus(HANDLE CompletionPort,//需要监视的完成端口句柄

LPDWORD lpNumberOfBytes,//实际传输的字节

PULONG_PTR lpCompletionKey,//单句柄数据

LPOVERLAPPED* lpOverlapped,//一个指向伪造的重叠IO的指针,大小取决于你的定义

DWORD dwMilliseconds//等待多少秒

);

这个函数返回有几种可能,某个重叠IO发生了数据传输,或者客户端CloseSocket,或者其他原因导致完成端口失败,或者服务器调用PostQueuedCompletionStatus主动要求结束。以下是我在程序里的判断代码。

bSuccess=GetQueuedCompletionStatus(g_hCompPort,

&dwNumBytes, (DWORD*)&PerHandleData, (OVERLAPPED**)&ConText, INFINITE);

if(!bSuccess)

{

file://客户端断开连接

if(PerHandleData!=NULL)

if(dwNumBytes == 0&&PerHandleData->pIOContext->OperationType==RECV_POST)

{

pIocpFrame->CloseClient(PerHandleData);

continue;

}

}

if(bSuccess)

if(PerHandleData==NULL&&dwNumBytes==0)

{

file://工作线程被通知结束

SetEvent(g_ThreadHandles[pos]);

return 0;

}

BOOL PostQueuedCompletionStatus(

HANDLE CompletionPort,

DWORD dwNumberOfBytesTransferred,

ULONG_PTR dwCompletionKey,

LPOVERLAPPED lpOverlapped

);

我是用这个函数来告诉工作线程给我马上停止工作。你也可以用这个函数发送其他字定义消息到完成端口,不过调用这个函数要记得先关闭所有客户端。程序中我的客户端套接字保存在链表中的是由ctx开头的几个函数处理的。

四、结束语

该程序是我学习完成端口的一个总结,源代码变量函数结构体较多注释少可能不好阅读,使用完成端口设计程序关键是对完成端口的几个函数的理解。主要用于文件上传下载服务。网关,c/s的程序中也可以使用,缺陷是不能移植到unix平台下。

参考资料:platformsdk 中iocp的例子,msdn,windows网络程序设计

客户端exe 服务端exe 服务端数据库 原码

我的主页

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有