2016-08-04 5 views
0

Helo、RabbitMQを使用して接続をリセットしました

私はrabbitmqで本当に新しいです。私はrabbitmqルーターを確立し、pikaを使ってPythonでHelloWorldを送ろうとしていました。

端末では、sudo rabbitmq-server startを実行します。私はlocalhost:15672を入力することができます。しかし、私がlocalhostに接続しようとすると、5672が1秒間 "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  - 

は私のpythonにエラー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。何か案が?あなたはRabbitMQのユーザーを追加する必要があります

答えて

0

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

rabbitmqctl add_user username password 

制御ユーザー

rabbitmqctl list_users 

追加バーチャルホスト

rabbitmqctl add_vhost test 

ユーザーのバーチャルホストの権限

rabbitmqctl set_permissions -p/username ".*" ".*" ".*" 
関連する問題