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

自助开通VIP,整站资源任意下载

  技术工作人员撰写网狐底层代码通信二次开发相关事项,今天解析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

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

  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);

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

  try

  {

  m_pIQueueServiceSink->OnQueueServiceSink(DataHead.wIdentifier,pBuffer,DataHead.wDataSize,DataHead.dwInsertTime);

  }

  catch () {}

  return;

  }

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

本站源码仅做学术研究,自娱自乐使用,不得用于赌博性质的非法商业用途!转载请说明出处!
棋牌资源网 » 网狐6603棋牌ServerKernel中的IQueueService接口分析

这里有你所需要的,找专业的人做专业的事!

游戏演示 联系客服