当前位置: 首页 > 知识库问答 >
问题:

如何在Docker Compose多容器应用中使用GoCQL连接bitnami/cassandra?

叶弘深
2023-03-14

我正在尝试构建一个应用程序的简化示例,它使用用户名和密码身份验证来连接到Cassandra。为此,我修改了<code>docker-compose。yml来自https://hub.docker.com/r/bitnami/cassandra/如下所示:

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"]  

< code>main.go尝试使用< code>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 构建运行此多容器应用程序,然后使用 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

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

共有1个答案

南门祯
2023-03-14

卡桑德拉需要几秒钟才能启动并开始接受连接;后端正在尝试在准备就绪之前进行连接。如果你在一小段延迟后启动后端(使用 docker-compose 启动后端),你的配置可以正常工作(对我来说)。修改后端以重试连接对我来说是可靠的,即

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
 类似资料:
  • 我花了几个小时在谷歌上搜索,但似乎找不到正确的路径/文档来帮助我走上正确的道路:( 前提很简单。 我有一个在localhost:8080上打开的springboot应用程序。我有一个在localhost:15672上打开的rabbitmq服务器 当这两个应用程序都运行时,springboot应用程序将通过一些用户交互向Rabbitmq服务器发送消息。当我对这两个独立的服务进行dockerize(容

  • 问题内容: 我正在练习制作一个与PostgreSQL数据库交互的Golang Web应用程序,每个应用程序都在各自的容器上运行。 我正在运行容器 但是我似乎无法正确设置postgres容器。 为简便起见,指向s和其他设置文件的链接位于此要点上(如果您需要在此处,请告诉我)。 工作良好。但是,当应用程序尝试使用以下方法打开数据库连接时: 我从docker compose得到以下错误: 如何使两个容器

  • 我正在尝试将查询转换为JPA规范,该查询包含带OR条件的连接操作。 以下是查询: 我试图编写一个规范,但在如何将多个列与OR条件连接方面遇到了障碍。 用户实体: 运营实体 我希望有一个规范来取代上面的查询

  • 创建azure容器实例时连接子网和vnet配置时遇到的难题。 我正在尝试使用AzureSDK-Java /.Net创建Azure容器实例。此容器需要与不同VM之间的组件进行通信。我能够使用具有vnet和子网配置的Azure CLI命令来实现这一点。但无法通过SDK复制相同的内容。 Java中的代码片段 Azure CLI az容器创建--资源组--名称--映像--cpu 1--内存1.5--注册表

  • 我正在尝试通过< code>apiserver proxy连接到< code > sky DNS < code > etcd 服务器,使用此文档http://kubernetes . io/docs/user-guide/access-the-cluster/# manually-constructing-API server-proxy-URLs命令 curl--cacert /etc/kube

  • 我有一个包含Docker和Elasticsearch(OS:Centos7)的VM。我想创建一个Kibana docker并与我的ES连接。 ES包含索引,如果输入curl-s http://localhost:9200/_cat/index,我就得到了索引列表。 我使用Dockerfile创建了我的Kibana映像: docker构建-t=“kibana_test”。 docker运行--名称k