LuaLanes和LuaSockets

我正在编写一个小的 Lua 应用程序(使用 LuaSocket,如果有影响),它使用套接字与外部世界通信。我试图并行地发起多个请求,所以我想到了 LuaLanes。在 laneTest 函数中,我遇到了问题,它无法访问 SOCKET(打印这个变量将会得到一个错误)。然后我尝试通过安装最新版本的 Lanes 来解决该问题,但是在我安装后,我仍然无法访问套接字并得到同样的错误消息,而且我也查看了一些其他解决方案。因此,我认为没有使用 Lanes 的基于协程的方案。

点赞
用户837856
用户837856

Lua Lanes 为每一个 lane 创建了一个全新(但很小)的 Lua 状态。任何传递的 upvalues 或者参数都是拷贝而不是引用;这就意味着您整个 clients 表将会被拷贝,包括它所包含的 sockets。

错误发生的原因是因为 sockets 是 userdata 类型,而 Lua Lanes 不知道如何复制(拷贝)它们,其中需要一些 C 模块的通知。不幸的是,LuaSocket 提供不了这样的提示。(虽然有方法可绕过此问题,但要慎重处理:LuaSocket 不是线程安全的,而且同步错误非常难以追踪。)

虽然这不能解决您的问题,但请注意您需要在生成的 lane 中 require LuaSocket;这不是默认拷贝的。

解决方案!

这些方案按照易于实施程度排序(大多数来源于我的另一个答案在这里)。

单线程轮询

重复调用 LuaSocket 中的轮询函数:

  • 阻塞型:调用 socket.select,不用任何时间参数然后等待 socket 可读。
  • 非阻塞型:调用 socket.select,将 timeout 参数设置为 0 并使用连接到您正在读取的 socket 上的 sock:settimeout(0)

简单地重复调用这些函数即可。建议使用 协程调度器 来实现非阻塞版本,以允许程序的其他部分继续执行而不会造成过多的延迟。

(如果您采用此解决方案,请查看 Paul 的回答。)

双线程轮询

您的主线程不处理任何 socket。相反,它会生成另一个 lane,该 lane 会 require LuaSocket,处理所有客户端并通过 linda 与主线程通信。

这可能是您最可行的选择。

多线程轮询

与上面相同,除了每个线程处理所有客户端的一个子集(1:1 是可能的,但是在客户端数量较大时会出现收益递减的情况)。

我已经做了一个简单的示例,可在此处获得。它依赖于 Lua Lanes 3.4.0(GitHub repo)和经修补的LuaSocket 2.0.2(sourcepatchblog post re' patch)。

结果令人鼓舞,但如果您从中衍生出代码,应该重新设计我的示例代码。

LuaJIT + ENet

ENet 是一个非常好的库。它提供了 TCP 和 UDP 的完美结合:在需要的情况下可靠,在此情况下则不可靠。它还抽象了操作系统的特定细节,就像LuaSocket一样。您可以使用 Lua API 将其绑定,也可以通过 LuaJIT的 FFI 直接访问它(建议这样做)。

2012-11-04 20:30:50
用户1442917
用户1442917

Programming Lua 上有关于非抢占式多线程(使用协程)的示例,你可以直接使用。我认为,在你的用例中,协程将是更好的解决方案。

此外,还有一个名为copas库的库,它自称为“基于协程的分发器,可以被 TCP/IP 服务器使用”,但实际上你也可以使用它来异步发送请求(使用 addthreadstep 调用的组合)。

2012-11-04 22:18:27