Как использовать клиент Python AMQP для ActiveMQ

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: Сервер неожиданно закрыл соединение

Answer 1

Пика использует AMQP 0,9, а ActiveMQ использует 1,0. Эти протоколы несовместимы.

Прочтите самое начало Пика документов .

Прочитать первую строку в ActiveMQ AMQP документах .

Answer 2

Похоже, параметры соединения по умолчанию настроены правильно.

Попробуйте просто

import amqp

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

host = HOST + ":" + PORT

conn = amqp.connection.Connection()
conn.connect()
print(conn.is_closing)

Если вы посмотрите на реализацию Connection (), это

def __init__(self, host='localhost:5672', userid='guest', password='guest',
                 login_method=None, login_response=None, 

...

Так что по умолчанию все правильно и работает для меня локально, используя rabbit mq.

Надеюсь, это поможет!