连接到 bitnami/cassandra 的 GoCQL 在 Docker Compose 多容器应用程序中的使用方法

哈喽！今天心血来潮给大家带来了《连接到 bitnami/cassandra 的 GoCQL 在 Docker Compose 多容器应用程序中的使用方法》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！

我正在尝试构建一个应用程序的简化示例，该应用程序使用用户名和密码身份验证连接到 cassandra。为此，我对 https://hub.docker.com/r/bitnami/cassandra/ 中的 docker-compose.yml 进行了如下调整：

version: '2'

services:
  cassandra:
    image: 'docker.io/bitnami/cassandra:3-debian-10'
    ports:
      - '7000:7000'
      - '9042:9042'
    volumes:
      - 'cassandra_data:/bitnami'
    environment:
      - cassandra_seeds=cassandra
      - cassandra_password_seeder=yes
      - cassandra_password=cassandra
  backend:
    build: .
    environment:
      - cassandra_username=cassandra
      - cassandra_password=cassandra
volumes:
  cassandra_data:
    driver: local

我的目录结构在哪里

.
├── dockerfile
├── docker-compose.yml
├── go.mod
├── go.sum
└── main.go

多阶段dockerfile是

from golang as builder
workdir /go/src/app/
copy . .
run go111module=on cgo_enabled=0 goos=linux go build -a -installsuffix cgo -o app .

from alpine:latest  
run apk --no-cache add ca-certificates
workdir /root/
copy --from=builder /go/src/app/app .
cmd ["./app"]

并且 main.go 尝试使用 gocql 创建 cassandra 会话：

package main

import (
    "log"
    "os"

    "github.com/gocql/gocql"
)

func main() {
    cluster := gocql.newcluster("cassandra")
    cluster.authenticator = gocql.passwordauthenticator{
        username: os.getenv("cassandra_username"),
        password: os.getenv("cassandra_password"),
    }

    if _, err := cluster.createsession(); err != nil {
        log.fatalf("createsession: %v", err)
    }
}

用户名和密码均已设置为“cassandra”的默认值，如 https://hub.docker.com/r/bitnami/cassandra/ 中的“连接到其他容器”示例中所示。

问题是，如果我尝试使用 docker-compose build 和 docker-compose up 运行此多容器应用程序，则会收到以下错误：

backend_1    | 2020/11/04 15:10:34 CreateSession: gocql: unable to create session: unable to discover protocol version: dial tcp 172.18.0.3:9042: connect: connection refused

我不明白这里出了什么问题：主机名、端口号、用户名和密码似乎都是正确的。知道连接被拒绝的原因吗？

解决方案

cassandra 需要几秒钟的时间来启动并开始接受连接； backend 正在尝试在准备就绪之前进行连接。如果您在短暂延迟后启动 backend （使用 docker-compose start backend），您的配置工作正常（对我来说）。修改 backend 以重试连接对我来说可靠，即

for {
    _, err := cluster.createsession()
    if  err == nil {
        break
    }
    log.printf("createsession: %v", err)
    time.sleep(time.second)
}
log.printf("connected ok")

日志：

backend_1    | 2020/11/04 17:53:23 CreateSession: gocql: unable to create session: unable to discover protocol version: dial tcp 172.26.0.2:9042: connect: connection refused
backend_1    | 2020/11/04 17:53:24 CreateSession: gocql: unable to create session: unable to discover protocol version: dial tcp 172.26.0.2:9042: connect: connection refused
.......
backend_1    | 2020/11/04 17:53:36 CreateSession: gocql: unable to create session: unable to discover protocol version: dial tcp 172.26.0.2:9042: connect: connection refused
backend_1    | 2020/11/04 17:53:37 Connected OK

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《连接到 bitnami/cassandra 的 GoCQL 在 Docker Compose 多容器应用程序中的使用方法》文章吧，也可关注golang学习网公众号了解相关技术文章。