Lua sockets - 异步事件

在当前的lua sockets实现中,我看到我们必须安装一个定时器来周期性地回调,以便我们通过非阻塞API检查是否收到了任何信息。

这很好,但是在UDP情况下,如果发送方发送了大量信息,我们是否会冒失失去数据。假设另一个设备通过UDP发送了一个2MB的照片,并且我们每100毫秒检查一次socket接收。以2MBps的速度,底层系统必须在我们的调用查询底层TCP堆栈之前存储200Kbit。

有没有一种方式可以在收到特定socket上的数据时触发事件,而不是我们现在必须进行轮询的方式?

点赞
用户734069
用户734069

Lua 是天生单线程的;不存在所谓的“事件”。无法中断正在执行的 Lua 代码。因此,即使您可以创建一个看起来像事件的东西,但只有在调用一个轮询可用事件的函数时才能获得一个事件。

通常情况下,如果要使用 Lua 进行此类低级别的工作,则选择了错误的工具。您应该使用 C 或其他工具来访问此类数据,然后在准备好时将其传递给 Lua。

2012-10-15 04:50:07
用户1442917
用户1442917

你可能正在使用非阻塞的 select() 来“轮询”套接字并检查是否有新数据可用。据我所知,Luasocket 没有提供其他接口以查看是否有新数据可用,但如果您担心这样做每秒进行 10 次时花费太多时间,考虑编写一个简化版本,仅检查您需要的一个套接字,避免创建和丢弃 Lua 表。如果这不是一个选项,请考虑将 {} 替换为 nil,对于那些您不需要读取的列表,使用静态表而非临时表:

local rset = {socket}
... 后面
...select(rset, nil, 0)

而不是

...select({socket}, {}, 0)
2012-10-15 05:56:54
用户1358661
用户1358661

我使用 lua-ev 处理所有 IO 多路复用。它非常易于使用,并可以与 Lua(及其 function)完美匹配。它基于 select/poll/epoll 或 kqueue,并且性能非常出色。

local ev = require 'ev'
local loop = ev.Loop.default
local udp_sock -- 你的 udp socket 实例
udp_sock:settimeout(0) -- 设置为非阻塞
local udp_receive_io = ev.IO.new(function(io, loop)
    local chunk, err = udp_sock:receive(4096)
    if chunk and not err then
        -- 处理数据
    end
end, udp_sock:getfd(), ev.READ)

udp_receive_io:start(loop)

loop:loop() -- 无限循环直到被阻塞

在我看来,Lua+luasocket+lua-ev 是构建高效和健壮的网络应用程序(针对嵌入式设备/环境)的超级搭档。还有更强大的工具可供选择!但如果你的资源有限,Lua 是一个不错的选择!

2012-10-19 08:07:13