python - Django:与 TCP 服务器通信(扭曲？)

Question

我有一个 Django 应用程序，它需要与远程 TCP 服务器通信。该服务器将发送包，根据包的内容，我需要向数据库添加条目并通知应用程序的其他部分。我还需要主动向TCP服务器发送请求，比如当用户导航到某个页面时，我想订阅TCP服务器上的某个流。因此双向沟通都需要有效。

到目前为止，我使用以下解决方案:

我写了一个自定义的 Django 命令，我可以从它开始

python manage.py listen

此命令将使用 reactor.connectTCP(IP, PORT, factory) 启动一个双绞套接字服务器，因为它是一个 django 命令，我将可以访问数据库和所有其他部分我的申请。

但由于我还希望能够向 TCP 服务器发送一些东西，由某个 django View 触发，我有一个额外的套接字服务器，它在我扭曲的应用程序中通过 reactor.listenTCP(PORT, server_factory )。

然后我将在我的 Django 应用程序中的一个新线程中直接连接到该服务器:

class MSocket:

    def __init__(self):
        self.stopped = False
        self.socket = None
        self.queue = []
        self.process = start_new_thread(self.__connect__, ())
        atexit.register(self.terminate)


    def terminate(self):
        self.stopped = True
        try:
            self.socket.close()
        except:
            pass

    def __connect__(self):
        if self.stopped:
            return
        attempts = 0
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        while True and not self.stopped:
            try:
                print "Connecting to Socket Server..."
                self.socket.connect(("127.0.0.1", settings.SOCKET_PORT))
                print "Connection Successful!"
                for msg in self.queue:
                    self.socket.send(msg)
                self.queue = []
                break
            except:
                pause = min(int(round(1.2**attempts)), 30)
                print "Connection Failed! Try again in " + str(pause) + " seconds."
                sleep(pause)
                attempts += 1

        self.__loop__()

    def __loop__(self):
        if self.stopped:
            return
        while True and not self.stopped:
            try:
                data = self.socket.recv(1024)
            except:
                try:
                    self.socket.close()
                except:
                    pass
                break
            if not data:
                break
        self.__connect__()

    def send(self, msg):
        try:
            self.socket.send(msg)
            return True
        except:
            self.queue.append(msg)
            return False


m_socket = MSocket()

m_socket 然后将被主 urls.py 导入，以便它以 django 开头。

所以我的设置看起来很不错:

发送到 TCP 服务器:

Django (connect:8001) ------->  (listen:8001) Twisted (connect:4444) ------> (listen:4444) TCP-Server

从 TCP 服务器接收

TCP-Server (listen:4444) ------> (connect:4444) Twisted ---(direct access)---> Django

一切似乎都是这样工作的，但我担心这不是一个很好的解决方案，因为我必须打开这个额外的 TCP 连接。所以我现在的问题是，是否可以优化设置(我确信可以)以及如何完成。

Answer 1

除非你猴子修补 Django(正如@pss 所提到的)，否则这是行不通的我遇到了类似的情况，所以这就是我所做的。

1. 运行一个单独的扭曲守护进程。
2. 要从 Django 到 Twisted 进行通信，请使用 Unix 套接字。本地 twisted 服务器可以监听 Unix 套接字 (AF_UNIX)，Django 可以简单地连接到该套接字。这将避免通过 TCP 堆栈
3. 要从 Twisted 到 Django 进行通信，您有多种选择，a) 用数据调用 Django urlb) 启动脚本(Django 管理命令)c) 使用 celery 启动上面的 Django 命令d) 使用队列(zeromq 或 rabbit)并让 Django 管理命令监听队列(首选)

使用最后一个选项，您可以获得更好的吞吐量、耐用性并且可以很好地扩展。