C# + DockerCompose - 等待 MS SQL Server Docker 容器启动，然后再尝试连接

Question

我正在尝试为我的微服务创建类似于Spotify方法的集成测试。

我仍在研究如何启动和播种数据库。 目前我有一个带有FluentDocker v2.2.15和DbUp 4.1.0的.NET Core 2.0项目。

我使用 FluentDocker 调用 DockerCompose 并启动我的服务，包括 SQL Server 容器

var hosts = new Hosts().Discover();
var dockerHost = hosts.FirstOrDefault(x => x.IsNative) ?? hosts.FirstOrDefault(x => x.Name == "default");
if (dockerHost == null)
{
return;
}
var composeFile = Args["composeFile"];
var result = dockerHost.Host.ComposeUp(composeFile: composeFile);

然后我使用 DbUp 运行我的脚本并为数据库设定种子。

var connectionString = Args["connectionString"];
var scriptsPath = Args["scriptsPath"];
EnsureDatabase.For.SqlDatabase(connectionString);
var upgradeEngine = DeployChanges.To.SqlDatabase(connectionString).WithScriptsFromFileSystem(scriptsPath).Build();
var result = upgradeEngine.PerformUpgrade();

当我给 SQL Server 足够的启动时间(例如，在调试时(时，我可以成功运行它。但是，如果我全速运行它，那么 DbUp 会在它还没有准备好时尝试连接到 SQL Server。 FluentDocker有一个WaitForPort的方法，但它似乎不适用于DockerCompose API。

我想知道是否有办法在运行脚本之前等待 SQL Server 的端口 1433 响应(不包括非确定性策略，例如await Task.Delay(，或者是否有替代库允许我进行这种控制。

谢谢

Answer 1

您可以在FluentDockerv2.6.2 的 compose 上使用WaitForPort、WaitForProcess、WaitForHttp或自定义 lambdaWait函数。例如：

给定 docker 撰写文件：

version: '3.3'
services:
db:
image: mysql:5.7
volumes:
- db_data:/var/lib/mysql
restart: always
environment:
MYSQL_ROOT_PASSWORD: somewordpress
MYSQL_DATABASE: wordpress
MYSQL_USER: wordpress
MYSQL_PASSWORD: wordpress
wordpress:
depends_on:
- db
image: wordpress:latest
ports:
- "8000:80"
restart: always
environment:
WORDPRESS_DB_HOST: db:3306
WORDPRESS_DB_USER: wordpress
WORDPRESS_DB_PASSWORD: wordpress
volumes:
db_data:

该文件指定wordpress依赖于db，因此首先启动db，然后实例化wordpress容器。但是要确保在WordPressWeb 正在运行的using子句，您需要使用HTTP来确定这一点。您可以使用Fluent API实例化并等待服务像这样启动。

var file = Path.Combine(Directory.GetCurrentDirectory(),
(TemplateString) "Resources/ComposeTests/WordPress/docker-compose.yml");
using (new Builder()
.UseContainer()
.UseCompose()
.FromFile(file)
.RemoveOrphans()
.Wait("wordpress", (service, cnt) => {
if (cnt > 60) throw new FluentDockerException("Failed to wait for wordpress service");
var res = HttpExtensions.DoRequest("http://localhost:8000/wp-admin/install.php").Result;            
return (res.Code == HttpStatusCode.OK && 
res.Body.IndexOf("https://wordpress.org/", StringComparison.Ordinal) != -1) ? 0 : 500;
})
.Build().Start())
{
// Since we have waited - this shall now always work.       
var installPage = await "http://localhost:8000/wp-admin/install.php".Wget();
Assert.IsTrue(installPage.IndexOf("https://wordpress.org/", StringComparison.Ordinal) != -1);
}

(上面的示例是一个更麻烦WaitForHttp但使用自定义 lambda 来说明这一点(。

通过这种方式，您甚至可以使用db 连接并在继续之前查询表。 返回高于零的值是等待下次进行测试的时间。零及以下将成功结束等待。异常将终止等待(并失败(。

上面的示例使用FluentAPI语法，但您可以手动将钩子添加到组合容器上，并自行使用扩展。

干杯 马里奥