860312 跨服接口二进制流传输,需指定数据长度
| | |
| | | return
|
| | | GameWorld.Log("SendMsgToClientServer => serverGroupIDList=%s, srcMsg=%s" % (serverGroupIDList, srcMsg))
|
| | | if not serverGroupIDList:
|
| | | GameWorld.GetGameWorld().SendBroadcastMergeClient(sendMsg)
|
| | | GameWorld.GetGameWorld().SendBroadcastMergeClient(sendMsg, len(sendMsg))
|
| | | else:
|
| | | serverGroupIDList = list(set(serverGroupIDList)) # 去重
|
| | | #for serverGroupID in serverGroupIDList:
|
| | | # GameWorld.GetGameWorld().SendMergeMsgToClientByGroupID(serverGroupID, sendMsg)
|
| | | # GameWorld.GetGameWorld().SendMergeMsgToClientByGroupID(serverGroupID, sendMsg, len(sendMsg))
|
| | | jsonGroupIDInfo = cPickle.dumps(serverGroupIDList, 2)
|
| | | GameWorld.GetGameWorld().SendMergeMsgToClientByGroupList(jsonGroupIDInfo, sendMsg)
|
| | | GameWorld.GetGameWorld().SendMergeMsgToClientByGroupList(jsonGroupIDInfo, len(jsonGroupIDInfo), sendMsg, len(sendMsg))
|
| | | return
|
| | |
|
| | | def OnClientServerReceiveMsg(index, tick):
|
| | |
| | | if limitTime < curTime:
|
| | | needClearGUIDList.append([curMail.PlayerID, curMail.GUID])
|
| | |
|
| | | GameWorld.Log("ClearUpPersonalCompensation count=%s"%len(needClearGUIDList))
|
| | | |
| | | #删除过期补偿信息, 没有主动通知在线玩家
|
| | | for playerID, GUID in needClearGUIDList:
|
| | | ClearPersonalCompensation(playerID, GUID)
|