我有三台PC,其中两台PC是生产商,一台是消费者。使用Python,我如何让他们相互沟通。我可以在localhost上做同样的事情,我遵循RabbitMQ网站上的教程。在那里他们提到我所要做的就是添加IP地址而不是本地主机,但这不起作用。请在这里帮忙。使用RabbitMQ将消息从一台PC发送到另一台
编辑:
我已经做了以下修改我的代码使用鼠来验证用户名和密码。我仍收到错误
为receive.py的代码如下:
import pika
credentials = pika.PlainCredentials('sneha', 'sneha')
connection = pika.BlockingConnection(pika.ConnectionParameters('[email protected]', 5672, '/', credentials))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
我收到以下错误:
Traceback (most recent call last):
File "receive.py", line 4, in <module>
connection = pika.BlockingConnection(pika.ConnectionParameters('[email protected]', 5672, '/', credentials))
File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 339, in __init__
self._process_io_for_connection_setup()
File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 374, in _process_io_for_connection_setup
self._open_error_result.is_ready)
File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 395, in _flush_output
raise exceptions.ConnectionClosed()
pika.exceptions.ConnectionClosed
添加您正在运行的代码。如果您在终端上看到还提及任何错误 –
您尝试过什么? –