数据库发包

现在就来看看数据库发包模式

这个用到了抽象工厂模式

其实经理的那个差不多都是注册具体工厂到抽象工厂,只是这里不是抽象工厂而是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解析数据访问数据库

 

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。