pika.exceptions.ConnectionClosed：连接到172.18.0.3:5672失败：[Errno 111]连接被拒绝

我试图连接一个Pika客户端与RabbitMQ服务器。他们都在不同的码头图像上，他们在同一个码头网络上。设置我的网络pika.exceptions.ConnectionClosed：连接到172.18.0.3:5672失败：[Errno 111]连接被拒绝

docker network create my_first_net

我运行的是RabbitMQ的图像rabbitmq作为

docker run -d --network my_first_net --hostname rabbitmqhost -p 35672:15672 -p 45672:5672 rabbitmq

我运行鼠害的图像ms2-1作为

docker run --network my_first_net --hostname rabbitmq ms2-1

这里是高原鼠兔的代码 - 客户ms2.py：

import pika 

exchange = 'gateway_exchange' 

myName = 'microservice2' 

myKey = '#.ms2.#' 
gwKey = 'gw' 

credentials = pika.PlainCredentials('guest', 'guest') 
parameters = pika.ConnectionParameters('rabbitmq', 5672, '/', credentials) 

def send(key, message): 
    send_conn = pika.BlockingConnection(parameters) 
    send_ch = send_conn.channel() 

    send_ch.exchange_declare(exchange=exchange, 
          exchange_type='topic') 

    send_ch.basic_publish(exchange=exchange, 
          routing_key=key, 
          body=message) 
    print(" [x] Sent %r:%r" % (key, message)) 
    send_conn.close() 

def receive(): 
    connection = pika.BlockingConnection(parameters) 
    channel = connection.channel() 
    channel.exchange_declare(exchange=exchange, 
          exchange_type='topic') 

    result = channel.queue_declare(exclusive=True) 
    queue_name = result.method.queue 

    binding_key = myKey 
    channel.queue_bind(exchange=exchange, 
         queue=queue_name, 
         routing_key=binding_key) 

    print(' [*] Waiting for messages. To exit press CTRL+C') 

    def callback(ch, method, properties, body): 
     print(" [x] Received %r:%r" % (method.routing_key, body)) 
     send('Response-from-' + myName + '-to-.' + gwKey, body) 

    channel.basic_consume(callback, 
          queue=queue_name, 
          no_ack=True) 
    channel.start_consuming() 

if __name__ == "__main__": 
    receive()

我收到以下错误，当我尝试运行鼠兔形象

Traceback (most recent call last): 
    File "ms2.py", line 61, in <module> 
    receive() 
    File "ms2.py", line 36, in receive 
    connection = pika.BlockingConnection(parameters) 
    File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 374, in __init__ 
    self._process_io_for_connection_setup() 
    File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 414, in _process_io_for_connection_setup 
    self._open_error_result.is_ready) 
    File "/usr/local/lib/python2.7/dist-packages/pika/adapters/blocking_connection.py", line 468, in _flush_output 
    raise exceptions.ConnectionClosed(maybe_exception) 
pika.exceptions.ConnectionClosed: Connection to 172.18.0.3:5672 failed: [Errno 111] Connection refused

的RabbitMQ的容器的IP地址是172.18.0.2当我做docker inspect，它是68.50.13.82当我curl ifconfig.me容器内。我确认容器正在使用`netstat -ap tcp | grep -i“listen”

我认为Errno 111与身份验证错误有关，但我无法连接到来自我的计算机的任何IP地址。

我的下一步应该怎样解决这个问题？

编辑：我意识到，在运行的RabbitMQ服务器虽然我没有添加--name标志，所以我删除容器，并开始一个新的为：

docker run -d --network my_first_net --hostname rabbitmqhost --name rabbitmq -p 15672:15672 -p 5672:5672 rabbitmq

但现在我得到的错误：

Traceback (most recent call last): 
    File "ms2.py", line 61, in <module> 
    receive() 
    File "ms2.py", line 36, in receive 
    connection = pika.BlockingConnection(parameters) 
    File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 374, in __init__ 
    self._process_io_for_connection_setup() 
    File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 414, in _process_io_for_connection_setup 
    self._open_error_result.is_ready) 
    File "/usr/local/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 466, in _flush_output 
    raise maybe_exception 
socket.gaierror: [Errno 8] nodename nor servname provided, or not known

来源

2017-09-14 nrl7

的问题正在发生的事情，因为你重复使用相同的主机名，而运行鼠容器

docker run --network my_first_net --hostname rabbitmq ms2-1

不应将您的rabbitmq容器名称设置为相同的主机名。我跑了相同的步骤，我可以连接

来源

2017-09-14 15:34:16

pika.exceptions.ConnectionClosed：连接到172.18.0.3:5672失败：[Errno 111]连接被拒绝

回答

相关问题