Ошибка подключения RabbitMQ: java.net.ConnectException: соединение отклонено ⇐ JAVA

[Anonymous]

У меня есть два очень простых Java-приложения (издатель-потребитель), которые подключаются к серверу RabbitMQ с помощью ConnectionFactory.newConnection(...).
Мой докер -compose.yml выглядит следующим образом:

Код: Выделить всё

services:
publisher:
build: ./publisher/
networks:
- messaging
depends_on:
rabbitmq:
condition: service_healthy
consumer:
build: ./consumer/
networks:
- messaging
depends_on:
rabbitmq:
condition: service_healthy
rabbitmq:
image: rabbitmq:4.0.4-management-alpine
networks:
- messaging
ports:
- 5672:5672
- 5671:5671
- 15672:15672
- 4369:4369
- 25672:25672
healthcheck:
test: ["CMD", "rabbitmq-diagnostics", "check_running"]
interval: 10s
timeout: 10s
start_period: 30s
retries: 3
networks:
messaging:
name: messaging
driver: bridge

Когда я запускаю этот сценарий, RabbitMQ запускается успешно, но мой издатель и потребитель выдают исключение. Вот журнал ошибок:

Код: Выделить всё

rabbitmq-1   | ...
publisher-1  | Exception in thread "main" java.net.ConnectException: Connection refused
consumer-1   | Exception in thread "main" java.net.ConnectException: Connection refused
consumer-1   |  at java.base/sun.nio.ch.Net.pollConnect(Native Method)
consumer-1   |  at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
consumer-1   |  at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:542)
consumer-1   |  at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)
consumer-1   |  at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
consumer-1   |  at java.base/java.net.Socket.connect(Socket.java:633)
consumer-1   |  at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:61)
consumer-1   |  at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:69)
consumer-1   |  at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:165)
consumer-1   |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1242)
consumer-1   |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1198)
consumer-1   |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1156)
consumer-1   |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1321)
consumer-1   |  at arkadisahakyan.Consumer.main(Consumer.java:20)
publisher-1  |  at java.base/sun.nio.ch.Net.pollConnect(Native Method)
publisher-1  |  at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
publisher-1  |  at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:542)
publisher-1  |  at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)
publisher-1  |  at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
publisher-1  |  at java.base/java.net.Socket.connect(Socket.java:633)
publisher-1  |  at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:61)
publisher-1  |  at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:69)
publisher-1  |  at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:165)
publisher-1  |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1242)
publisher-1  |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1198)
publisher-1  |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1156)
publisher-1  |  at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1321)
publisher-1  |  at arkadisahakyan.Publisher.main(Publisher.java:20)
consumer-1 exited with code 1
publisher-1 exited with code 1

Как видите, я попытался добавить проверку работоспособности в файл компоновки, чтобы дождаться, пока RabbitMQ начнет прослушивать соединения, но это не сработало, и проблема осталась.< /п>

Подробнее здесь: https://stackoverflow.com/questions/792 ... on-refused