快捷導(dǎo)航

skynet.rawcall使用應(yīng)用場(chǎng)景分析

更新時(shí)間：2025年04月09日 16:50:24 作者：monGyrate

skynet.rawcall 是 Skynet 框架中用于直接傳遞原始二進(jìn)制數(shù)據(jù)的低級(jí)通信接口,適用于需要繞過(guò)自動(dòng)序列化/反序列化、手動(dòng)控制內(nèi)存或?qū)崿F(xiàn)高性能傳輸?shù)膱?chǎng)景,下面給大家介紹skynet.rawcall使用應(yīng)用場(chǎng)景分析,感興趣的朋友一起看看吧

skynet.rawcall 是 Skynet 框架中用于直接傳遞原始二進(jìn)制數(shù)據(jù)的低級(jí)通信接口，適用于需要繞過(guò)自動(dòng)序列化/反序列化、手動(dòng)控制內(nèi)存或?qū)崿F(xiàn)高性能傳輸?shù)膱?chǎng)景。以下是其詳細(xì)用法和典型應(yīng)用場(chǎng)景：

核心特性

非自動(dòng)序列化：

直接傳遞 lightuserdata（C 指針）+ size（數(shù)據(jù)長(zhǎng)度），不調(diào)用 skynet.pack/skynet.unpack。
適用于已序列化的二進(jìn)制數(shù)據(jù)或需要避免序列化開(kāi)銷的場(chǎng)景。

同步調(diào)用：

與 skynet.call 類似，發(fā)送請(qǐng)求后阻塞等待響應(yīng)。
返回值為接收方通過(guò) skynet.ret 返回的原始數(shù)據(jù)指針（需手動(dòng)處理）。

內(nèi)存管理：

- 發(fā)送方和接收方需明確內(nèi)存所有權(quán)，避免野指針或內(nèi)存泄漏。

函數(shù)原型

local response_ptr, response_size = skynet.rawcall(target, typename, data_ptr, data_size)

參數(shù)：
- target：目標(biāo)服務(wù)地址（如 skynet.self() 或服務(wù)句柄）。
- typename：消息類型（字符串，需接收方注冊(cè)對(duì)應(yīng)的處理協(xié)議）。
- data_ptr：原始數(shù)據(jù)指針（lightuserdata）。
- data_size：數(shù)據(jù)長(zhǎng)度（number）。
返回值：
- response_ptr：響應(yīng)數(shù)據(jù)的指針（lightuserdata）。
- response_size：響應(yīng)數(shù)據(jù)的長(zhǎng)度（number）。

使用場(chǎng)景

場(chǎng)景 1：高性能二進(jìn)制傳輸（如文件轉(zhuǎn)發(fā)）

-- 發(fā)送方（直接傳遞文件內(nèi)容指針）
local file_content = read_file_as_binary("data.bin")
local ptr, size = convert_to_lightuserdata(file_content) -- 假設(shè)已獲得指針和大小
-- 同步調(diào)用目標(biāo)服務(wù)，獲取響應(yīng)
local resp_ptr, resp_size = skynet.rawcall(target_service, "binary", ptr, size)
-- 處理響應(yīng)數(shù)據(jù)（需手動(dòng)解析）
process_response(resp_ptr, resp_size)
skynet.free(resp_ptr)  -- 手動(dòng)釋放響應(yīng)內(nèi)存（若由接收方分配）

場(chǎng)景 2：自定義序列化協(xié)議（如 Protocol Buffers）

-- 發(fā)送方（使用 Protobuf 編碼）
local protobuf = require "protobuf"
local msg = { id = 1001, name = "Alice" }
local encoded_data = protobuf.encode("MyProto", msg)
local ptr, size = get_data_pointer(encoded_data)  -- 獲取數(shù)據(jù)指針和長(zhǎng)度
-- 發(fā)送原始數(shù)據(jù)并等待響應(yīng)
local resp_ptr, resp_size = skynet.rawcall(target, "proto", ptr, size)
local decoded_resp = protobuf.decode("ResponseProto", resp_ptr, resp_size)
skynet.free(resp_ptr)

場(chǎng)景 3：跨服務(wù)共享內(nèi)存（避免拷貝）

-- 發(fā)送方（傳遞共享內(nèi)存指針）
local shared_buf = skynet.malloc(1024)  -- 分配共享內(nèi)存
fill_buffer(shared_buf, 1024)  -- 填充數(shù)據(jù)
-- 請(qǐng)求目標(biāo)服務(wù)處理共享內(nèi)存
local resp_ptr, resp_size = skynet.rawcall(target, "shared_mem", shared_buf, 1024)
-- 處理完畢后釋放內(nèi)存
skynet.free(shared_buf)
if resp_ptr ~= nil then
    skynet.free(resp_ptr)
end

配套接收方實(shí)現(xiàn)

接收方需注冊(cè)對(duì)應(yīng)的協(xié)議類型，并手動(dòng)處理原始數(shù)據(jù)指針：

-- 接收方服務(wù)
skynet.register_protocol {
    name = "binary",
    id = skynet.PTYPE_USER,  -- 自定義類型（如 100）
    unpack = function(ptr, size) return ptr, size end,  -- 直接透?jìng)髦羔樅痛笮?
    pack = function(ptr, size) return ptr, size end,     -- 響應(yīng)時(shí)不打包
}
skynet.dispatch("binary", function(session, source, ptr, size)
    -- 處理原始數(shù)據(jù)
    local result = process_binary_data(ptr, size)
    -- 返回響應(yīng)（假設(shè) result 是已分配的指針和大?。?
    skynet.ret(result.ptr, result.size)
end)

與 skynet.call 的對(duì)比

特性	`skynet.rawcall`	`skynet.call`
數(shù)據(jù)傳輸	原始指針（無(wú)序列化）	自動(dòng)調(diào)用 `skynet.pack`/`unpack`
性能	更高（避免序列化開(kāi)銷）	較低（適合結(jié)構(gòu)化數(shù)據(jù)）
內(nèi)存管理	需手動(dòng)管理指針生命周期	框架自動(dòng)管理
適用場(chǎng)景	大文件、自定義協(xié)議、共享內(nèi)存	常規(guī) RPC、結(jié)構(gòu)化數(shù)據(jù)交互
錯(cuò)誤處理	需自行處理指針有效性	框架自動(dòng)捕獲異常

注意事項(xiàng)

內(nèi)存安全：

確保傳遞的指針在接收方使用期間有效。
若數(shù)據(jù)由發(fā)送方分配，接收方不應(yīng)釋放；若需返回新數(shù)據(jù)，接收方應(yīng)分配新內(nèi)存。

協(xié)議一致性：

發(fā)送方和接收方必須使用相同的協(xié)議類型（typename）。
接收方需正確注冊(cè)協(xié)議處理函數(shù)（skynet.register_protocol）。

避免野指針：

使用 skynet.malloc 和 skynet.free 替代原生 malloc/free，確保內(nèi)存池統(tǒng)一管理。

典型錯(cuò)誤示例

-- 錯(cuò)誤：傳遞臨時(shí)棧指針（可能導(dǎo)致崩潰）
local tmp_data = "Hello"
local ptr = get_pointer(tmp_data)
skynet.rawcall(target, "test", ptr, #tmp_data)  -- tmp_data 可能已被回收
-- 正確：分配堆內(nèi)存并傳遞
local heap_ptr = skynet.malloc(1024)
fill_data(heap_ptr)
skynet.rawcall(target, "test", heap_ptr, 1024)
skynet.free(heap_ptr)  -- 確保接收方不再使用后釋放