多个连接 Lua 套接字。

我正在使用 Lua Sockets 和 TCP 制作类似 IRC 的聊天客户端和服务器。我正在尝试弄清楚如何让客户端和服务器同时监听和发送消息。由于在服务器上执行 socket:accept() 会阻止程序,直到建立连接为止。有没有方法可以接受多个连接并将它们存储到一个表中?

点赞
用户204011
用户204011

这看起来和由调度程序 Copas 解决的问题一模一样。你应该阅读此处:http://keplerproject.github.com/copas/manual.html#why - 即使你不想使用 Copas,它也会帮助你弄清楚如何解决这个问题。

基本上,你需要在 accept() 之前使用 select()。请注意,即使你这样做,accept() 也不一定会立即返回,所以你还应该使用 settimeout()(参见:http://w3.impa.br/~diego/software/luasocket/socket.html#select)。

2013-03-04 10:38:42
用户10621899
用户10621899

你需要在 accept() 之前设置 settimeout 以允许非阻塞套接字。根据 Lua socket 的文档,accept() 方法将阻塞下一个连接。

默认情况下,所有 I/O 操作都是阻塞的。也就是说,调用 send、receive 和 accept 方法将无限期地阻塞,直到操作完成为止。settimeout 方法为 I/O 方法定义了阻塞的时间限制。

以下是一个聊天服务器的工作示例。您可以使用 telnet 连接到它。

socket = require("socket") -- 导入库

-- 定义主机和端口
host = "*"
port = 8080

-- 创建套接字并绑定到一个可用端口
server = assert(socket.bind(host, port))

-- 获取本地端口号和 IP 地址
ip, port = server:getsockname()

totalclient = 0 -- 存储总连接数
clients = {} -- 例如 clients[1] = 0xSocketAddress
clientnames = {} -- 例如 clientnames[1] = "john"

-- 开始循环监听连接
while true do

  -- 新客户端连接,设置超时以不阻塞连接
  server:settimeout(0.01)
  local client, err = server:accept();

  -- 打印新客户端的信息并将其添加到表中
  if (not err) then
    clientname = client:receive()
    totalclient = totalclient + 1
    clients[totalclient] = client
    clientnames[totalclient] = clientname
    print(">> "..clientname.." connected from " .. tostring(client:getsockname()) .." at " ..os.date("%m/%d/%Y %H:%M:%S"))
  end

  -- 遍历客户端表
  for i = 1, totalclient do
    -- 如果有客户端,监听该客户端
    if (clients[i] ~= nil) then
      clients[totalclient]:settimeout(0.01) -- 防止阻塞
      clientmessage, err = clients[i]:receive() -- 接受来自客户端的数据

      -- 检查是否有任何东西发送到服务器,且没有错误发生
      if (err == nil and clientmessage ~= nil) then

        -- 遍历客户列表以发送广播消息
        else
          for j = 1, totalclient do
            -- 检查不要向说话人发送广播
            if clients[i] ~= clients[j] then
              clients[j]:send(tostring("["..clientnames[i]).."]: " ..clientmessage.."\r\n")
            end
          end--for
          logdbmessage(clientnames[i], clientmessage)
        end--if

      end--if

    end--if
  end--for

end--while
2018-11-09 01:39:58