使用循环接收和发送多次消息时出现Lua TCP服务器问题

我需要通过套接字使客户端和服务器通信。客户端通过字符串"arquivo"告诉服务器它想要一个特定的消息,并且得到长度为10KB的消息。如果客户端想使用相同的字符串再次请求消息,两者都必须保持连接开放。我可以实现1个交换,然后关闭连接。然而当我放入while时,服务器显然发送了消息,但除非我关闭客户端运行的终端窗口,否则消息永远无法到达客户端。我在不同的终端窗口中运行每个服务端和客户端的代码,并使用只传递一次消息然后关闭连接的服务器测试了客户端的代码,消息通过了。以下是存在问题的服务器代码:

filename = "file10KB.txt"
file = assert(io.open(filename, "r"))
msg = file:read("*a")
file:close()

socket = require("socket")

host = "*"
port =  8080

print("绑定主机 '" .. host .. "' 和端口 " .. port .. "...")

server = assert(socket.bind(host, port))
server:setoption("reuseaddr", true)
ipaddress, socketport = server:getsockname()
assert(ipaddress, socketport)

print("等待客户端连接 " .. ipaddress .. ":" .. socketport .. "...")

connection = assert(server:accept())
connection:setoption("keepalive", true)
connection:settimeout(10)

print("已连接!")

while true do
    print("等待请求...")
    data, errormsg = connection:receive()

    if data == "arquivo" then
        print("接收到请求,发送消息...")
        assert(connection:send(msg .. "\n"))
        print("消息已发送!")
    elseif not errormsg then
        print("无效请求。")
        break
    else
        print("错误消息:" .. errormsg)
        break
    end
end

还有,我的客户端代码:

socket = require("socket")

host = "localhost"
port = 8080

print("正在尝试连接服务器 '" .. host .. "' 和端口 " .. port .. "...")

client = assert(socket.connect(host, port))

client:setoption("keepalive", true)
client:setoption("reuseaddr", true)
client:settimeout(10)

print("已连接!")

repeat
    print("发送消息请求...")
    assert(client:send("arquivo" .. "\n"))

    print("消息请求已发送!等待消息...")
    data, errormsg = client:receive("*a")

    if data then
        print("已接收到消息!")
        print(data)
    else
        print("无法接收到消息。")
        break
    end
until not client

我对Lua和套接字都很新,并且我遵循了在网上找到的一些教程,例如http://www.portugal-a-programar.pt/topic/36175-aprendendo-a-usar-lua-socket/(葡萄牙语)。我只希望你们中的任何人都可以为我提供一些指导。顺便说一下,我正在使用Mac OS X机器,不知道这是否有帮助。

点赞
用户207421
用户207421

当我等待一段时间后,服务器显然已经发送了消息,但除非我关闭客户端运行的终端窗口,否则它永远不会到达客户端。

我不知道这是什么意思。关闭终端窗口应该会关闭客户端,这几乎不可能导致它突然接收到消息。

然而,这还有许多问题,太长了注释无法解决:

  • 您需要在绑定之前设置 SO_REUSEADDR。之后太晚了。
  • 您根本不需要在客户端设置它,但如果要设置,必须在连接之前。
  • 服务器中的sockname检查是无意义的。它不可能失败。
  • 您的服务器只接受一个连接。
  • 您的服务器从未关闭连接。
  • 您的服务器似乎不能正确识别流的结束。
  • 您的客户端从未关闭连接。
2016-03-29 23:15:44
用户6131742
用户6131742

问题在客户端代码的以下行中:

data, errormsg = client:receive("*a")

选项*a仅在连接关闭时接收,并将其更改为*l或像以下一样什么都不加可以解决问题。

data, errormsg = client:receive()
2016-03-30 11:27:13