牛马服务端消息处理机制

meinvwudi

QF接收

--所有发送给服务端的网络消息触发
function handlerequest(actor, msgid, arg1, arg2, arg3, sMsg)
    -- LOGPrint("handlerequest", type(msgid),msgid, arg1, arg2, arg3, sMsg)
    --跨服禁止使用
    if cfg_KuaFuJinZhi[msgid] then
        local isKuaFu = checkkuafu(actor)
        if isKuaFu then
            Player.sendmsgEx(actor, "跨服中,禁止使用该功能!#249")
            return
        end
    end
    local lastRequestTime = preventFrequentRequestsCache[actor] or 0
    local currentRequestTime = os.clock()
    if currentRequestTime - lastRequestTime <= 0.2 then
        if not filterOutMsgid[msgid] then
            -- Player.sendmsgEx(actor, "请求频繁#249")
            return
        end
    else
        preventFrequentRequestsCache[actor] = os.clock()
    end

    if msgid == ssrNetMsgCfg.sync then
        login(actor)
        return
    end
    --派发
    local result, errinfo = pcall(Message.dispatch, actor, msgid, arg1, arg2, arg3, sMsg)
    if not result then
        local name = getbaseinfo(actor, ConstCfg.gbase.name)
        local msgName = ssrNetMsgCfg[msgid]
        local err = "网络消息派发错误：消息ID=" .. msgid .. "  消息Name=" .. msgName .. "   "
        release_print(name, err, errinfo, arg1, arg2, arg3, sMsg)
    end
end

meinvwudi

派发处理

Message = {}

--这个表包含了定义的所有网络消息
local dispatch_handler = {}


---发送消息
---* actor:	玩家对象
---* msgID:	消息ID
---* arg1:	参数1
---* arg2:  参数2
---* arg3:	参数3
---* data: 	消息体
function Message.sendmsg(actor, msgID, arg1, arg2, arg3, data)
    local str = data and tbl2json(data) or nil
    --LOGPrint("sendmsg msgID=", msgID, arg1, arg2, arg3, str)
    --LOGWrite("sendmsg msgID=", msgID, arg1, arg2, arg3, str)
    sendluamsg(actor, msgID, arg1, arg2, arg3, str)
end

function Message.dispatch(actor, msgID, arg1, arg2, arg3, str)
    --LOGPrint("dispatch msgID=", msgID, arg1, arg2, arg3, str)
    --LOGWrite("dispatch msgID=", msgID, arg1, arg2, arg3, str)
    
    local msgName = ssrNetMsgCfg[msgID]
    if not msgName then return end

    local module, method = msgName:match "([^.]*)_(.*)"
    local target = dispatch_handler[module]
    if not target or not target[method] then return end
    --如果是条件开启模块并且模块还未开启不处理网络消息
    -- local moduleid = target.ID
    -- if moduleid and xxx[moduleid] then
        --如果未开启
        --return
    -- end
    --派发
    -- printusetime(actor,1)
    local data = (str and str ~= "") and json2tbl(str) or nil
    target[method](actor, arg1, arg2, arg3, data)
    -- printusetime(actor,2)
    
end

function Message.RegisterNetMsg(msgType, target)
    dispatch_handler[msgType] = target
end

meinvwudi

消息注册

--网络
ssrNetMsgCfg = safeRequire("QuestDiary/net/NetMsgCfg.lua") --消息配置
safeRequire("QuestDiary/net/Message.lua")                  --网络消息函数封装

local ssrNetMsgCfg = {}

local cfg_ssrNetMsg = include("QuestDiary/cfgcsv/cfg_ssrNetMsg.lua") --绑定网络消息配置

for k, v in pairs(cfg_ssrNetMsg) do
    ssrNetMsgCfg[k] = v.value
end

local t = {}
for msgName,msgID in pairs(ssrNetMsgCfg) do
    t[msgName] = msgID
    t[msgID] = msgName
end
ssrNetMsgCfg = t
return ssrNetMsgCfg

meinvwudi

消息ID配置关联文件

local config = {
	sync = {
		value = 100,
	},
	Global = {
		value = "Global",
	},
	Global_ClickNpcResponse = {
		value = 1000,
	},
}