在线日本成人,国产麻豆日韩欧美久久,久久xxxx精品视频

跨服Lua調用

跨服Lua調用

(金慶的專欄 2017.3)

跨服Lua調用是指服務器集群內部A服調用B服上的腳本。

服務器之間已經實現RPC調用，Lua調用是Rpc調用的簡化方式。

示例：
   -- Tell remote server svr_id that game_clt_id is disconnected.
   local arguments = { "Remote.ClientDisconnected", game_clt_id }
   remote_runner.run_mfa(svr_id, "event.dispatcher",
       "dispatch", arguments)

以上例子相當于調用了其他服務器上的代碼：
   require("event.dispatcher").dispatch("Remote.ClientDisconnected", game_clt_id)

需要參數為：
* 遠程服務器ID
* Lua模塊名
* Lua模塊中的函數名
* 調用參數列表

remote_runner這樣實現：

-- 運行另一服務器上的Lua代碼
-- 也支持本服運行(本服RPC調用)

local M = {}

local log = require("log"):new("remote_runner")
local pb = require("protobuf")
local serpent = require("serpent")

-- on_result(result) 生成 rpc 回調函數 cb(resp_str)
local function get_mfa_cb(on_result)
   if (not on_result) then return nil end
   assert("function" == type(on_result))

   local cb = function(resp_str)
       assert("string" == type(resp_str))
       local resp = pb.decode("svr.RunLuaMfaResponse", resp_str)
       local ok, copy = serpent.load(resp.returned_dump)
       assert(ok, "Run mfa returns invalid value.")
       log:debug("RunLuaMfaResponse: %s", serpent.line(copy))
       on_result(table.unpack(copy)) -- 回調時執行
   end -- cb

   return cb
end -- get_mfa_cb()

-- Run module function with arguments on remote server.
-- 示例 rum_mfa(123, "event.dispatcher", "dispatch", {"EventName", 1,2,3}, nil)
function M.run_mfa(svr_id, module_name, function_name, arguments, on_result)
   assert("number" == type(svr_id))
   assert("string" == type(module_name))
   assert("string" == type(function_name))
   assert("table" == type(arguments))
   assert(nil == on_result or "function" == type(on_result))
   log:debug("Request to call Svr_%s %s.%s()", svr_id, module_name, function_name)
   local req = {
       module_name = module_name,
       function_name = function_name,
       arguments_dump = serpent.dump(arguments)
   }
   local req_str = pb.encode("svr.RunLuaMfaRequest", req)
   local cb = get_mfa_cb(on_result)
   c_rpc.request_svr(svr_id, "svr.RunLua", "RunMfa", req_str, cb)
end -- run()

return M

通過Rpc服務RunLua.RunMfa實現。run_lua.proto如下定義

syntax = "proto3";
package svr;

// 服務器內部跨服調用Lua
service RunLua {
    // 運行 module.function(...arguments...)
    rpc RunMfa(RunLuaMfaRequest) returns (RunLuaMfaResponse);
}

message RunLuaMfaRequest {
    string module_name = 1;
    string function_name = 2;
    // arguments_dump = serpent.dump({1,2,3})
    string arguments_dump = 3;
}

message RunLuaMfaResponse {
    // Get returned table copy:
    // local ok, copy = serpent.load(returned_dump)
    string returned_dump = 1;
}

服務這樣實現：

-- svc_run_lua.lua
-- Run lua by other servers.

local M = {}

local log = require("log"):new("svc_run_lua")
local pb = require("protobuf")

-- Run module.function(...arguments...)
function M.RunMfa(ctx, content)
   local req = pb.decode("svr.RunLuaMfaRequest", content)
   log:debug("RunMfa %s.%s", req.module_name, req.function_name) -- todo: from where?
   local mod = require(req.module_name)
   local fun = mod[req.function_name]
   local ok, arguments = serpent.load(serpent.dump(req.arguments_dump))
   assert(ok, "Illegal arguments.")
   local result_table = table.pack(fun(table.unpack(arguments)))
   local resp = { returned_dump = serpent.dump(result_table) }
   local resp_str = pb.encode("svr.RunLuaMfaResponse", resp)
   c_rpc.reply_to(ctx, resp_str)
end -- Run()

return M

posted on 2017-03-02 17:12 金慶閱讀(476) 評論(0) 編輯收藏引用所屬分類: 2. 網游開發

只有注冊用戶登錄后才能發表評論。


相關文章: How are dtLinks created in NavMesh UE4 Blueprint Multiple Event BeginPlay 第9代游戲主機 Canvas Scaler 的3種模式幀同步是否允許客戶端指定命令幀號 rpc應答太快造成請求超時測試 tolua 例子 TestErrorStack lua變量缺少local造成unity死鎖 C# tolua 之間互傳 byte[] Unity使用異步grpc

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜