擅长:python、mysql、java
<p>好的,我用<a href="http://zeromq.org" rel="nofollow">Zero MQ</a>库解决了这个问题。在</p>
<p><strong>节点A,发布者:</strong></p>
<pre><code>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)
</code></pre>
<p><strong>节点B,接收方:</strong></p>
^{pr2}$
<p>这个设置实现了我想要的,也就是说,它将信号从一个程序传输到另一个程序,并且它在相当好的时间内完成(这个非常简单的消息,两个整数的元组,大约在0.5毫秒内发送)。在</p>
<p>两件重要的事:</p>
<ol>
<li>订阅必须是“授权”接收消息-这是通过过滤消息的第一个值来完成的</li>
<li>发布者正在“绑定”,订阅者“正在连接”到套接字</li>
</ol>