Python：在進程之間共享消息

Question

我一直在尋找解決這個問題幾個小時的答案，但無法解決它，所以我必須在這裏發佈這個問題，我相信這是微不足道的。

我與之合作的項目有很多類和線程，我正在爲它添加小類。這些類在不同的線程中使用項目引擎執行，但我需要它們在它們自己之間進行同步 - 即類A應該能夠向類B發送消息。它們也位於不同的模塊中。

EDIT2：這個問題有一個新的解釋：看底部。

我在蟒蛇真的很初學者，我試圖通過共享隊列對象（Queue.Queue（）），並檢查它在無限循環的內容，以解決這個問題，我做了很簡單的模塊，這個對象和方法獲取和放置：

信使模塊：

import Queue 

MessageQueue = Queue.Queue() 

def GetMessage(): 
    return MessageQueue.get() 

def PutMessage(message): 
    MessageQueue.put(message) 
    return 

，並用它在兩個不同的類（進口信使），但因爲它不是全局變量，我認爲「的MessageQueue」對象有不同類別的不同實例。因爲這些類似乎在不同的隊列上工作。

如何在兩個類之間同步這樣的對象（也許有更好的方法，而不是使這個隊列成爲全局的）？

EDIT1 - 這裏是類：

A類：

from utils import messenger as m 

class Foo(): 

[...] 

def foo(): 

    [...] 
    m.put(message) 

B類：

from utils import messenger 

class Bar(): 

[...] 

def bar(): 

    [...] 
    while True:   
     print(str(m.get())) 

EDIT2：既然我現在明白我的問題好一點，在這裏是更新：

這兩個類在不同的進程中作爲不同的程序運行（可以解釋爲什麼不共享全局變量:)）。

所以問題依然存在：如何在兩個不同的程序之間進行同步？我想到的唯一解決方案是在光盤上製作一個文件並在兩個進程之間讀取它，但它看起來非常不可靠（鎖等）並且速度很慢。

你能不能告訴我不同​​的方法？

Answer 1

好吧，我用Zero MQ庫解決了這個問題。

節點A，出版商：

import zmq, time 
from datetime import datetime 

context = zmq.Context() 

#create this node as publisher 
socket = context.socket(zmq.PUB) 
socket.bind("tcp://*:25647") 


for i in range(300): 
    message = ("%d, %d" % (1, i)) 
    print str(datetime.now().time()) + "> sending: " + message 
    socket.send(message) 
    time.sleep(1) 

節點B，接收器：

import zmq, time 
from datetime import datetime 

context = zmq.Context() 
socket = context.socket(zmq.SUB) 
socket.connect("tcp://localhost:25647") 

#filter message for particular subscriber ('1') 
socket.setsockopt(zmq.SUBSCRIBE, '1') 

while True: 
    message = socket.recv() 
    print(str(datetime.now().time()) + "> received: " + str(message)) 

此設置做什麼，我想，那就是，它從一個程序傳送信號到另一個，它在相當好的時間內完成（這個非常簡單的消息，兩個整數的元組，大約在0.5毫秒內發送）。

兩個重要的事情：

1. 訂閱必須「授權」收到的消息 - 這是通過過濾消息
2. 發佈者「綁定」的第一個值來完成，用戶「連接」到插座

Answer 2

在多個實例（不同類，同一個類，不論什麼）之間共享任何對象而不使其全局化的方式是相同的：將對象傳遞給每個實例的構造函數。例如：

class Foo(object): 

    def __init__(self, m): 
     self.m = m 
     # ... 

    # ... 

    def foo(self): 
     # ... 
     self.m.put(message) 
     # ... 

# ... 

class Bar(object): 

    def __init__(self, m): 
     self.m = m 
     self.foo = Foo(m) 
     # ... 

    # ... 

    def foo(self): 
     # ... 
     self.m.put(message) 
     # ... 

# ... 

m = Queue.Queue() 
bar1 = Bar(m) 
bar2 = Bar(m) 

現在bar1，bar2，bar1.foo和bar2.foo都具有相同的m對象。