Python 网络客户端，尝试响应服务器响应

Question

该应用程序是一个 WxPython 客户端/服务器设置，有多个客户端连接到服务器并使用双工网络协议(protocol)。

我过去曾让 Twisted 与 AMP 结合使用，但它并没有完全针对应用程序中的架构进行切割，最终使事情变得过于复杂。

因此对于服务器，我已经设置了带有 ThreadingMixIn 的 SocketServer。目前我正在处理服务器的缓冲区/命令队列，但这不是问题所在。

在客户端，我可以执行所有由 UI 中的事件触发的正常数据发送，没有太多问题。我目前一直在尝试让客户端在不阻塞整个应用程序的情况下收听响应。所以我想把它放在一个线程中，但它应该从现在被注释掉的部分开始，还是应该完全不同地处理而我只是没有看到它？

简而言之:我希望客户端向服务器发送命令并监听任何响应，而不会阻塞/停止整个应用程序。

下面的代码是原型(prototype)代码，如魔法值和其他硬编码数据等典型错误请见谅，最终代码会有所不同。

import socket
import threading
import time


class CommandProxy(object):
    def __init__(self, host, port):
        self.host = host
        self.port = port

    def close(self):
        if self.connection:
            self.connection.close()

    def connect(self):
        try:
            self.connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.connection.connect((self.host, self.port))
        except socket.error as e:
            print "Socket error: {0}".format(e)

    def send_command(self, command, *kw):
        datalist = ' '.join(kw)
        data = command + ' ' + datalist + '\x00'

        print 'DATA: {0}'.format(data)

        self._write(data)

#        while True:
#            data = self._read()
#            if data == 0:
#                break
#
#        print "DATA RECEIVED: {0}".format(data)

    def _read(self):
        data = self.connection.recv(1024)
        return data

    def _write(self, bytes):
        self.connection.sendall(bytes)


if __name__ == '__main__':
    HOST, PORT = 'localhost', 1060

    proxy = CommandProxy(HOST, PORT)
    proxy.connect()
    try:
        while True:
            proxy.send_command('ID', '1')
            time.sleep(2)

    except KeyboardInterrupt:
        print "Interrupted by user"
    except socket.error as e:
        print "Socket error: {0}".format(e)
    except Exception as e:
        print "something went wrong: {0}".format(e)
    finally:
        proxy.close()

Answer 1

我认为您误解了单线程方法还是多线程方法会使您的应用程序或多或少变得复杂。您现在正在努力解决的问题是(例如)Twisted 开箱即用地为您解决的众多问题之一。

人们对 Twisted 最常见的提示是，它让他们以一种他们不习惯的方式奇怪地构建他们的代码。然而，当您使用像 wxPython 这样的 GUI 库时，您已经接受了这个约束。 Twisted 的事件驱动架构与所有流行的 GUI 工具包的事件驱动架构完全一样。只要您继续使用 wxPython，同时使用 Twisted 就不会强制您做任何else您不想做的事情。

另一方面，切换到线程将意味着您需要非常小心地访问共享数据结构，您将无法有效地进行单元测试，并且出现的许多问题只有在其他人参与时才会出现运行您的应用程序 - 因为它们的核心数量与您不同，或者它们的网络具有不同的延迟特性，或者其他任何导致您的线程代码以您从未体验过的方式运行的因素。如果格外小心，您仍然可以写出有用的东西，但这会困难得多。

由于您尚未在此处发布任何基于 Twisted 的代码，因此我无法就如何使事情尽可能简单给出任何具体建议。但是，我建议您再看看非线程解决方案。加入 twisted-python@twistedmatrix.com 邮件列表，跳上 freenode 上的#twisted，或发布更多关于它的 stackoverflow 问题。很多人会很乐意提供帮助。 :)