Die Verbindung wurde zurückgesetzt mit RabbitMQ

Question

Helo,

Ich bin wirklich neu bei rabbitmq. Ich habe versucht, einen Rabbitmq Router einzurichten und ihm eine HelloWorld in Python mit Pika zu schicken.

In Terminal ich Sudo Rabbitmq-Server starten. Ich kann localhost eingeben: 15672. Aber wenn ich versuche, mich mit localhost zu verbinden: 5672 erscheint "AMQP" für eine Sekunde und dann "Die Verbindung wurde zurückgesetzt".

Wenn sudo rabbitmqctl list_connections ausgeführt wird, wird meine Verbindung nicht angezeigt. Wenn netstat -tapnl | grep 5672 scheint es so:

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  - 

Mein Python gibt den Fehler ProbableAccessDeniedError, aber ich habe alles in Ordnung konfiguriert, denke ich. Hier ist ein 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() 

Und hier ist mein 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, []} 
    ]} 
]. 

Also ich denke, das Problem aufgrund des localhost: 5672. Irgendeine Idee?

Answer 1

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

Sie einen rabbitmq Benutzer hinzufügen müssen,

rabbitmqctl add_user username password 

Kontrolle Benutzer

rabbitmqctl list_users 

Add vHost

rabbitmqctl add_vhost test 

Benutzer vHost Berechtigungen

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