testcontainers-go：Go 测试中的 Docker

在现代软件开发中，测试与外部服务（数据库、消息代理、缓存）的集成是最具挑战性的任务之一。传统方法，例如使用共享测试数据库或模拟对象，常常导致问题：测试变得脆弱、依赖环境或无法反映系统的真实行为。testcontainers-go 库提供了一个优雅的解决方案：它允许直接从 Go 测试代码中启动隔离的 Docker 容器，为每次测试运行提供干净、可重现且接近生产的环境。

testcontainers-go 的核心思想是以编程方式管理 Docker 容器的生命周期。您在测试代码中描述所需的服务（例如 PostgreSQL、Redis、Kafka），该库会自动下载镜像（如果不存在）、启动容器、等待其就绪，并向您提供连接参数（主机、端口、凭据）。测试完成后，容器会自动停止并删除，不会在系统中留下任何垃圾。这使得测试独立、快速且安全。

testcontainers-go 是流行项目 Testcontainers 的 Go 实现，该项目最初出现在 Java 中，随后被移植到其他语言。该库得到社区的积极维护，并为大多数流行服务提供现成的模块：PostgreSQL、MySQL、Redis、MongoDB、Kafka、RabbitMQ、Elasticsearch 等等。它非常适合编写集成测试、端到端测试，甚至用于需要快速搭建环境的本地开发。

安装

要安装 testcontainers-go，请使用标准的 Go 包管理器。确保您已安装 Docker（或 Podman）以及 Go 1.19 或更高版本。

go get github.com/testcontainers/testcontainers-go\n

要使用特定服务（例如 PostgreSQL），您需要安装相应的模块：

go get github.com/testcontainers/testcontainers-go/modules/postgres\ngo get github.com/testcontainers/testcontainers-go/modules/redis\ngo get github.com/testcontainers/testcontainers-go/modules/mongodb\ngo get github.com/testcontainers/testcontainers-go/modules/kafka\n# 等等\n

安装后，将包导入到您的测试文件中：

import (\n    "context"\n    "testing"\n    \n    "github.com/testcontainers/testcontainers-go"\n    "github.com/testcontainers/testcontainers-go/wait"\n    "github.com/testcontainers/testcontainers-go/modules/postgres"\n)\n

快速入门：最小工作示例

让我们编写一个简单的测试，它启动一个 PostgreSQL 容器，创建一个表，插入数据并验证它们。这将向您展示该库的基本工作原理。

package main\n\nimport (\n    "context"\n    "database/sql"\n    "testing"\n    "time"\n\n    "github.com/testcontainers/testcontainers-go"\n    "github.com/testcontainers/testcontainers-go/modules/postgres"\n    "github.com/testcontainers/testcontainers-go/wait"\n    _ "github.com/lib/pq" // PostgreSQL 驱动\n)\n\nfunc TestPostgresIntegration(t *testing.T) {\n    ctx := context.Background()\n\n    // 1. 启动 PostgreSQL 容器\n    postgresContainer, err := postgres.RunContainer(ctx,\n        testcontainers.WithImage("postgres:16-alpine"),\n        postgres.WithDatabase("testdb"),\n        postgres.WithUsername("testuser"),\n        postgres.WithPassword("testpass"),\n        testcontainers.WithWaitStrategy(\n            wait.ForLog("database system is ready to accept connections").\n                WithOccurrence(2).\n                WithStartupTimeout(60*time.Second)),\n