求SOCKET重叠模型结构定义示例代码.............
小猪的手把手教你玩转SOCKET模型之重叠文章看了,程序也下了感觉真的很不错,
但是猪哥的WSASEND部分没有示例,我调起来很困难,各位帮帮忙,最好有完整的示例代码,
谢过!
[解决办法]
WSASend和WSARecv的用法没有太大差别，你可以参考他的WSARecv代码
[解决办法]
#include "stdafx.h"WSAOVERLAPPED AcceptOverlapped[10];SOCKET s,c;int i;WSAEVENT EventArray[WSA_MAXIMUM_WAIT_EVENTS];WSABUF DataBuf; DWORD dwEventTotal, // 程序中事件的总数 dwRecvBytes, // 接收到的字符长度 Flags; // WSARecv的参数 void CALLBACK WorkRoutine(DWORD error,DWORD BytesTransferred,LPWSAOVERLAPPED Overlapped, DWORD InFlags){ DWORD SendBytes; DWORD RecvBytes; DWORD Flags; if(error != 0 || BytesTransferred == 0){ cout<<error<<endl; closesocket(c); return; } cout<<DataBuf.buf<<endl; return ;}DWORD WINAPI _AcceptProc(LPVOID lpParameter){ // c = WSASocket(AF_INET,SOCK_STREAM,0,NULL,NULL,WSA_FLAG_OVERLAPPED); SOCKET *s = (SOCKET*)lpParameter; char buffer[1024]; if(i == 10 ){ cout<<"客户连接已满"<<endl; shutdown(c,2); closesocket(c); i--; if(i == 0){ cout<<"以清空"<<endl; return 0; } return 0; } ZeroMemory(&buffer,sizeof(buffer)); DataBuf.buf = buffer; DataBuf.len = sizeof(buffer); while(1){ c = accept(*s,NULL,NULL); if(c == INVALID_SOCKET){ cout<<"Accept错误"<<endl; cout<<WSAGetLastError()<<endl; return 0; } ZeroMemory(&AcceptOverlapped[i],sizeof(AcceptOverlapped)); if(i == 0){ if( WSARecv(c,&DataBuf,1,&dwRecvBytes,&Flags,&AcceptOverlapped[i],WorkRoutine) == SOCKET_ERROR){ if(WSAGetLastError() != WSA_IO_PENDING){ cout<<"WSARecv failed with error"<<WSAGetLastError()<<endl; closesocket(c); WSACloseEvent(EventArray[dwEventTotal]); return 0; } } } i++; Sleep(500); } // CreateThread(NULL,0,_AcceptProc,s,0,NULL); return 0;}DWORD WINAPI _InterestEventProc(LPVOID lpParameter){ return 0;}int main(int argc, char* argv[]){ WSADATA wsaData; SOCKET s; sockaddr_in service,client; WORD Version = MAKEWORD(2,2); DWORD ThreadID; EventArray[dwEventTotal] = WSACreateEvent(); //lAcceptOverlapped.hEvent = EventArray[dwEventTotal]; dwEventTotal ++; WSAStartup(Version,&wsaData); s = WSASocket(AF_INET,SOCK_STREAM,0,NULL,NULL,WSA_FLAG_OVERLAPPED); if(s == INVALID_SOCKET){ cout<<"WSASocket错误"<<endl; cout<<WSAGetLastError()<<endl; getch(); WSACleanup(); return 0; } service.sin_addr.S_un.S_addr = INADDR_ANY; service.sin_family = AF_INET; service.sin_port = htons(5150); if( bind(s,(sockaddr*)&service,sizeof(sockaddr_in)) == SOCKET_ERROR){ cout<<"bind 错误"<<endl; cout<<WSAGetLastError()<<endl; getch(); WSACleanup(); return 0; } listen(s,10); CreateThread(NULL,0,_AcceptProc,&s,0,NULL); DWORD dwIndex = 0, dwBytesTransferred; while(1){ dwIndex = WSAWaitForMultipleEvents(dwEventTotal,EventArray,false,2000,true); if(dwIndex == WSA_WAIT_TIMEOUT){ cout<<"超时"<<endl; continue; } if(dwIndex == WAIT_IO_COMPLETION){ cout<<"IO完成"<<endl; break; } dwIndex = dwIndex - WSA_WAIT_EVENT_0; if(dwIndex == 0){ cout<<"连入一个用户"<<endl; continue; } WSAResetEvent(EventArray[dwIndex]); WSAGetOverlappedResult(s,&AcceptOverlapped[i],& dwBytesTransferred,false,&Flags); if(dwBytesTransferred == 0){ cout<<"数据流量0关闭"; closesocket(s); WSACloseEvent(EventArray[dwIndex]); // 关闭事件 return 0; } Sleep(500); } getch(); WSACloseEvent(EventArray[dwEventTotal]); closesocket(s); WSACleanup(); return 0;}
[解决办法]
希望有用，慢慢看
#include "../common/initsock.h" //初始化SOCKET环境，包括一个类，析构时调用WSACleanup
#include <Mswsock.h>
#include <stdio.h>
#include <windows.h>
CInitSock theSock; //实例化
#define BUFFER_SIZE 1024
typedef struct _SOCKET_OBJ
{
SOCKET s;// 套节字句柄
int nOutstandingOps;// 记录此套节字上的重叠I/O数量
LPFN_ACCEPTEX lpfnAcceptEx;// 扩展函数AcceptEx的指针（仅对监听套节字而言）
} SOCKET_OBJ, *PSOCKET_OBJ;
typedef struct _BUFFER_OBJ
{
OVERLAPPED ol;// 重叠结构
char *buff;// send/recv/AcceptEx所使用的缓冲区
int nLen;// buff的长度
PSOCKET_OBJ pSocket;// 此I/O所属的套节字对象
int nOperation;// 提交的操作类型
#define OP_ACCEPT1
#define OP_READ2
#define OP_WRITE3
SOCKET sAccept;// 用来保存AcceptEx接受的客户套节字（仅对监听套节字而言）
_BUFFER_OBJ *pNext;
} BUFFER_OBJ, *PBUFFER_OBJ;
HANDLE g_events[WSA_MAXIMUM_WAIT_EVENTS];// I/O事件句柄数组
int g_nBufferCount;// 上数组中有效句柄数量
PBUFFER_OBJ g_pBufferHead, g_pBufferTail;// 记录缓冲区对象组成的表的地址
// 申请套节字对象和释放套节字对象的函数
PSOCKET_OBJ GetSocketObj(SOCKET s)
{
PSOCKET_OBJ pSocket = (PSOCKET_OBJ)::GlobalAlloc(GPTR, sizeof(SOCKET_OBJ));
if(pSocket != NULL)
{
pSocket->s = s;
}
return pSocket;
}
void FreeSocketObj(PSOCKET_OBJ pSocket)
{
if(pSocket->s != INVALID_SOCKET)
::closesocket(pSocket->s);
::GlobalFree(pSocket);
}
PBUFFER_OBJ GetBufferObj(PSOCKET_OBJ pSocket, ULONG nLen)
{
if(g_nBufferCount > WSA_MAXIMUM_WAIT_EVENTS - 1)
return NULL;
PBUFFER_OBJ pBuffer = (PBUFFER_OBJ)::GlobalAlloc(GPTR, sizeof(BUFFER_OBJ));
if(pBuffer != NULL)
{
pBuffer->buff = (char*)::GlobalAlloc(GPTR, nLen);
pBuffer->ol.hEvent = ::WSACreateEvent();
pBuffer->pSocket = pSocket;
pBuffer->sAccept = INVALID_SOCKET;
// 将新的BUFFER_OBJ添加到列表中
if(g_pBufferHead == NULL)
{
g_pBufferHead = g_pBufferTail = pBuffer;
}
else
{
g_pBufferTail->pNext = pBuffer;
g_pBufferTail = pBuffer;
}
g_events[++ g_nBufferCount] = pBuffer->ol.hEvent;
}
return pBuffer;
}
void FreeBufferObj(PBUFFER_OBJ pBuffer)
{
// 从列表中移除BUFFER_OBJ对象
PBUFFER_OBJ pTest = g_pBufferHead;
BOOL bFind = FALSE;
if(pTest == pBuffer)
{
g_pBufferHead = g_pBufferTail = NULL;
bFind = TRUE;
}
else
{
while(pTest != NULL && pTest->pNext != pBuffer)
pTest = pTest->pNext;
if(pTest != NULL)
{
pTest->pNext = pBuffer->pNext;
if(pTest->pNext == NULL)
g_pBufferTail = pTest;
bFind = TRUE;
}
}
// 释放它占用的内存空间
if(bFind)
{
g_nBufferCount --;
::CloseHandle(pBuffer->ol.hEvent);
::GlobalFree(pBuffer->buff);
::GlobalFree(pBuffer);
}
}
PBUFFER_OBJ FindBufferObj(HANDLE hEvent)
{
PBUFFER_OBJ pBuffer = g_pBufferHead;
while(pBuffer != NULL)
{
if(pBuffer->ol.hEvent == hEvent)
break;
pBuffer = pBuffer->pNext;
}
return pBuffer;
}
void RebuildArray()
{
PBUFFER_OBJ pBuffer = g_pBufferHead;
int i = 1;
while(pBuffer != NULL)
{
g_events[i++] = pBuffer->ol.hEvent;
pBuffer = pBuffer->pNext;
}
}
BOOL PostAccept(PBUFFER_OBJ pBuffer)
{
PSOCKET_OBJ pSocket = pBuffer->pSocket;
if(pSocket->lpfnAcceptEx != NULL)
{
// 设置I/O类型，增加套节字上的重叠I/O计数
pBuffer->nOperation = OP_ACCEPT;
pSocket->nOutstandingOps ++;
// 投递此重叠I/O
DWORD dwBytes;
pBuffer->sAccept =
::WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);
BOOL b = pSocket->lpfnAcceptEx(pSocket->s,
pBuffer->sAccept,
pBuffer->buff,
BUFFER_SIZE - ((sizeof(sockaddr_in) + 16) * 2),
sizeof(sockaddr_in) + 16,
sizeof(sockaddr_in) + 16,
&dwBytes,
&pBuffer->ol);
if(!b)
{
if(::WSAGetLastError() != WSA_IO_PENDING)
return FALSE;
}
return TRUE;
}
return FALSE;
};
BOOL PostRecv(PBUFFER_OBJ pBuffer)
{
// 设置I/O类型，增加套节字上的重叠I/O计数
pBuffer->nOperation = OP_READ;
pBuffer->pSocket->nOutstandingOps ++;
// 投递此重叠I/O
DWORD dwBytes;
DWORD dwFlags = 0;
WSABUF buf;
buf.buf = pBuffer->buff;
buf.len = pBuffer->nLen;
if(::WSARecv(pBuffer->pSocket->s, &buf, 1, &dwBytes, &dwFlags, &pBuffer->ol, NULL) != NO_ERROR)
{
if(::WSAGetLastError() != WSA_IO_PENDING)
return FALSE;
}
return TRUE;
}