私は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のユーザーを追加する必要があります