亚洲欧美精品,日韩午夜在线电影,欧美精品一区二区蜜臀亚洲

跨服Lua調(diào)用

跨服Lua調(diào)用

(金慶的專欄 2017.3)

跨服Lua調(diào)用是指服務(wù)器集群內(nèi)部A服調(diào)用B服上的腳本。

服務(wù)器之間已經(jīng)實現(xiàn)RPC調(diào)用，Lua調(diào)用是Rpc調(diào)用的簡化方式。

示例：
   -- 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)

以上例子相當(dāng)于調(diào)用了其他服務(wù)器上的代碼：
   require("event.dispatcher").dispatch("Remote.ClientDisconnected", game_clt_id)

需要參數(shù)為：
* 遠(yuǎn)程服務(wù)器ID
* Lua模塊名
* Lua模塊中的函數(shù)名
* 調(diào)用參數(shù)列表

remote_runner這樣實現(xiàn)：

-- 運(yùn)行另一服務(wù)器上的Lua代碼
-- 也支持本服運(yùn)行(本服RPC調(diào)用)

local M = {}

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

-- on_result(result) 生成 rpc 回調(diào)函數(shù) 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)) -- 回調(diào)時執(zhí)行
   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服務(wù)RunLua.RunMfa實現(xiàn)。run_lua.proto如下定義

syntax = "proto3";
package svr;

// 服務(wù)器內(nèi)部跨服調(diào)用Lua
service RunLua {
    // 運(yùn)行 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;
}

服務(wù)這樣實現(xiàn)：

-- 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 金慶閱讀(467) 評論(0) 編輯收藏引用所屬分類: 2. 網(wǎng)游開發(fā)

只有注冊用戶登錄后才能發(fā)表評論。
【推薦】100%開源！大型工業(yè)跨平臺軟件C++源碼提供，建模，組態(tài)！

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

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜