LogServer
日志服務(wù)器看起來是一個(gè)完全獨(dú)立的服務(wù)器，啟動以后直接向某個(gè)邏輯服務(wù)器發(fā)起一個(gè)連接，然后根據(jù)如下的映射表工作起來：
QLOG_MSG_ENTRY( GMSG_LOG_SERVER_INFO,gmsg_log_server_info)
QLOG_MSG_ENTRY( GMSG_LOG_ITEM,gmsg_log_item)
QLOG_MSG_ENTRY( GMSG_LOG_CHAT,gmsg_log_chat)
QLOG_MSG_ENTRY( GMSG_LOG_ACCOUNT,gmsg_log_account)
QLOG_MSG_ENTRY( GMSG_LOG_SYS,gmsg_log_sys)
QLOG_MSG_ENTRY(GMSG_LOG_PLAYER,gmsg_log_player)
QLOG_MSG_ENTRY(GMSG_LOG_SAMPLE,gmsg_log_sample)
QLOG_MSG_ENTRY( GMSG_LOG_STAT,gmsg_log_stat)
QLOG_MSG_ENTRY( GMSG_LOG_GM,gmsg_log_gm)
QLOG_MSG_ENTRY(GMSG_LOG_QUEST,gmsg_log_quest)
QLOG_MSG_ENTRY(GMSG_LOG_MAIL,gmsg_log_mail)
QLOG_MSG_ENTRY(GMSG_LOG_SCRIPT,gmsg_log_script)
QLOG_MSG_ENTRY(GMSG_LOG_TENCENT_CLIENT_WG, gmsg_log_tencent_client_wg)
QLOG_MSG_ENTRY(GMSG_LOG_PING, gmsg_log_ping)
key是網(wǎng)絡(luò)協(xié)議，value是對應(yīng)的處理函數(shù)，對應(yīng)的邏輯類是QLoggerHandler
QLoggerHandler管理著LogServer唯一的socket句柄，連接建立后就做一件事，把接受到的數(shù)據(jù)塞到日志數(shù)據(jù)庫囧。
日志服務(wù)器協(xié)議命令碼
enum EServerLogProtocol
{
GMSG_LOG_SERVER_INFO = 1,
LMSG_LOG_SERVER_CLOSE = 2,
LMSG_LOG_SERVER_ERROR = 3,
GMSG_LOG_ITEM = 4,//物品相關(guān)log
GMSG_LOG_CHAT = 5,//聊天log
GMSG_LOG_ACCOUNT = 6,//account活動log
GMSG_LOG_SYS = 7,//系統(tǒng)警告log
GMSG_LOG_PLAYER = 8,//玩家log
GMSG_LOG_SAMPLE = 9,//玩家log
GMSG_LOG_STAT = 10,//系統(tǒng)統(tǒng)計(jì)log
GMSG_LOG_GM = 11,//gm log
GMSG_LOG_QUEST = 12,//quest log
GMSG_LOG_MAIL = 13,//mail log
GMSG_LOG_SCRIPT = 14,//script log
GMSG_LOG_CLIENT_WG = 15,//客戶端檢測外掛
GMSG_LOG_TENCENT_CLIENT_WG = 16,//騰訊的檢測外掛log
GMSG_LOG_PING = 17,//檢測LogServer是否死掉
};
編碼技巧：
1.在網(wǎng)絡(luò)協(xié)議風(fēng)暴解包中MSG_X系列宏算一個(gè)亮點(diǎn)。
用法舉例：
msg標(biāo)識一個(gè)消息數(shù)據(jù)，實(shí)際上一個(gè)ACE_Message_Block
MSG_NEW(MSG_OP_CODE, msg) // 定義一個(gè)消息包，opcode是MSG_OP_CODE
MSG_SET_STR( // 調(diào)用ACE_Message_Block相關(guān)接口寫入需要攜帶的數(shù)據(jù)，數(shù)據(jù)大小變化會被ace自動感知到
MSG_DEL(smsg); // 銷毀消息
2.利用map做的消息映射表：
#define QLOG_MSG_MAP_BEGIN \
class __LOG_MSG_MAP__{ public:__LOG_MSG_MAP__(); }; \
static __LOG_MSG_MAP__ __log_msg_map__; \
__LOG_MSG_MAP__::__LOG_MSG_MAP__(){ \
QLoggerHandler::msg_map_.clear();
#define QLOG_MSG_ENTRY( QMSG, FUNC ) \
if(QLoggerHandler::msg_map_.find(QMSG)==QLoggerHandler::msg_map_.end()) \
{ QLoggerHandler::msg_map_.insert(QLoggerHandler::Msg_Map::value_type(QMSG,QLoggerHandler::FUNC));}
#define QLOG_MSG_MAP_END }
#define QLOG_MSG_ENTRY( QMSG, FUNC ) bool FUNC( ACE_Message_Block* msg );
這種設(shè)計(jì)要求網(wǎng)絡(luò)響應(yīng)函數(shù)參數(shù)是一致的，函數(shù)內(nèi)部各自做解包操作。
3.統(tǒng)一分離出來的數(shù)據(jù)庫操作：
class DBProxy
{
public:
static bool save_sys_log(const char* sys_l
static bool save_item_log(const char* serv
int left_credit,int item_guid,int item
static bool save_gm_log(int gm_log_type, c
static bool save_chat_log(int chat_type,co
static bool save_account_log( int log_type
static bool save_player_log(int log_type,c
static bool save_sample_log(int log_type,c
static bool save_stat_log(const char* serv
static bool save_quest_log(int log_type, c
static bool save_mail_log(int log_type, co
static bool save_script_log(int log_type,
const char* log_p_2,const char* log_p_
static bool save_tencent_wg_log(const char
};
#endif//__DBProxy_H_
整個(gè)設(shè)計(jì)顯得非常清晰：
QLoggerHandler接受到網(wǎng)絡(luò)消息通過映射表static Msg_Map msg_map_;分解到各自的解包函數(shù)，然后通過DBProxy執(zhí)行最終的數(shù)據(jù)庫操作。