skynet.rawcall使用应用场景分析

 更新时间:2025年04月09日 16:50:24   作者:monGyrate  
skynet.rawcall 是 Skynet 框架中用于直接传递原始二进制数据的低级通信接口,适用于需要绕过自动序列化/反序列化、手动控制内存或实现高性能传输的场景,下面给大家介绍skynet.rawcall使用应用场景分析,感兴趣的朋友一起看看吧

skynet.rawcall 是 Skynet 框架中用于直接传递原始二进制数据的低级通信接口,适用于需要绕过自动序列化/反序列化、手动控制内存或实现高性能传输的场景。以下是其详细用法和典型应用场景:

核心特性

非自动序列化

  • 直接传递 lightuserdata(C 指针)+ size(数据长度),不调用 skynet.pack/skynet.unpack
  • 适用于已序列化的二进制数据或需要避免序列化开销的场景。

同步调用

  • 与 skynet.call 类似,发送请求后阻塞等待响应。
  • 返回值为接收方通过 skynet.ret 返回的原始数据指针(需手动处理)。

内存管理

    • 发送方和接收方需明确内存所有权,避免野指针或内存泄漏。

函数原型

local response_ptr, response_size = skynet.rawcall(target, typename, data_ptr, data_size)
  • 参数
    • target:目标服务地址(如 skynet.self() 或服务句柄)。
    • typename:消息类型(字符串,需接收方注册对应的处理协议)。
    • data_ptr:原始数据指针(lightuserdata)。
    • data_size:数据长度(number)。
  • 返回值
    • response_ptr:响应数据的指针(lightuserdata)。
    • response_size:响应数据的长度(number)。

使用场景

场景 1:高性能二进制传输(如文件转发)

-- 发送方(直接传递文件内容指针)
local file_content = read_file_as_binary("data.bin")
local ptr, size = convert_to_lightuserdata(file_content) -- 假设已获得指针和大小
-- 同步调用目标服务,获取响应
local resp_ptr, resp_size = skynet.rawcall(target_service, "binary", ptr, size)
-- 处理响应数据(需手动解析)
process_response(resp_ptr, resp_size)
skynet.free(resp_ptr)  -- 手动释放响应内存(若由接收方分配)

场景 2:自定义序列化协议(如 Protocol Buffers)

-- 发送方(使用 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)  -- 获取数据指针和长度
-- 发送原始数据并等待响应
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)

场景 3:跨服务共享内存(避免拷贝)

-- 发送方(传递共享内存指针)
local shared_buf = skynet.malloc(1024)  -- 分配共享内存
fill_buffer(shared_buf, 1024)  -- 填充数据
-- 请求目标服务处理共享内存
local resp_ptr, resp_size = skynet.rawcall(target, "shared_mem", shared_buf, 1024)
-- 处理完毕后释放内存
skynet.free(shared_buf)
if resp_ptr ~= nil then
    skynet.free(resp_ptr)
end

配套接收方实现

接收方需注册对应的协议类型,并手动处理原始数据指针:

-- 接收方服务
skynet.register_protocol {
    name = "binary",
    id = skynet.PTYPE_USER,  -- 自定义类型(如 100)
    unpack = function(ptr, size) return ptr, size end,  -- 直接透传指针和大小
    pack = function(ptr, size) return ptr, size end,     -- 响应时不打包
}
skynet.dispatch("binary", function(session, source, ptr, size)
    -- 处理原始数据
    local result = process_binary_data(ptr, size)
    -- 返回响应(假设 result 是已分配的指针和大小)
    skynet.ret(result.ptr, result.size)
end)

与 skynet.call 的对比

特性skynet.rawcallskynet.call
数据传输原始指针(无序列化)自动调用 skynet.pack/unpack
性能更高(避免序列化开销)较低(适合结构化数据)
内存管理需手动管理指针生命周期框架自动管理
适用场景大文件、自定义协议、共享内存常规 RPC、结构化数据交互
错误处理需自行处理指针有效性框架自动捕获异常

注意事项

内存安全

  • 确保传递的指针在接收方使用期间有效。
  • 若数据由发送方分配,接收方不应释放;若需返回新数据,接收方应分配新内存。

协议一致性

  • 发送方和接收方必须使用相同的协议类型(typename)。
  • 接收方需正确注册协议处理函数(skynet.register_protocol)。

避免野指针

  • 使用 skynet.mallocskynet.free 替代原生 malloc/free,确保内存池统一管理。

典型错误示例

-- 错误:传递临时栈指针(可能导致崩溃)
local tmp_data = "Hello"
local ptr = get_pointer(tmp_data)
skynet.rawcall(target, "test", ptr, #tmp_data)  -- tmp_data 可能已被回收
-- 正确:分配堆内存并传递
local heap_ptr = skynet.malloc(1024)
fill_data(heap_ptr)
skynet.rawcall(target, "test", heap_ptr, 1024)
skynet.free(heap_ptr)  -- 确保接收方不再使用后释放

总结

使用场景优先级

  • 高频二进制传输(如音视频流、日志批量处理)。
  • 自定义序列化协议(如 Protobuf、FlatBuffers)。
  • 零拷贝共享内存(大规模数据共享,避免复制开销)。
  • 与 C 模块交互(直接传递 C 层分配的内存块)。

核心原则

  • 仅在必要时使用 skynet.rawcall,优先选择更安全的 skynet.call
  • 严格管理内存生命周期,结合 skynet.malloc/skynet.free 使用。
  • 确保发送方和接收方对数据格式和协议类型有明确约定。

到此这篇关于skynet.rawcall使用详解及应用场景的文章就介绍到这了,更多相关skynet.rawcall使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:

相关文章

  • WebStorm 2019.2安装配置方法图文教程

    WebStorm 2019.2安装配置方法图文教程

    这篇文章主要为大家详细介绍了WebStorm 2019.2安装配置方法图文教程,文中安装步骤介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-09-09
  • DVWA下载、安装、使用(漏洞测试环境搭建)的详细教程

    DVWA下载、安装、使用(漏洞测试环境搭建)的详细教程

    这篇文章主要介绍了DVWA下载、安装、使用(漏洞测试环境搭建)的详细教程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-10-10
  • Trie树_字典树(字符串排序)简介及实现

    Trie树_字典树(字符串排序)简介及实现

    有时,我们会碰到对字符串的排序,若采用一些经典的排序算法,则时间复杂度一般为O(n*lgn),但若采用Trie树,则时间复杂度仅为O(n)
    2014-03-03
  • 聊聊Druid register mbean error的问题

    聊聊Druid register mbean error的问题

    这篇文章主要介绍了Druid register mbean error的问题,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-11-11
  • 总结一些你可能不知道的ip地址

    总结一些你可能不知道的ip地址

    IP对大家来说应该再熟悉不过了,但其实IP地址有一些不为人知的事情,可能你并不知道。例如短IP、不同进制的ip等,所以下面这篇文章主要给大家总结介绍了一些你可能不知道的ip地址知识,需要的朋友可以参考借鉴,下面来一起看看吧。
    2017-07-07
  • gradle+shell实现自动系统签名

    gradle+shell实现自动系统签名

    这篇文章主要介绍了gradle+shell实现自动系统签名的相关资料,需要的朋友可以参考下
    2019-08-08
  • git pull时冲突的几种解决方式(小结)

    git pull时冲突的几种解决方式(小结)

    这篇文章主要介绍了git pull时冲突的几种解决方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • 编程趣事:当下流行编程语言的”讨厌”程度排行榜

    编程趣事:当下流行编程语言的”讨厌”程度排行榜

    这篇文章主要介绍了编程趣事:当下流行编程语言的”讨厌”程度排行榜,和小编的感觉一样,需要的朋友可以参考下
    2014-07-07
  • chatgpt 1020 错误码成功解决的三种方案(推荐)

    chatgpt 1020 错误码成功解决的三种方案(推荐)

    造成1020错误的主要原因是代理问题,当打开代理时,登录该网站会直接显示上述错误“Access denied Error code 1020”,怎么解决这个问题呢,下面小编给大家带来了chatgpt 1020 错误码成功解决的三种方案,感兴趣的朋友一起看看吧
    2023-02-02
  • 一文详解软件测试需求分析是什么

    一文详解软件测试需求分析是什么

    需求分析是掌握被测系统的过程,一般测试和开发人员都要进行需求分析,测试方做的需求分析称为测试需求分析,这篇文章主要给大家介绍了关于软件测试需求分析的相关资料,需要的朋友可以参考下
    2007-04-04

最新评论