iocp 完成端口封装类 内存优化 高并发 接口简单
文章转自王牌软件----
class Iocp //完成端口 功能类
class IocpMemoryManager //此类提供IOCP 内存的管理
//IocpMemoryManager.h #pragma once#include <winsock2.h>#include <Mswsock.h>#include <list>#include <iostream>usingnamespace std;//此类提供IOCP 内存的管理#define BUFFER_SIZE 1024*4 // I/O请求的缓冲区大小 单次发送最大 4096// 这是per-I/O数据。它包含了在套节字上处理I/O操作的必要信息classCIOCPBuffer{public: CIOCPBuffer(); ~CIOCPBuffer(); boolisUsed; WSAOVERLAPPED ol; SOCKET sClient; // AcceptEx接收的客户方套节字 char*buff; // I/O操作使用的缓冲区 intnLen; // buff缓冲区（使用的）大小 ULONGnSequenceNumber; // 此I/O的序列号 intnOperation; // 操作类型#define OP_ACCEPT 1#define OP_WRITE 2#define OP_READ 3}; // 这是per-Handle数据。它包含了一个套节字的信息classCIOCPContext{public: CIOCPContext(); ~CIOCPContext(); boolisUsed; SOCKET s; // 套节字句柄 SOCKADDR_IN addrLocal; // 连接的本地地址 SOCKADDR_IN addrRemote; // 连接的远程地址 boolbClosing; // 套节字是否关闭 intnOutstandingRecv; // 此套节字上抛出的重叠操作的数量 intnOutstandingSend; ULONGnReadSequence; // 安排给接收的下一个序列号 ULONGnCurrentReadSequence; // 当前要读的序列号 list<CIOCPBuffer*> pOutOfOrderReadsList; // 记录没有按顺序完成的读I/O CRITICAL_SECTION Lock; // 保护这个结构}; classIocpMemoryManager{public: IocpMemoryManager(void); ~IocpMemoryManager(void); staticIocpMemoryManager* GetInstence(); intm_nMaxFreeBuffers; //最大的空闲Buffer intm_nMaxFreeContexts; //最大的空闲Contexts intm_nMaxConnections; //最大的连接数 intGetContextListCount(){returnm_contextList.size();} //Accept 操作 boolInsertAPendingAccept(CIOCPBuffer *pBuffer); boolRemoveAPendingAccept(CIOCPBuffer *pBuffer); intGetPendingAcceptCount(); //buffer 操作 CIOCPBuffer* AllocateBuffer(intnLen = BUFFER_SIZE);//buffer 申请 voidReleaseABuffer(CIOCPBuffer *pBuffer); //buffer 释放 CIOCPBuffer* GetANoUseBuffer(); //获取一个空闲的buffer intGetFreeBuffersCount(); //获取空闲的Buffer的数目 //Contexts 操作 CIOCPContext* AllocateContext(constSOCKET& sClient); //Contexts 申请 voidReleaseAContext(CIOCPContext *pBuffer); //Contexts 释放 CIOCPContext* GetANoUseContexts(); //获取一个空闲的Contexts intGetFreeContextsCount(); ////获取空闲的Contexts的数目 voidCloseAConnection(CIOCPContext *pContext); voidCloseAllConnections(); //关闭所有的socket 但不FreeContexts(); voidFreeBuffers(); //清空所有Buffers voidFreeContexts(); //清空所有Contexts // 取得下一个要读取的 CIOCPBuffer *GetNextReadBuffer(CIOCPContext *pContext, CIOCPBuffer *pBuffer); //获取工作线程最大数 = CPU个数*2｛最佳｝ intGetMaxWorkerThreadCount(); voidHandlePendingAcceptTimeOut(); private: list<CIOCPBuffer*> m_bufferList; //统一管理 【管理所有申请的buffer】 list<CIOCPContext*> m_contextList;//统一管理 【管理所有申请的context】 list<CIOCPBuffer*> m_pPendingAcceptsList; CRITICAL_SECTION m_FreeBufferListLock; CRITICAL_SECTION m_FreeContextListLock; CRITICAL_SECTION m_PendingAcceptsLock; CRITICAL_SECTION m_ConnectionListLock;};