python - 如何为 ActiveMQ 使用 AMQP python 客户端

Question

我使用amqp客户端连接 ActiveMQ 代理。

import amqp

USER = "guest"
PASSWORD = "guest"
HOST = 'localhost'
PORT = '5672'

host = HOST + ":" + PORT

conn = amqp.connection.Connection(host=host,userid=USER,password=PASSWORD,login_method='AMQPLAIN',ssl=True)
conn.connect()

出现错误：OSError：服务器意外关闭连接

标签： pythonactivemqamqp

Answer 1

Pika 使用 AMQP 0.9，而 ActiveMQ 使用 1.0。这些协议是不兼容的。

阅读Pika 文档的开头部分。

阅读ActiveMQ AMQP 文档的第一行。