设计上：

(1)文件数据库是用于处理游戏逻辑业务请求。

(2)mysql数据库是用于处理运营后台查询请求。

(3)备份业务是用于定时备份文件数据库文件。

本文目录： 1、角色数据更新请求

2、mysql业务线程循环处理更新请求 3、文件数据库业务线程循环处理更新请求

4、备份业务线程循环处理备份业务

本文内容：

1、角色数据更新请求

保存角色数据请求,提交到业务线程队列

保存角色描述数据，提交到文件数据库角色描述数据更新列表和mysql角色描述数据更新列表。

保存角色具体数据，提交到文件数据库角色数据更新列表和mysql角色数据更新列表。

VOIDCDBDataClient::CatchSaveCharData(CDataPacketReader &inPacket)

{

INT64nCharId;

DWORDdwDataSize;

inPacket >> nCharId;

inPacket >> dwDataSize;

CGameDataBuffer *pBuffer = m_pDataServer->AllocGameDataBuffer();

pBuffer->AddRef();

pBuffer->SetData(nCharId, inPacket.getOffsetPtr(), dwDataSize);

CharDesc *pCharDesc = m_pLocalDB->GetCharDesc(nCharId);

if(pCharDesc)

{

//跳过角色基本数据头结构

common::DBType::PlayerBasicData *pBaseData =(common::DBType::PlayerBasicData *)\

pBuffer->getPositionPtr(sizeof(common::DBType::DataSectionHeader));

//发起对角色描述数据的更新

pCharDesc->wLevel = pBaseData->wLevel;

pCharDesc->btGender = pBaseData->btGender;

pCharDesc->nUpdateTime = CMiniDateTime::now();

m_pLocalDB->PostUpdateCharDesc(pCharDesc);

m_pSQLDB->PostUpdateCharDesc(pCharDesc);

}

elselogError( _T("试图更新在本地角色描述数据中找不到的角色数据(%lld)"), nCharId);

m_pLocalDB->PostUpdateCharData(pBuffer);

m_pSQLDB->PostUpdateCharData(pBuffer);

pBuffer->Release();

CDataPacket &pack = AllocProtoPacket(DBType::dsSaveCharData);

pack <

pack <

FlushProtoPacket(pack);

}

2、mysql业务线程循环处理更新请求

mysql线程处理循环，处理数据写入mysql请求

VOIDCSQLDB::OnRountine()

{

TICKCOUNT dwStartTick;

while(!terminated())

{

if(!m_boStarted)

{

moon::OS::osSleep(16);

continue;

}

//连接SQL数据库

if(!ConnectSQLDB())

{

moon::OS::osSleep(16);

continue;

}

dwStartTick = _getTickCount();

//处理角色描述更新请求

m_NewCharList.flush();

if(m_NewCharList.count() > 0)

{

ProcessAddNewChars(4);

}

m_UpdateCharDescList.flush();

if(m_UpdateCharDescList.count() > 0)

{

ProcessUpdateCharDescs(4);

}

//处理角色数据更新请求

m_CharDataUpdateList.flush();

if(m_CharDataUpdateList.count() > 0)

{

ProcessCharDataUpdate(4);

}

//处理帮会数据更新请求

m_GuildDataUpdateList.flush();

if(m_GuildDataUpdateList.count() > 0)

{

ProcessGuildDataUpdate(4);

}

moon::OS::osSleep(4);

}

}

3、文件数据库业务线程循环处理更新请求

VOIDCLocalDB::OnRountine()

{

TICKCOUNT dwStartTick;

TICKCOUNT dwBackupTick = 0;

while(!terminated())

{

if(!m_boOpened)

{

osSleep(16);

continue;

}

dwStartTick = _getTickCount();

if((m_nBackupInterval) && (0 == dwBackupTick))

dwBackupTick = _getTickCount();

//处理角色描述更新请求

m_CharDescUpdateList.flush();

if(m_CharDescUpdateList.count() > 0)

{

ProcessCharDescUpdate(4);

}

//处理角色数据更新请求

m_CharDataUpdateList.flush();

if(m_CharDataUpdateList.count() > 0)

{

ProcessCharDataUpdate(4);

}

//处理帮会数据更新请求

m_GuildDataUpdateList.flush();

if(m_GuildDataUpdateList.count() > 0)

{

ProcessGuildDataUpdate(4);

}

if((m_nBackupInterval) && ((INT)(_getTickCount() - dwBackupTick) >= m_nBackupInterval))//每隔一段时间(目前48小时)

{

BackupFDBFiles();

m_ZipBackup.StartZipBackup();//发送信号通知备份业务线程处理备份业务

dwBackupTick = 0;

}

osSleep(4);

}

}

4、备份业务线程循环处理备份业务

备份业务线程阻塞等待通知来处理文件数据库的文件的备份业务。

VOIDCZipBackup::OnRountine()

{

#ifdef WINDOWS

m_hZipBackupEvent = ::CreateEvent(NULL, FALSE, FALSE, NULL);

#else

pthread_cond_init(&m_hZipBackupEvent, NULL);

#endif

while(!terminated())

{

#ifdef WINDOWS

::WaitForSingleObject(m_hZipBackupEvent, INFINITE);

#else

pthread_mutex_lock( &m_tx );

pthread_cond_wait( &m_hZipBackupEvent , &m_tx );

pthread_mutex_unlock( &m_tx );

#endif

if(terminated())

break;

DoZipBackup();

CleanBackupFiles();

osSleep(10);

}

#ifdef WINDOWS

::CloseHandle(m_hZipBackupEvent);

m_hZipBackupEvent = NULL;

#else

pthread_cond_destroy(&m_hZipBackupEvent);

#endif

}