数据库发包
现在就来看看数据库发包模式 这个用到了抽象工厂模式 其实经理的那个差不多都是注册具体工厂到抽象工厂,只是这里不是抽象工厂而是PktFactoryMgr功能和抽象工厂差不多 { #define __REGISTER_DB_PKT_CREATEFUNCTION(DBOptClassType) \ Register<DBOptClassType>(PktSingleFactory<DBOptClassType>::GetOrCreateInstance()); __REGISTER_DB_PKT_CREATEFUNCTION(AskActorList);//注册包工厂到m_vecPktConstructor中 __REGISTER_DB_PKT_CREATEFUNCTION(AskActorInfo); __REGISTER_DB_PKT_CREATEFUNCTION(AskActorInfoEx); __REGISTER_DB_PKT_CREATEFUNCTION(AskUserInfo); } m_vecPktConstructor[pFactory->GetPktID()] = new FnPktCreate(std::bind(&PktSingleFactory<T>::CreatePkt, pFactory)); 我任务PktSingleFactory就相当于具体工厂,将具体工厂类注册金抽象工厂类 void asynDBCenter::GetUserInfo(std::function<void(bool bExist, const ShuiHu::UserInfo& hr)>* fnGetUserInfo, const char* pszName) { //抽象工厂根据注册进去的具体工厂创建具体产品,但有点疑问就是抽象工厂具体工厂可以创建多个具体产品类的实例,但CreatePkt是显示的去new DB::AskUserInfo* pAskPkt = dynamic_cast<DB::AskUserInfo*>(m_pPktFacMgr->CreatePkt(DB::eDBOpt_AskUserInfo)); //InterruptStream流内部封装操作,没什么 DB::InterruptStream SendStream(m_pSendBuffer, eMaxSendBufferSize); DB::DBOptID eOptID = pAskPkt->GetID(); SendStream.CopyIn(&eOptID, sizeof(DB::DBOptID)); // 操作ID pAskPkt->m_uFlag = (unsigned __int64)fnGetUserInfo; // 识别标记 strncpy(pAskPkt->m_aUserName, pszName, MAX_NAME_LEN); pAskPkt->Write(SendStream); //DestroyPkt又显示的delete,每次发包去new,delete容易造成内存碎片 m_pPktFacMgr->DestroyPkt(pAskPkt); PushShmInter(SendStream); }
DBSvr那边根据接收的数据创建介入式流,从其中读取ID创建相应的包,然后从包从介入式流中读取数据,在根据包的ID解析数据访问数据库
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。