我在两台服务器之间有一个代理客户端。主服务器 S1 在 Internet 上。代理客户端和第二服务器S2位于同一个内联网中。我有以下代码(为简单起见省略了部分),它负责将来自 S2 的数据“按原样”转发到 S1:
fsctimeout = 0.01
function send_data(sock, data, i, l)
local p,err,q = sock:send(data, i, l)
if(err == "timeout" and q ~= l) then
fsctimeout = fsctimeout * 2
sock:settimeout(fsctimeout)
send_data(sock, data, q + 1, l)
fsctimeout = fsctimeout / 2
sock:settimeout(fsctimeout)
end
end
while not e do
rect, _, st = socket.select({csc, fsc}, nil, .01) --csc is S1, fsc is S2 sockets.
if(rect[fsc] ~= nil and csc ~= nil) then
local data, err, part = fsc:receive(8192)
if(data ~= nil) then
send_data(csc, data, 1, data:len())
totalBytesFromFP = totalBytesFromFP + data:len()
end
if(part ~= nil) then
send_data(csc, part, 1, part:len())
totalBytesFromFP = totalBytesFromFP + part:len()
end
end
end
我编写了该send_data
函数,以便如果发送超时,它将使套接字超时加倍并重试。但是现在有时程序会卡在send_data
函数内部而无法成功发送数据。我可以在这里做什么?(我正在测试尝试发送一个 1MB 的文件,对于少量数据,这个问题似乎没有发生。)