Python Pika 和 RabbitMQ 连接发布

Question

尝试使用 Python 将数据发送到 RabbitMQ 队列。

我尚未配置服务器，但它正在为其他进程运行。我有一个有效的登录名，可以毫无问题地访问网络输出。

RabbitMQ 为 python 提供的示例代码使用 Pika：

#!/usr/bin/env python
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='xxx.xxx.xxx.xxx:xxxxx'))
channel = connection.channel()

channel.queue_declare(queue='Test')

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

这运行并让我开始：

pika.exceptions.ConnectionClosed

没什么可继续的，但安全的假设是登录问题，因为示例代码没有任何登录信息。

所以我添加了它。

import pika
import sys
try:

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


    connection = pika.BlockingConnection(pika.ConnectionParameters('xxx.xxx.xxx.xxx',
                                           xxxxx,
                                           'virtualhostnamehere',
                                           credentials,))

    channel = connection.channel()
    channel.queue_declare(queue='Test')

    channel.basic_publish(exchange='amq.direct',
                          body='Hello World!')
    print(" [x] Sent 'Hello World!'")
except:
    e = sys.exc_info()[0]
    print e

它似乎在给我之前停留了好几分钟：

<class 'pika.exceptions.IncompatibleProtocolError'>

服务器运行其他服务正常，但我似乎无法确定我做错了什么。

登录是正确的。虚拟主机名称正确。楼主说得对。交易所名称正确。

希望能指出正确的方向。

更新：

我也尝试使用 URLParameters 得到相同的结果。

parameters = pika.URLParameters('amqp://username:password@xxx.xxx.xxx.xxx:xxxxx/notmyvhostname')
connection = pika.BlockingConnection(parameters)

Answer 1

但我想端口不会改变任何东西。它的端口是 15672，登录名与我用来获取浏览器输出的登录名相同。

使用端口 5672 - 或您为 AMQP 侦听器设置的任何默认端口。端口 15672 用于 Web UI 访问，这是通过 HTTP 完成的，因此出现不兼容协议错误