rabbitmq 程序运行Pika时抛出AMQPConnectionError

nwlls2ji  于 2022-12-04  发布在  RabbitMQ
关注(0)|答案(3)|浏览(204)

查看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()

任何帮助都是非常感激的。提前感谢你。

sigwle7e

sigwle7e1#

你所需要做的就是在你的PC上安装RabbitMQ。你可以在另一个终端上使用下面的命令运行docker,然后重新运行你的代码

docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
pgpifvop

pgpifvop2#

您需要在计算机上安装RabbitMQ:https://rabbitmq.com/download.html
安装RabbitMQ服务器后,重新运行脚本。

1aaf6o9v

1aaf6o9v3#

请执行下列步骤:

  1. sudo apt-获取安装rabbitmq-服务器
  2. sudo systemctl启动rabbitmq-服务器
  3. sudo systemctl启用rabbitmq服务器

相关问题