查看Rabbit MQ Pika HelloWorld教程,可在此处找到:https://www.rabbitmq.com/tutorials/tutorial-one-python.html
问题是,每当我运行接收脚本时,我总是收到此错误:
Traceback (most recent call last):
File "receive.py", line 5, in <module>
pika.ConnectionParameters(host='localhost'))
File "C:\Users\Colin Warn\PycharmProjects\untitled2\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 360, in __init__
self._impl = self._create_connection(parameters, _impl_class)
File "C:\Users\Colin Warn\PycharmProjects\untitled2\venv\lib\site-packages\pika\adapters\blocking_connection.py", line 451, in _create_connection
raise self._reap_last_connection_workflow_error(error)
pika.exceptions.AMQPConnectionError
下面是我尝试运行的代码:
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(
queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
任何帮助都是非常感激的。提前感谢你。
3条答案
按热度按时间sigwle7e1#
你所需要做的就是在你的PC上安装RabbitMQ。你可以在另一个终端上使用下面的命令运行docker,然后重新运行你的代码
pgpifvop2#
您需要在计算机上安装RabbitMQ:https://rabbitmq.com/download.html
安装RabbitMQ服务器后,重新运行脚本。
1aaf6o9v3#
请执行下列步骤: