LogServer
日志服務器看起來是一個完全獨立的服務器，啟動以后直接向某個邏輯服務器發起一個連接，然后根據如下的映射表工作起來：
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是網絡協議，value是對應的處理函數，對應的邏輯類是QLoggerHandler
QLoggerHandler管理著LogServer唯一的socket句柄，連接建立后就做一件事，把接受到的數據塞到日志數據庫囧。
日志服務器協議命令碼
enum EServerLogProtocol
{
GMSG_LOG_SERVER_INFO = 1,
LMSG_LOG_SERVER_CLOSE = 2,
LMSG_LOG_SERVER_ERROR = 3,
GMSG_LOG_ITEM = 4,//物品相關log
GMSG_LOG_CHAT = 5,//聊天log
GMSG_LOG_ACCOUNT = 6,//account活動log
GMSG_LOG_SYS = 7,//系統警告log
GMSG_LOG_PLAYER = 8,//玩家log
GMSG_LOG_SAMPLE = 9,//玩家log
GMSG_LOG_STAT = 10,//系統統計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.在網絡協議風暴解包中MSG_X系列宏算一個亮點。
用法舉例：
msg標識一個消息數據，實際上一個ACE_Message_Block
MSG_NEW(MSG_OP_CODE, msg) // 定義一個消息包，opcode是MSG_OP_CODE
MSG_SET_STR( // 調用ACE_Message_Block相關接口寫入需要攜帶的數據，數據大小變化會被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 );
這種設計要求網絡響應函數參數是一致的，函數內部各自做解包操作。
3.統一分離出來的數據庫操作：
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_
整個設計顯得非常清晰：
QLoggerHandler接受到網絡消息通過映射表static Msg_Map msg_map_;分解到各自的解包函數，然后通過DBProxy執行最終的數據庫操作。