skynet.dispatch 使用示例详解

skynet.dispatch(type, func)

local skynet = require "skynet"
-- 注册 Lua 类型消息的处理函数
skynet.dispatch("lua", function(session, source, cmd, ...)
    if cmd == "add" then
        local a, b = ...
        skynet.ret(skynet.pack(a + b))
    elseif cmd == "ping" then
        skynet.ret(skynet.pack("pong"))
    end
end)
skynet.start(function()
    -- 服务初始化代码
end)

local skynet = require "skynet"
-- 注册自定义协议
skynet.register_protocol {
    name = "myproto",
    id = 100,  -- 自定义协议 ID（需唯一）
    unpack = function(msg, sz)
        -- 自定义解包逻辑（如 sproto 解析）
        return myproto.decode(msg, sz)
    end
}
-- 处理自定义协议消息
skynet.dispatch("myproto", function(session, source, data)
    print("Received:", data)
    skynet.ret()  -- 无返回值
end)
skynet.start(function()
    -- 服务初始化代码
end)

skynet.dispatch("lua", function(session, source, cmd)
    if cmd == "slow_task" then
        skynet.sleep(100)  -- 挂起协程 1 秒
        skynet.ret("Done")
    end
end)

skynet.dispatch("lua", function(session, source, cmd)
    if session ~= 0 then  -- 需要响应
        skynet.ret(skynet.pack("Response"))
    end
end)

skynet.register_protocol {
    name = "binary",
    id = skynet.PTYPE_USER,  -- 自定义 ID
    unpack = function(msg, sz) return msg, sz end,  -- 不解包，直接传递原始数据
    pack = skynet.pack  -- 默认打包函数
}

skynet.dispatch("binary", function(session, source, msg, sz)
    -- 处理二进制数据
end)

skynet.dispatch("lua", function(session, source, cmd)
    if cmd == "heavy_task" then
        skynet.fork(function()
            -- 在子协程中执行耗时操作
            local result = heavy_compute()
            skynet.ret(skynet.pack(result))
        end)
    end
end)