☰

为什么我会收到这个“pika.exceptions.AMQPConnectionError”？

tag-icon • tag-icon python 22.04 python3 rabbitmq
为什么我会收到这个“pika.exceptions.AMQPConnectionError”？

我一直在尝试运行一个名为“send.py”的文件来向队列发送消息RabbitMQ。每当我尝试运行此文件时，我都会收到“pika.exceptions.AMQPConnectionError”。我没有RabbitMQ已安装，无法用于此项目。我有另一台设备已安装RabbitMQ安装了必须通过运行“receive.py”文件来接收我发送到队列的消息。我被告知我需要安装“AMQP 库”，但我已经安装了“pika”。我不确定如何解决这个问题。任何帮助都将不胜感激。

错误如下：

Traceback (most recent call last):
  File "/home/user/file/send.py", line 6, in <module>
    connection = pika.BlockingConnection(
  File "/usr/local/lib/python3.10/dist-packages/pika/adapters/blocking_connection.py", line 360, in __init__
    self._impl = self._create_connection(parameters, _impl_class)
  File "/usr/local/lib/python3.10/dist-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection
    raise self._reap_last_connection_workflow_error(error)
pika.exceptions.AMQPConnectionError

这是我的 send.py 代码：

#!/usr/bin/env python
import pika

credentials = pika.PlainCredentials(username='username', password='password')

connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='ipaddress', credentials=credentials))

channel = connection.channel()

channel.queue_declare(queue='Hello')

channel.basic_publish(exchange='', routing_key='Hello', body='Hey!')
print(" [x] Sent 'Hello World!' ")
connection.close()

答案1

我在 macos 上遇到了同样的问题，reseason 没有安装 rabbitmq。我使用以下命令解决了该问题。

在Linux中：

sudo apt-get update
sudo apt-get install rabbitmq-server

在 macOS 中：

brew update
brew install rabbitmq

最后你需要开始。

sudo service rabbitmq-server start

相关内容