RabbitMQ的连接错误

问题描述：

当我试图执行此代码（服务器代码）我得到错误：（我收到同样的错误接收器代码也）

import pika 
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host="localhost:5672")) 
channel = connection.channel() 
channel.queue_declare(queue='hello') 
channel.basic_publish(exchange='', 
        routing_key='hello', 
        body='Hello World!') 
print(" [x] Sent 'Hello World!'") 
connection.close()

错误：

Traceback (most recent call last): 
File "D:\Workspace\Luna_WS\MQ\RabbitMQ\Sample\Src\Sample.py", line 10, in <module> 
host="localhost:5672")) 
File "C:\Python34\lib\site-packages\pika\adapters\blocking_connection.py", line 339, in __init__ 
self._process_io_for_connection_setup() 
File "C:\Python34\lib\site-packages\pika\adapters\blocking_connection.py", line 374, in _process_io_for_connection_setup 
self._open_error_result.is_ready) 
File "C:\Python34\lib\site-packages\pika\adapters\blocking_connection.py", line 395, in _flush_output 
raise exceptions.ConnectionClosed() 
pika.exceptions.ConnectionClosed

我已安装:(使用Windows 7,32位）

pikka包 - pika-0.10.0-py2.py3-none-any.whl

二郎 - ESL-erlang_18.2-1-windows_i386

的RabbitMQ服务器 - RabbitMQ的服务器 - 3.6.0

我已将环境变量RABBITMQ_SERVER设置为C：\ Program Files \ RabbitMQ Server \ rabbitmq_server-3.6.0和RABBITMQ_BASE到C：\ Program Files \ RabbitMQ服务器 –

是否还有更多环境变量需要设置使其工作 –

答

尝试拆分主机置于单独的主机和端口连接参数：

connection = pika.BlockingConnection(
       pika.ConnectionParameters(host="localhost", port=5672))

否，它不是与host =“localhost”，port = 5672）） –

@NagaumadeviPalaparthy：哦，值得一试。它是用单独的参数记录的，所以你应该保留这个调用。 – mhawke

@NagaumadeviPalaparthy：你确定你的rabbitmq-server正在使用主机'localhost'和端口'5672'吗？如果不是，您将看到与您显示的相同的错误。而且，实际上，它适用于我使用'host =“localhost”，port = 5672'但是host =“localhost：5672”'因为你的回溯而失败。所以'host'和'port'参数都是必需的。你需要仔细检查你的服务器。 – mhawke

RabbitMQ的连接错误

相关推荐