Docker部署Go+Elasticsearch遇127.0.0.1:9200连接拒绝问题求助

核心原因分析 #

• 容器网络访问错误：Go程序运行在monolith容器中，若代码里连接的是127.0.0.1:9200，这个地址指向的是monolith容器自身，而非elasticsearch容器。Docker Compose会为服务创建独立网络，容器间需通过服务名（即elasticsearch）互相访问。
• 服务启动时机不匹配：depends_on仅保证monolith在elasticsearch之后启动，但不会等待Elasticsearch完全就绪（ES启动需要加载数据、初始化服务，这个过程需要时间），此时Go程序发起连接会被拒绝。
• 端口映射混淆：compose里将ES的9200端口映射到宿主机的9201，这个映射仅用于宿主机访问ES，容器内部访问ES依然要用9200端口。

具体解决办法 #

1. 修改Go代码中的ES连接地址 #

找到初始化Elasticsearch客户端的代码（你提供的片段未展示这部分），将连接地址从http://127.0.0.1:9200改为http://elasticsearch:9200。示例：

es, err := elasticsearch.NewClient(elasticsearch.Config{
    Addresses: []string{
        "http://elasticsearch:9200", // 用服务名替代localhost
    },
})

2. 添加Elasticsearch健康检查与启动等待 #

在compose.yml中给elasticsearch服务添加健康检查，确保ES就绪后再启动monolith：

version: '3.1'

services:
  elasticsearch:
    image: docker.elastic.co/elasticsearch/elasticsearch:7.15.0
    container_name: elasticsearch
    ports:
      - 9201:9200
    environment:
      - discovery.type=single-node
    healthcheck:
      test: ["CMD-SHELL", "curl -f http://localhost:9200/_cluster/health || exit 1"]
      interval: 10s
      timeout: 10s
      retries: 5

  monolith:
    build:
      context: .
    ports:
      - 3001:3001
    depends_on:
      elasticsearch:
        condition: service_healthy # 等待ES健康检查通过

3. （可选）在Go代码中添加重试逻辑 #

为应对ES偶尔的启动延迟，可在索引请求时添加重试机制：

retryCount := 3
var res *esapi.Response
var err error

for i := 0; i < retryCount; i++ {
    res, err = req.Do(context.Background(), es)
    if err == nil {
        break
    }
    fmt.Printf("Retry %d: failed to index data, error: %v\n", i+1, err)
    time.Sleep(2 * time.Second)
}

if err != nil {
    fmt.Println("Data indexing failed after retries", err)
    return
}

内容的提问来源于stack exchange，提问作者eymen iron