0
Helo,RabbitMQ를 사용하여 연결을 재설정했습니다.
저는 rabbitmq에서 정말 새로 왔습니다. 나는 rabbitmq 라우터를 구축하고 pika를 사용하여 Python으로 HelloWorld를 보내려고했다.
터미널에서 나는 sudo rabbitmq-server start를한다. 나는 localhost : 15672를 입력 할 수있다. 하지만 localhost에 연결하려고하면 5672가 1 초 동안 "AMQP"로 나타나고 "연결이 재설정되었습니다"라고 표시됩니다.
sudo rabbitmqctl list_connections를 할 때 내 연결이 나타나지 않습니다. netstat -tapnl을 수행 할 때 | 그렙 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를주고있다,하지만 난 내가 생각하는 모든 권리를 구성했습니다. 여기
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, []}
]}
].