.NET 6 Worker Service 项目如何高效创建集成测试

Worker Service 本质是基于 .NET Generic Host 运行的长生命周期后台服务，集成测试的核心目标是走完服务注册、启动、运行、停止的完整生命周期，同时完全隔离生产依赖，避免测试卡壳、污染环境，以下是经过生产项目验证的实现方法：

基础环境准备 #

• 测试项目优先选你熟悉的测试框架（xUnit/NUnit/MSTest都可以），安装以下对齐.NET 6版本的Nuget包：
  • Microsoft.Extensions.Hosting.Testing：提供测试场景下的Host构建辅助能力
  • Moq/NSubstitute：用于Mock外部依赖
  • Microsoft.Extensions.Logging.Testing/Xunit.Extensions.Logging：把服务日志输出到测试结果面板，排错不用本地复现
  • （可选）Testcontainers：需要验证真实数据库、MQ交互时，用容器自动拉起测试实例，用完自动销毁
• 测试项目单独新增appsettings.Test.json配置文件，所有生产环境的外部服务地址（数据库、Redis、MQ、第三方接口）全部替换为测试实例地址，不要直接引用生产项目的配置文件。

核心：构建隔离的测试专用Host #

别直接运行生产项目Program.cs里构建的正式Host，测试场景下自定义Host构建逻辑，替换所有外部IO依赖，同时开放控制入口解决BackgroundService长循环卡测试的问题，参考实现：

public class TestWorkerHostFactory : IDisposable, IAsyncDisposable
{
    private readonly IHost _host;
    // 暴露Mock对象供测试做断言、设置返回逻辑
    public Mock<IOrderProcessingDependency> MockOrderProcessor { get; } = new();

    public TestWorkerHostFactory(Action<IServiceCollection>? configureTestServices = null)
    {
        _host = Host.CreateDefaultBuilder()
            .ConfigureAppConfiguration((_, config) =>
            {
                config.AddJsonFile("appsettings.Test.json");
                // 直接覆盖配置缩短轮询间隔，加快测试执行速度，不用等生产配置里的几秒/几分钟间隔
                config.AddInMemoryCollection(new Dictionary<string, string>
                {
                    ["WorkerOptions:PollingIntervalMs"] = "100",
                    ["WorkerOptions:BatchSize"] = "10"
                });
            })
            .ConfigureServices((ctx, services) =>
            {
                // 注册被测的Worker服务，不需要注册项目里其他无关的后台服务，避免干扰
                services.AddHostedService<OrderProcessingWorker>();
                // 替换真实外部依赖为Mock对象
                services.AddSingleton(MockOrderProcessor.Object);
                // 数据库等存储依赖直接用EF Core内存数据库、内存版缓存，不要连真实实例
                services.AddDbContext<OrderDbContext>(opt => opt.UseInMemoryDatabase("TestOrderDb"));
                // 支持测试自定义注入服务
                configureTestServices?.Invoke(services);
            })
            .ConfigureLogging(logging =>
            {
                logging.ClearProviders(); // 关掉控制台等多余日志输出
                logging.AddXUnit(TestOutputHelper); // 日志输出到测试结果
            })
            .Build();
    }

    // 可控的启动方法，用取消令牌控制服务运行时长
    public Task StartAsync(CancellationToken testCancellationToken)
    {
        return _host.StartAsync(testCancellationToken);
    }

    public T GetService<T>() where T : notnull => _host.Services.GetRequiredService<T>();

    public async ValueTask DisposeAsync()
    {
        await _host.StopAsync();
        _host.Dispose();
    }

    public void Dispose()
    {
        _host.Dispose();
    }

    // 用于接入xUnit日志输出
    public ITestOutputHelper? TestOutputHelper { get; set; }
}

常见业务场景的测试实现 #

1. 启动初始化逻辑验证 #

针对Worker启动时执行的配置加载、缓存预热、监听注册等一次性逻辑，控制Host短时间运行后断言逻辑执行结果即可：

[Fact]
public async Task Worker_Start_ShouldPreheatCacheSuccess()
{
    // Arrange
    await using var factory = new TestWorkerHostFactory();
    // 设置2秒超时，避免测试无限等待
    using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(2));

    // Act
    var runTask = factory.StartAsync(cts.Token);
    // 等待500ms足够初始化逻辑执行完成
    await Task.Delay(500, cts.Token);

    // Assert
    factory.MockOrderProcessor.Verify(p => p.LoadPendingOrderCache(), Times.Once);
}

注意：不要await runTask 等待任务完成，BackgroundService的ExecuteAsync是长运行任务，正常场景下不会自行退出，靠取消令牌控制停止时机就不会卡测试。

2. 轮询/消费类循环逻辑验证 #

针对定时拉取任务、消费消息这类循环执行的逻辑，先把轮询间隔改到100ms以内，提前往测试存储里写入测试数据，控制服务运行1-2秒后断言处理结果：

• 正常流程：写入3条待处理订单，断言3条订单都被标记为已处理、对应通知逻辑被调用3次
• 异常流程：设置Mock依赖第一次调用抛异常、第二次返回成功，断言服务按配置做了重试、错误日志正常记录
• 限流场景：写入20条待处理数据，断言服务按配置的BatchSize=10分批次处理，不会一次性拉取全部数据压垮下游

3. 优雅停止逻辑验证 #

针对服务收到停止信号时的资源释放、任务收尾逻辑，先启动服务等业务逻辑开始执行后触发取消，断言收尾逻辑正常执行：

[Fact]
public async Task Worker_Stop_ShouldCompleteProcessingTaskGracefully()
{
    await using var factory = new TestWorkerHostFactory();
    // 模拟长耗时处理任务
    factory.MockOrderProcessor.Setup(p => p.Process(It.IsAny<Order>(), It.IsAny<CancellationToken>()))
        .Returns<Order, CancellationToken>(async (_, ct) =>
        {
            await Task.Delay(500, ct);
        });

    using var cts = new CancellationTokenSource();
    var runTask = factory.StartAsync(cts.Token);
    // 等待任务开始执行
    await Task.Delay(200);

    // Act：触发服务停止
    cts.Cancel();
    await runTask; // 正常优雅停止不会抛出未处理的OperationCanceledException

    // Assert
    factory.MockOrderProcessor.Verify(p => p.ReleaseLock(), Times.Once);
}

4. 半真实依赖场景测试 #

如果不想全Mock依赖，要验证真实的SQL执行、MQ消息收发逻辑，直接用Testcontainers在测试启动时自动拉起对应服务的容器（PostgreSQL、RabbitMQ、Redis等），自动分配随机端口，测试执行完自动销毁容器，不会污染本地/测试环境，比纯Mock更接近生产运行状态。

落地规范与避坑 #

• 绝对不要在集成测试中连接生产环境的任何服务，所有外部依赖要么Mock要么用临时测试实例
• 所有测试用例必须加超时控制，单条测试运行时长控制在5秒以内，才能顺畅接入CI/CD流水线每次提交自动跑
• 不要图省事直接new Worker实例传Mock依赖测ExecuteAsync，这只能算单元测试，覆盖不到配置绑定、服务注册、生命周期管理这些最高发的线上问题
• 同一个Host里有多个Worker时，测试时只注册当前被测的Worker，避免其他后台服务的逻辑干扰断言结果
• 不要忽略日志输出，测试失败时直接看测试面板里的服务日志，不用反复本地复现排错

内容的提问来源于stack exchange，提问作者Mitiku Teshome