0

目前我的客户端上有两个网络接口。我创建了两个单独的套接字，它们绑定到每个接口 ip。现在我还有两台服务器，每台都与客户端上的一个套接字通信。我希望能够同时从两个接口（当前使用 UDP 或 DGRAMS）接收数据（现在约 10MB，但以后会更大），但由于某种原因，总是存在延迟，因为它必须用一个来完成数据传输在它开始在另一个套接字上传输之前。

我已经确认绑定每个接口都是成功的，并且我能够在每个套接字上与其各自的服务器进行通信。目前我只是在同一个代码块内s1.recv()执行。s2.recv()

所以我的问题是，延迟是由于 using 的“阻塞”功能recv()吗？另外通过我的搜索，似乎有办法使该功能解除阻塞？但我不确定如何去做……这会通过使用多线程来解决吗？我对多线程有点生疏，但如果它解决了我的问题，我会调查它。如果没有，那么我如何利用这两个接口，因为我能够从两个接口并行接收/发送？

如果有人可以提供帮助，我将不胜感激。

4

1 回答 1

1

该recv功能默认为阻塞。这意味着该方法将停止控制流，直到在此套接字上接收到某些内容。如果你调用sock1.recv()then sock2.recv()，第二个调用只会在套接字 1 接收到东西时到达。

您可以使用该setblocking方法进行recv非阻塞，使其立即返回，即使没有可接收的内容。但是，您可能必须轮询两个套接字以获取要读取的新字节：

s1.setblocking(False)
s2.setblocking(False)

while True:
    # In non-blocking mode, recv throws a socket.error when
    # there is nothing to receive.
    try: a = s1.recv()
    except socket.error: a = None

    try: b = s2.recv()
    except socket.error: b = None

    handle_data(a,b) # Use received bytes at your discretion

recv您可以使用multiprocessingorthreading模块并行化这两个调用：

class SocketThread(threading.Thread):
    def run():
        while True:
            a = self.sock.recv() # This time, recv in blocking mode
            handle_data(a)

t1, t2 = SocketThread(), SocketThread()
t1.sock = sock1
t1.start()

t2.sock = sock2
t2.start()
于 2013-01-24T15:20:36.533 回答