使两个python程序通信

2024-06-08 00:02:31 发布

您现在位置:Python中文网/ 问答频道 /正文

我有两个python程序无限运行。在

第一个进程使用Twisted和Autobahn从WebSocket提要接收数据。这是一个无限循环。

第二个进程使用自定义库从Pusher WebSocket feed接收数据。它也是一个无限循环

我正在寻找一种方法,使这两个进程与第三个进程通信。第三个进程必须能够与两个进程进行双向通信。因此,第三个进程必须能够推送并接收来自两个程序的消息。在

我尝试使用多处理和队列,但没有成功。在

这是第一个过程:

from twisted.internet import reactor
from autobahn.twisted.websocket import WebSocketClientFactory, WebSocketClientProtocol, connectWS
import json

class ClientProtocol(WebSocketClientProtocol):

    ...

    def onMessage(self, msg, binary):
        ...
        # Send data to third process
    ...

if __name__ == '__main__':
    factory = WebSocketClientFactory("wss://feed.com")
    factory.protocol = ClientProtocol
    connectWS(factory)
    reactor.run()

这是第二个过程:

^{pr2}$

Tags: fromimport程序进程过程factoryfeedtwisted

热门问题