Python：非阻塞套接字或异步 I/O答案

【问题标题】：Python: Non-blocking socket or Asynchronos I/OPython：非阻塞套接字或异步 I/O
【发布时间】：2011-09-16 12:15:01
【问题描述】：

我是 Python 新手，目前必须编写一个 Python 套接字以作为脚本运行，该脚本通过 TCP/IP（气象站）与设备通信。
该设备充当服务器端（通过 IP:PORT 侦听、接受连接、接收请求、传输数据）。
我只需要发送一条消息，接收答案，然后和平而漂亮地关闭并关闭套接字。

try:
    comSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    sys.stderr.write("[ERROR] %s\n" % msg[1])
    sys.exit(1)

try:
   comSocket.connect((''))
except socket.error, msg:
   sys.stderr.write("[ERROR] %s\n" % msg[1])
   sys.exit(2)

comSocket.send('\r')
comSocket.recv(128)
comSocket.send('\r')
comSocket.recv(128)
comSocket.send('\r\r')
comSocket.recv(128)

comSocket.send('1I\r\r3I\r\r4I\r\r13I\r\r5I\r\r8I\r\r7I\r\r9I\r\r')

rawData = comSocket.recv(512)

comSocket.shutdown(1)
comSocket.close()

我遇到的问题是：
通信通道不可靠，设备速度慢。因此，有时设备响应的消息长度为 0（只是一个 ACK），我的代码将冻结并永远等待响应。
这段代码包含涉及 SOCKET 的部分，整个代码将在 CRON 下运行，因此冻结不是可取的行为。

我的问题是：
在 Python 中处理这种行为的最佳方法是什么，这样代码就不会冻结并永远等待，而是会尝试继续进行下一次发送（或类似的）。

【问题讨论】：

你应该看看 Python 的 Twisted 库。它是一个异步网络框架，可以让这一切变得更容易。
虽然使用 Twisted 库可能会奏效，但一条消息的整个库似乎有点矫枉过正。也许您需要让 CRON 打开一个子进程，而您的套接字通信在一个单独的线程中进行。这样您就可以避免阻塞问题。
@Andrea 因为我对发布的问题有类似的问题。 Twisted 不是为服务器端设计的吗？如何修改它以在客户端使用？
@Hangon 这些不是本质上不同的场景，都是 CLI Python

标签： python sockets nonblocking

【解决方案1】：

您可以尝试超时方法，例如 Russel 代码，也可以使用非阻塞套接字，如下面的代码所示。它永远不会在socket.recv 阻塞，您可以在循环中使用它来重试任意多次。这样你的程序就不会在超时时挂起。这样，您可以测试数据是否可用，如果没有，您可以做其他事情，稍后再试。

socket.setblocking(0)
while (retry_condition):
    try:
        data = socket.recv(512)
    except socket.error:
        '''no data yet..'''

【讨论】：

【解决方案2】：

我会为此推荐 eventlet 和绿色线程。

Twisted 是一个很好的库，但是对于这样一个简单的用例来说，学习曲线有点陡峭。

查看一些示例here。

【讨论】：

【解决方案3】：

尝试，在接收之前，在套接字上设置一个超时：

comSocket.settimeout(5.0)
try:
    rawData = comSocket.recv(512)
except socket.timeout:
    print "No response from server"

【讨论】：