Docker、rabbitMQ和pike连接被拒绝
Docker、rabbitMQ和pike连接被拒绝
提问于 2020-12-09 20:49:46
我正在尝试使用docker-compose从内部docker连接到rabbitMQ。从容器外部运行的程序连接到"image: rabbitmq:3-management“没有问题。
没有设置密码或其他任何东西。
在进一步查看错误消息后，pika似乎尝试使用IPv6而不是IPv4进行连接。查看文档时，我想不出一种连接IPv4的方法。
故障发生在
self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
Error log
rabbitMQ_1 | 2020-12-09 12:41:42.332 [info] <0.685.0> Ready to start client connection listeners
rabbitMQ_1 | 2020-12-09 12:41:42.333 [info] <0.988.0> started TCP listener on [::]:5672
listener_1 | ERROR:pika.adapters.utils.io_services_utils:Socket failed to connect: <socket.socket fd=9, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('127.0.0.1', 36782)>; error=111 (Connection refused)
listener_1 | ERROR:pika.adapters.utils.connection_workflow:TCP Connection attempt failed: ConnectionRefusedError(111, 'Connection refused'); dest=(<AddressFamily.AF_INET: 2>, <SocketKind.SOCK_STREAM: 1>, 6, '', ('127.0.0.1', 5672))
listener_1 | ERROR:pika.adapters.utils.connection_workflow:AMQPConnector - reporting failure: AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused')
listener_1 | ERROR:pika.adapters.utils.io_services_utils:<socket.socket fd=9, family=AddressFamily.AF_INET6, type=SocketKind.SOCK_STREAM, proto=6, laddr=('::', 0, 0, 0)>.connect(('::1', 5672, 0, 0)) failed: OSError(99, 'Cannot assign requested address')
listener_1 | ERROR:pika.adapters.utils.connection_workflow:TCP Connection attempt failed: OSError(99, 'Cannot assign requested address'); dest=(<AddressFamily.AF_INET6: 10>, <SocketKind.SOCK_STREAM: 1>, 6, '', ('::1', 5672, 0, 0))
listener_1 | ERROR:pika.adapters.utils.connection_workflow:AMQPConnector - reporting failure: AMQPConnectorSocketConnectError: OSError(99, 'Cannot assign requested address')
listener_1 | ERROR:pika.adapters.utils.connection_workflow:AMQP connection workflow failed: AMQPConnectionWorkflowFailed: 2 exceptions in all; last exception - AMQPConnectorSocketConnectError: OSError(99, 'Cannot assign requested address'); first exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused').
listener_1 | ERROR:pika.adapters.utils.connection_workflow:AMQPConnectionWorkflow - reporting failure: AMQPConnectionWorkflowFailed: 2 exceptions in all; last exception - AMQPConnectorSocketConnectError: OSError(99, 'Cannot assign requested address'); first exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused')
listener_1 | ERROR:pika.adapters.blocking_connection:Connection workflow failed: AMQPConnectionWorkflowFailed: 2 exceptions in all; last exception - AMQPConnectorSocketConnectError: OSError(99, 'Cannot assign requested address'); first exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused')
listener_1 | ERROR:pika.adapters.blocking_connection:Error in _create_connection().
listener_1 | Traceback (most recent call last):
listener_1 | File "/usr/local/lib/python3.8/site-packages/pika/adapters/blocking_connection.py", line 450, in _create_connection
listener_1 | raise self._reap_last_connection_workflow_error(error)
listener_1 | pika.exceptions.AMQPConnectionErrordocker-compose.yml
version: '3'
services:
rabbitMQ:
image: rabbitmq:3-management
ports:
- "15672:15672"
- "5672:5672"
login:
build:
context: .
dockerfile: Dockerfile.login
restart: on-failure
listener:
build:
context: .
dockerfile: Dockerfile.listener
restart: on-failure回答 1
Stack Overflow用户
发布于 2020-12-10 16:21:27
docker-compose不设置本地主机网络。这意味着每个服务都有自己的名称。在这种情况下，应该更改主机。
self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
should be changed to
self.connection = pika.BlockingConnection(pika.ConnectionParameters(host='rabbitMQ'))页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/65217124
复制相关文章
相似问题
腾讯云开发者
