网狐6603棋牌ServerKernel中的IQueueService接口分析

　　技术工作人员撰写网狐底层代码通信二次开发相关事项，今天解析ServerKernel中的IQueueService接口分析

　　根据底层结构分析的此图：

　　在添加数据是处理如下图：

　　在有相关的库文件来处理执行相关的结构：

　　在执行过程中相关代码展示：

　　1//开始服务

　　2bool __cdecl CQueueService::StartService（）

　　3{

　　4    //效验参数

　　5    ASSERT（m_bService==false）；

　　6    ASSERT（m_hCompletionPort==NULL）；

　　7    ASSERT（m_pIQueueServiceSink!=NULL）；

　　8

　　9    //建立完成端口

　　10    //! 需要追踪一下这里的完成端口句柄

　　11    //! 首先分析这里的创建，INVALID_HANDLE_VALUE表示没有关联任何文件句柄，也就是

　　12    //! 说不存在某个实现某个操作完成以后系统自动给这个完成端口post一个完成消息的概念

　　13    //! 然后这里用限制工作线程数是1，也就是同意时刻只会有一条线程受到完成消息

　　14    m_hCompletionPort=CreateIoCompletionPort（INVALID_HANDLE_VALUE,NULL,NULL,1）；

　　15    if （m_hCompletionPort==NULL） throw TEXT（"队列对象完成端口创建失败"）；

　　16

　　17    //启动线程

　　18    if （m_QueueServiceThread.InitThread（m_hCompletionPort）==false） throw TEXT（"队列对象线程初始化失败"）；

　　19    if （m_QueueServiceThread.StartThead（）==false） throw TEXT（"队列对象线程启动失败"）；

　　20

　　21    //设置参数

　　22    m_bService=true;

　　23

　　24    return true;

　　25}m_QueueServiceThread.InitThread（m_hCompletionPort）；是用于给完成端口句柄抛给了服务线程，能得到服务线程工作原理

　　//运行函数

　　bool CQueueServiceThread::RepetitionRun（）

　　{

　　//效验参数

　　ASSERT（m_hCompletionPort!=NULL）；

　　//变量定义

　　DWORD dwThancferred=0;

　　OVERLAPPED pOverLapped=NULL;

　　CQueueService pQueueService=NULL;

　　//等待完成端口

　　if （GetQueuedCompletionStatus（m_hCompletionPort,&dwThancferred,（PULONG_PTR）&pQueueService,&pOverLapped,INFINITE））

　　{

　　//判断退出

　　if （pQueueService==NULL） return false;

　　//获取数据

　　tagDataHead DataHead;

　　bool bSuccess=pQueueService->GetData（DataHead,m_cbBuffer,sizeof（m_cbBuffer））；

　　ASSERT（bSuccess==true）；

　　//处理数据

　　if （bSuccess==true） pQueueService->OnQueueServiceThread（DataHead,m_cbBuffer,DataHead.wDataSize）；

　　return true;

　　}

　　return false;

　　}执行处理原理过程在此：GetQueuedCompletionStatus（m_hCompletionPort,&dwThancferred（PULONG_PTR）&pQueueService,&pOverLapped,INFINITE）

　　m_hCompletionPort是通过线程参数传递进来的，dwThancferred和pQueueService是在之前CQueueService::AddToQueue（）中Post过来的参数，

　　数据经过完成端口在CQueueServiceThread绕一圈以后会回到CQueueService::OnQueueServiceThread（）

　　//数据消息

　　void CQueueService::OnQueueServiceThread（const tagDataHead & DataHead, void pBuffer, WORD wDataSize）

　　{

　　ASSERT（m_pIQueueServiceSink!=NULL）；

　　try

　　{

　　m_pIQueueServiceSink->OnQueueServiceSink（DataHead.wIdentifier,pBuffer,DataHead.wDataSize,DataHead.dwInsertTime）；

　　}

　　catch （） {}

　　return;

　　}

　　这样队列服务就完成了他的使命，将执行的消息，异步的交给指定接口去处理，用一句话来描述QueueService模块就是：将队列的插入和处理通过关联到完成端口上以实现在IOCP线程池管理下异步处理；Add以后投递完成消息，在完成端口上监听的线程受到消息以后读取数据并处理； 找，还的选择专业开发商，科技。