如何获得无阻塞套接字connect（）？

Question

我这里有一个很简单的问题。我需要同时与许多主机进行通信，但是我真的不需要任何同步，因为每个请求都足够自给自足。

因此，我选择使用异步套接字，而不是发送垃圾邮件。现在我确实有一个小问题：

异步的东西就像一个咒语一样工作，但是当我连接到100个主机时，我得到100个超时（超时= 10秒），然后我等待1000秒，只是发现我所有的连接都失败了。

有什么办法也可以使套接字连接无阻塞吗？我的套接字已经设置为nonBlocking，但是对connect（）的调用仍然处于阻塞状态。

减少超时不是可接受的解决方案。

我正在Python中执行此操作，但我猜编程语言在这种情况下并不重要。

我真的需要使用线程吗？

Answer 1

您还需要并行化连接，因为设置超时时套接字会阻塞。或者，您无法设置超时，而是使用选择模块。

您可以使用asyncore模块中的dispatcher类进行此操作。看一下基本的HTTP客户端示例。该类的多个实例在连接时不会互相阻塞。您可以使用线程轻松地做到这一点，而且我认为使跟踪套接字超时变得更容易，但是由于您已经在使用异步方法，因此您最好还是走在同一个轨道上。

例如，以下内容适用于我的所有Linux系统

import asyncore, socket

class client(asyncore.dispatcher):
    def __init__(self, host):
        self.host = host
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connect((host, 22))

    def handle_connect(self):
        print 'Connected to', self.host

    def handle_close(self):
        self.close()

    def handle_write(self):
        self.send('')

    def handle_read(self):
        print ' ', self.recv(1024)

clients = []
for i in range(50, 100):
    clients.append(client('cluster%d' % i))

asyncore.loop()

在cluster50-cluster100中，有许多机器无响应或不存在。这将立即开始打印：

Connected to cluster50
  SSH-2.0-OpenSSH_4.3

Connected to cluster51
  SSH-2.0-OpenSSH_4.3

Connected to cluster52
  SSH-2.0-OpenSSH_4.3

Connected to cluster60
  SSH-2.0-OpenSSH_4.3

Connected to cluster61
  SSH-2.0-OpenSSH_4.3

...

但是，这没有考虑必须阻塞的getaddrinfo。如果您在解决dns查询时遇到问题，则必须等待一切。您可能需要自己收集DNS查询，并在异步循环中使用IP地址

如果您想要比异步异步开发工具更大的工具包，请查看Twisted
Matrix
。入门有些繁琐，但这是您可以获得的python最好的网络编程工具包。