2台のPCがプロデューサで、1台がコンシューマである3台のPCがあります。 Pythonを使用して、どうやって互いに通信できるようにしますか?私はlocalhostでも同じことができます。私はRabbitMQウェブサイトのチュートリアルに従いました。彼らは、私がしなければならないことは、localhostではなくIPアドレスを追加することだと言いましたが、それはうまくいきません。ここで助けてください。RabbitMQを使用して1台のPCから別の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
実行しているコードを追加してください。また、端末に表示されるエラーについても言及してください。 –
まだ試したことはありますか? –