最新公告
  • 欢迎您光临码农资源网,本站秉承服务宗旨 履行“站长”责任,销售只是起点 服务永无止境!加入我们
  • Golang testcontainers,无法使网络工作

    golang testcontainers,无法使网络工作

    php小编草莓在使用Golang testcontainers时遇到了一个问题,即无法使网络正常工作。Golang testcontainers是一个用于在测试中运行容器的工具,它可以帮助开发人员在测试环境中快速启动和销毁容器。然而,在实际使用中,php小编草莓发现无法在容器中正常使用网络功能,这给测试带来了一定的困扰。接下来,我们将一起探讨这个问题的解决方案。

    问题内容

    我正在尝试在我的微服务中创建一些测试,我想创建一个网络,将我的数据库测试容器(postgres)和我的微服务测试容器附加到该网络。无论我尝试什么,我都无法让我的微服务连接到数据库。我的微服务是使用 Fiber 和 Gorm 的 golang。我尝试连接到 db.go 配置文件中的数据库,如下所示:

    func SetupDB(port string, host string) *gorm.DB {
    
        dsn := "host=" + host + " user=postgres password=password dbname=prescription port=" + port + " sslmode=disable"
    
        db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
    
        if err != nil {
            panic("error connecting to database")
        }
    
        db.AutoMigrate(&model.Prescription{})
    
        return db
    }

    这就是我的测试容器的样子:

    prescriptionDBContainer, err := testcontainers.GenericContainer(context.Background(), testcontainers.GenericContainerRequest{
            ContainerRequest: testcontainers.ContainerRequest{
                Image:        "postgres",
                ExposedPorts: []string{postgresPort.Port()},
                Env: map[string]string{
                    "POSTGRES_USER":     "postgres",
                    "POSTGRES_PASSWORD": "password",
                    "POSTGRES_DB":       "prescription",
                },
                Networks: []string{network.Name},
                NetworkAliases: map[string][]string{
                    network.Name: {"db-network"},
                },
                WaitingFor: wait.ForAll(
                    wait.ForLog("database system is ready to accept connections"),
                    wait.ForListeningPort(postgresPort),
                ),
            },
            Started: true,
        })
    prescriptionContainer, err := testcontainers.GenericContainer(context.Background(), testcontainers.GenericContainerRequest{
            ContainerRequest: testcontainers.ContainerRequest{
                FromDockerfile: testcontainers.FromDockerfile{Context: "../../../../prescription"},
                Networks:       []string{network.Name},
                NetworkAliases: map[string][]string{
                    network.Name: {"db-network"},
                },
                Env: map[string]string{
                    "POSTGRES_USER":     "postgres",
                    "POSTGRES_PASSWORD": "password",
                    "POSTGRES_DB":       "prescription",
                    "HOST":              prescriptionDBHost,
                    "DB_PORT":           prescriptionDBPort.Port(),
                },
                ExposedPorts: []string{pMicroPort.Port()},
                WaitingFor:   wait.ForListeningPort("8080"),
            },
            Started: true,
        })

    也许是因为我根本不了解docker中网络连接过程中发生的事情,但我真的迷失了,当我为HOST和DB_PORT设置环境时(我已经尝试了阳光下的每一种组合),它拒绝连接数据库的微服务

    在我尝试过的微服务的测试容器中:

    "HOST":              prescriptionDBHost,
    "DB_PORT":           prescriptionDBPort.Port(),

    prescriptionDBHost 的提取方式为:

    prescriptionDBHost, err := prescriptionDBContainer.Name(context.Background())

    导致错误消息:

    failed to initialize database, got error failed to connect to `host=/stoic_heyrovsky user=postgres database=prescription`: dial error (dial unix /stoic_heyrovsky/.s.PGSQL.53802: connect: no such file or directory)
    panic: error connecting to database

    然后我尝试从主机名中删除“/”,例如:

    "HOST":              strings.Trim(prescriptionDBHost,"/"),
    "DB_PORT":           prescriptionDBPort.Port(),

    我也尝试过:

    "HOST":              "localhost",
    "DB_PORT":           prescriptionDBPort.Port(),
    "HOST":              "127.0.0.1",
    "DB_PORT":           prescriptionDBPort.Port(),
    prescriptionDBHost, err := prescriptionDBContainer.ContainerIP(context.Background())
    
    "HOST":              prescriptionDBHost,
    "DB_PORT":           prescriptionDBPort.Port(),

    这里的最后 4 个示例都会导致某种拨号 TCP 错误,例如:

    failed to initialize database, got error failed to connect to `host=localhost user=postgres database=prescription`: dial error (dial tcp [::1]:53921: connect: cannot assign requested address)

    我还在 testcontainer 创建数据库容器后进行了调试和停止,然后转到我的微服务并使用 DB_HOST=localhost 和 port= 硬编码连接到该容器,并且成功了,所以我真的迷失了正在发生的事情错误的。我唯一能想到的是,微服务容器在尝试连接数据库之前没有连接到网络?我做了一个 docker 网络检查,我可以看到数据库容器已附加,但微服务从未附加(但也许这只是因为其他原因?)。

    解决方法

    你可以这样做:

    prescriptionDBContainer, err := testcontainers.GenericContainer(context.Background(), testcontainers.GenericContainerRequest{
        ContainerRequest: testcontainers.ContainerRequest{
            Image:        "postgres",
            ExposedPorts: []string{"5432/tcp"},
            Env: map[string]string{
                "POSTGRES_USER":     "postgres",
                "POSTGRES_PASSWORD": "password",
                "POSTGRES_DB":       "prescription",
            },
            Networks:       []string{networkName},
            NetworkAliases: map[string][]string{networkName: []string{"postgres"}},
            WaitingFor: wait.ForAll(
                wait.ForLog("database system is ready to accept connections"),
                wait.ForListeningPort("5432/tcp"),
            ),
        },
        Started: true,
    })
    if err != nil {
        t.Fatal(err)
    }
    
    prescriptionContainer, err := testcontainers.GenericContainer(context.Background(), testcontainers.GenericContainerRequest{
        ContainerRequest: testcontainers.ContainerRequest{
            FromDockerfile: testcontainers.FromDockerfile{Context: "./testapp"},
            ExposedPorts:   []string{"8080/tcp"},
            Networks:       []string{networkName},
            NetworkAliases: map[string][]string{networkName: []string{"blah"}},
            Env: map[string]string{
                "DATABASE_URL": "postgres://postgres:password@postgres:5432/prescription",
            },
            WaitingFor: wait.ForListeningPort("8080/tcp"),
        },
        Started: true,
    })

    注意NetworkAliases的配置方式;在您的代码中,您将两者都设置为 db-network 但是,我想,这是由于误解。该设置配置了一个可以引用容器的别名(在本例中,我使用 postgres 作为 postgres 容器;这意味着当连接 HOST 时,根据上面示例中使用的 URL,postgres 将是 postgres)。

    作为替代方案,您可以使用 port, err :=处方DBContainer.MappedPort(context.Background(), "5432/tcp") 获取主机上公开的端口,然后连接到端口上的 host.docker.internalport.Port().当被测试的应用程序在主机上而不是在容器中运行时,经常使用此方法(但在这种情况下,您将连接到 localhost 并使用从 MappedPort() 返回的报告)。

    想要了解更多内容,请持续关注码农资源网,一起探索发现编程世界的无限可能!
    本站部分资源来源于网络,仅限用于学习和研究目的,请勿用于其他用途。
    如有侵权请发送邮件至1943759704@qq.com删除

    码农资源网 » Golang testcontainers,无法使网络工作
    • 7会员总数(位)
    • 25846资源总数(个)
    • 0本周发布(个)
    • 0 今日发布(个)
    • 292稳定运行(天)

    提供最优质的资源集合

    立即查看 了解详情