目前,我的客户端上有两个网络接口。我创建了两个独立的套接字,分别绑定到每个接口ip。现在,我还有两台服务器,每台服务器都与客户端上的一个套接字通信。我希望能够同时从两个接口(当前使用UDP或DGRAMS)接收数据(现在大约10MB,但以后会更大),但由于某些原因,在开始另一个套接字上的传输之前,必须先完成一个套接字的数据传输,因此总是会有延迟。
我已经确认绑定每个接口是成功的,并且我能够在每个套接字上与其各自的服务器通信。目前,我只是在同一个代码块中执行s1.recv()和s2.recv()。
所以我的问题是,延迟是由于使用recv()的“阻塞”特性造成的吗?另外,通过我的搜索,似乎有一些方法可以使该函数解锁?但我不确定该怎么做……这个问题会通过使用多线程来解决吗?我对多线程有点生疏,但如果它解决了我的问题,我会研究一下。如果不是,那么我如何利用这两个接口,因为我能够并行地从两个接口接收/发送?
如果有人能提供帮助,我将不胜感激。
发布于 2013-01-24 23:20:37
默认情况下,recv函数是阻塞的。这意味着该方法将暂停控制流,直到在此套接字上接收到某些内容。如果先调用sock1.recv(),然后调用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您可以使用multiprocessing或threading模块并行化这两个recv调用:
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()https://stackoverflow.com/questions/14504445
复制相似问题