将RabbitMQ添加到Docker中：错误：连接ECONNREFUSED 192.168.80.2:5672

huangapple
go评论89阅读模式
英文:

Add rabbitmq to Docker: Error: connect ECONNREFUSED 192.168.80.2:5672

问题

当运行命令docker compose up -d --build并检查网关服务的日志时，出现错误

错误: 连接ECONNREFUSED 192.168.80.2:5672
在TCPConnectWrap.afterConnect [as oncomplete] (node:net:1229:16) {
errno: -111,
code: 'ECONNREFUSED',
syscall: 'connect',
address: '192.168.80.2',
port: 5672
}

docker:

message_broker:
image: rabbitmq:3.10-management-alpine
hostname: rabbitmq
restart: unless-stopped
volumes:
- message_broker_data:/var/lib/rabbitmq
ports:
- 15672:15672
networks:
- tms

gateway:
container_name: gateway
stdin_open: true
tty: true
build:
context: ./micro_services/gateway
dockerfile: Dockerfile
depends_on:
- storage
volumes:
- ./micro_services/gateway/src/:/app/src/
- ./micro_services/gateway/public/:/app/public/
- tms_logs:/var/log/gateway
environment:
PORT: 3000
STORAGE_URL: 'http://storage:3000'
LOGS_PATH: '/var/log/gateway'
ports:
- '3000:3000'
networks:
- tms

并且我使用了amqplib

module.exports = async () => {
try {
const queue = 'tasks'
const conn = await amqplib.connect('amqp://message_broker:5672')
// 其余部分未提供，请补充
}

英文:

When run command docker compose up -d --build and check logs of gateway service then get an error

Error: connect ECONNREFUSED 192.168.80.2:5672
at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1229:16) {
errno: -111,
code: 'ECONNREFUSED',
syscall: 'connect',
address: '192.168.80.2',
port: 5672
}

docker:

  1.  message_broker:
  2.     image: rabbitmq:3.10-management-alpine
  3.     hostname: rabbitmq
  4.     restart: unless-stopped
  5.     volumes:
  6.       - message_broker_data:/var/lib/rabbitmq
  7.     ports:
  8.       - 15672:15672
  9.     networks:
  10.       - tms
  12.  gateway:
  13.     container_name: gateway
  14.     stdin_open: true
  15.     tty: true
  16.     build:
  17.        context: ./micro_services/gateway
  18.        dockerfile: Dockerfile
  19.     depends_on:
  20.        - storage
  21.     volumes:
  22.        - ./micro_services/gateway/src/:/app/src/
  23.        - ./micro_services/gateway/public/:/app/public/
  24.        - tms_logs:/var/log/gateway
  25.     environment:
  26.        PORT: 3000
  27.        STORAGE_URL: 'http://storage:3000'
  28.        LOGS_PATH: '/var/log/gateway'
  29.     ports:
  30.        - '3000:3000'
  31.     networks:
  32.        - tms

and i use amqplib

  1. module.exports = async () => {
  2.     try {
  3. const queue = 'tasks'
  4. const conn = await amqplib.connect('amqp://message_broker:5672')

答案1

得分: 1

以下是翻译好的部分：

  1. 我添加类似以下内容的代码：
  3. async function connectWithRetry(url, options) {
  4.   let retries = options.retries
  5.   let delay = options.delay
  6.   let lastError
  8.   while (retries > 0) {
  9.     try {
  10.       const conn = await amqplib.connect(url)
  11.       return conn
  12.     } catch (error) {
  13.       lastError = error
  14.       console.log(`连接失败。剩余重试次数：${retries}`)
  15.       await sleep(delay)
  16.       retries--
  17.     }
  18.   }
  20.   throw lastError
  21. }
  23. function sleep(ms) {
  24.   return new Promise((resolve) => setTimeout(resolve, ms))
  25. }
  27. 或者简单的方式是：
  29. setTimeout(async () => {
  30.   await initAmqp() // 在这个函数中包含来自amqp的逻辑
  31.   console.log('消息代理成功启动')
  32. }, 10000)
英文:

I add something like it

  1. async function connectWithRetry(url, options) {
  2.    let retries = options.retries
  3.    let delay = options.delay
  4.    let lastError
  6.    while (retries > 0) {
  7.      try {
  8.   const conn = await amqplib.connect(url)
  9.   return conn
  10. } catch (error) {
  11.   lastError = error
  12.   console.log(`Connection failed. Retries left: ${retries}`)
  13.   await sleep(delay)
  14.   retries--
  15.   }
  16. }
  18. throw lastError
  19. }
  21.   function sleep(ms) {
  22.     return new Promise((resolve) => setTimeout(resolve, ms))
  23.  }

or the simple way is

  1.  setTimeout(async () => {
  2.     await initAmqp() // in this func a logic from amqp
  3.     console.log('message brocker started successfully')
  4.   }, 10000)

huangapple
  • 本文由 发表于 2023年6月30日 05:06:36
  • 转载请务必保留本文链接：https://go.coder-hub.com/76584609.html
  • docker
  • docker-compose
  • node.js
  • rabbitmq
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定