| | |
| | | import cPickle
|
| | | import time
|
| | |
|
| | | # 仅输出简短日志的信息类型
|
| | | ClientServerMsg_ShortLogTypeList = [ShareDefine.ClientServerMsg_PushPlayerCache, ShareDefine.ClientServerMsg_PlayerPackData]
|
| | | CrossServerMsg_ShortLogTypeList = [ShareDefine.CrossServerMsg_PushPlayerPackData, ShareDefine.CrossServerMsg_ViewPlayerCacheRet]
|
| | |
|
| | | def SendMsgToCrossServer(msgType, dataMsg):
|
| | | ## 发送信息到跨服服务器上
|
| | | if GameWorld.IsCrossServer():
|
| | |
| | | if not GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_GameWorldInitOK):
|
| | | GameWorld.ErrLog("服务器未启动好,不允许向跨服服务器发送数据! %s" % (srcMsg))
|
| | | return
|
| | | if msgType in ClientServerMsg_ShortLogTypeList:
|
| | | playerID = 0
|
| | | if isinstance(dataMsg, dict):
|
| | | playerID = dataMsg.get("playerID", 0)
|
| | | if not playerID:
|
| | | playerID = dataMsg.get("PlayerID", 0)
|
| | | msgLen = len(str(srcMsg))
|
| | | GameWorld.Log("SendMsgToCrossServer => %s, playerID=%s,msgLen=%s" % (msgType, playerID, msgLen))
|
| | | else:
|
| | | GameWorld.Log("SendMsgToCrossServer => %s, %s" % (msgType, srcMsg))
|
| | | GameWorld.GetGameWorld().SendMergerChildToCenterStringData(sendMsg, len(sendMsg))
|
| | | return
|
| | |
| | | msgData = msgDict.get("Data", "")
|
| | | serverGroupID = msgDict.get("ServerGroupID", 0)
|
| | |
|
| | | GameWorld.Log("OnCrossServerReceiveMsg: %s, %s, %s" % (msgType, serverGroupID, msgDict))
|
| | | if msgType in ClientServerMsg_ShortLogTypeList:
|
| | | playerID = 0
|
| | | if isinstance(msgData, dict):
|
| | | playerID = msgData.get("playerID", 0)
|
| | | if not playerID:
|
| | | playerID = msgData.get("PlayerID", 0)
|
| | | msgLen = len(str(msgDict))
|
| | | GameWorld.Log("OnCrossServerReceiveMsg: %s, serverGroupID=%s,playerID=%s,msgLen=%s" % (msgType, serverGroupID, playerID, msgLen))
|
| | | else:
|
| | | GameWorld.Log("OnCrossServerReceiveMsg: %s, serverGroupID=%s, %s" % (msgType, serverGroupID, msgDict))
|
| | |
|
| | | if msgType == ShareDefine.ClientServerMsg_PKMatch:
|
| | | CrossRealmPK.ClientServerMsg_PKMatch(serverGroupID, msgData, tick)
|
| | |
| | | if not GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_GameWorldInitOK):
|
| | | GameWorld.ErrLog("跨服服务器未启动好,不允许向子服发送数据! serverGroupIDList=%s, srcMsg=%s" % (serverGroupIDList, srcMsg))
|
| | | return
|
| | | if msgType in CrossServerMsg_ShortLogTypeList:
|
| | | playerID = 0
|
| | | if isinstance(dataMsg, dict):
|
| | | playerID = dataMsg.get("playerID", 0)
|
| | | if not playerID:
|
| | | playerID = dataMsg.get("PlayerID", 0)
|
| | | msgLen = len(str(srcMsg))
|
| | | GameWorld.Log("SendMsgToClientServer => %s, %s, playerID=%s,msgLen=%s" % (msgType, serverGroupIDList, playerID, msgLen))
|
| | | else:
|
| | | GameWorld.Log("SendMsgToClientServer => %s, %s, %s" % (msgType, serverGroupIDList, srcMsg))
|
| | | if not serverGroupIDList:
|
| | | GameWorld.GetGameWorld().SendBroadcastMergeClient(sendMsg, len(sendMsg))
|
| | |
| | | msgType = msgDict.get("MsgType", -1)
|
| | | msgData = msgDict.get("Data", "")
|
| | | crossServerTimeStr = msgDict.get("CrossServerTime", "")
|
| | | |
| | | if msgType in CrossServerMsg_ShortLogTypeList:
|
| | | playerID = 0
|
| | | if isinstance(msgData, dict):
|
| | | playerID = msgData.get("playerID", 0)
|
| | | if not playerID:
|
| | | playerID = msgData.get("PlayerID", 0)
|
| | | msgLen = len(str(msgDict))
|
| | | GameWorld.Log("OnClientServerReceiveMsg: %s, playerID=%s,msgLen=%s" % (msgType, playerID, msgLen))
|
| | | else:
|
| | | GameWorld.Log("OnClientServerReceiveMsg: %s, %s" % (msgType, msgDict))
|
| | | |
| | | if crossServerTimeStr:
|
| | | curServerTime = int(time.time())
|
| | | crossServerTime = GameWorld.ChangeTimeStrToNum(crossServerTimeStr)
|