Соединение было сброшено с использованием RabbitMQ

Question

Helo,

Я действительно новый на rabbitmq. Я пытался установить маршрутизатор rabbitmq и отправить ему HelloWorld в python, используя pika.

В терминале i do sudo rabbitmq-server start. Я могу ввести localhost: 15672. Но когда я пытаюсь подключиться к localhost: 5672 появляется «AMQP» в течение одной секунды, а затем «Соединение было сброшено».

При выполнении sudo rabbitmqctl list_connections мое соединение не появляется. При выполнении netstat -tapnl | Grep 5672 представляется следующим образом:

tcp  0  0 0.0.0.0:15672   0.0.0.0:*    LISTEN  -     
tcp  0  0 127.0.0.1:5672   0.0.0.0:*    LISTEN  -     
tcp  0  0 0.0.0.0:25672   0.0.0.0:*    LISTEN  - 

Мой питон дает ошибку ProbableAccessDeniedError, но я настроил все в порядке, я думаю. Вот snipet:

import pika 
from pika.exceptions import ProbableAccessDeniedError 
from pika.exceptions import ProbableAuthenticationError 


if __name__ == '__main__': 

    credentials = pika.PlainCredentials('name', 'pass) 
    # change the ip in here! 
    parameters = pika.ConnectionParameters(
        host='localhost', port=5672, vhost='test', credentials=credentials) 
    try: 
     connection = pika.BlockingConnection(parameters) 

     channel = connection.channel() 

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

    except ProbableAuthenticationError: 
     print("Authetication Error") 
    except ProbableAccessDeniedError: 
     print("Authetication Denied") 
    finally: 
     if channel: 
      channel.close() 
     if connection: 
      connection.close() 

А вот мой rabbitmq.config:

[ 
    {rabbit, [ 
    % Network Connectivity 
    % ==================== 
    {tcp_listeners,[{"127.0.0.1",5672}]}, 
    {num_tcp_acceptors, 5}, 
    {handshake_timeout, 10000}, 
    % Default User/VHost 
    % ==================== 
    {default_vhost,  <<"test">>}, 
    {default_user,  <<"name">>}, 
    {default_pass,  <<"pass">>}, 
    {default_permissions, [<<".*">>, <<".*">>, <<".*">>]}, 
    {loopback_users, []} 
    ]} 
]. 

Так что я думаю, проблема из-за локального сервера: 5672. Есть идеи?

Answer 1

http://www.rabbitmq.com/man/rabbitmqctl.1.man.html

Вы должны добавить пользователя RabbitMQ,

rabbitmqctl add_user username password 

контроль ваш пользователь

rabbitmqctl list_users 

добавить ВХост

rabbitmqctl add_vhost test 

пользователь ВХост разрешения

rabbitmqctl set_permissions -p/username ".*" ".*" ".*"