无法使用鼠标连接到远程rabbitmq服务器

Question

我正在尝试使用鼠标连接到我的远程rabbitmq,但我收到Connectionclosed()错误.我已经在guest.user用户的rabbit.config中进行了必要的更改,以允许所有连接以及同样的连接从我的Java代码开始工作.我甚至尝试使用所有权限创建一个新用户并连接它,但它仍然无效.虽然相同的代码在我的localhost上工作正常.任何人都可以让我知道我在这里做错了什么？

def queue_message(message, queue):
    credentials = pika.PlainCredentials('xxxx', 'xxxx')
    parameters = pika.ConnectionParameters('remote-server',
                                   5672,
                                    '/',
                                    credentials)
   connection = pika.BlockingConnection(parameters)
   channel = connection.channel()
   channel.queue_declare(queue='python_update_queue')
   channel.basic_publish(exchange='update.fanout',
                  body=message)
   logger.info("Sent message: {} to queue: {}".format(message, queue))
   print 'message sent'
   connection.close()

以下是我得到的错误:

app/project/rabbitmq.py" in queue_message
connection = pika.BlockingConnection(parameters)
env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py" in __init__
     self._process_io_for_connection_setup()
env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py" in ss_io_for_connection_setup
                        self._open_error_result.is_ready)
env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py" in _flush_output
         raise exceptions.ConnectionClosed

Answer 1

为连接参数添加连接超时 - 您可能遇到了超时问题,即网络中连接速度不够快.

此外,您的代码显式调用connection.close()...这可能是您的连接关闭的原因