将DBContext服务添加到Worker项目中的program.cs中

对于这一切还相当陌生，所以如果我做了任何愚蠢的事情，我深表歉意。

我正在尝试实现一个与我设置的本地 SQL Server Express 数据库进行通信的工作项目。

我将连接字符串存储在我的AppSettings.Json如下所示

{
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft": "Warning",
      "Microsoft.Hosting.Lifetime": "Information"
    }
  },
  "ConnectionStrings": {
    "DBConnection": "Server=localhost\\SQLEXPRESS;Database=TwitterTesting;Trusted_Connection=True;"
  }
}

然后我有一个DBContext.cs存储我的数据库结构的文件。目前我只有一张表“推文”。

using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WorkerService1.Entities;

namespace WorkerService1
{
    public class DataContext : DbContext
    {
        public DataContext(DbContextOptions options) : base(options)
        {
        }

        public DbSet<tweets> tweets { get; set; }
    }
}

Tweets.cs仅具有列结构。

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Configuration;

namespace WorkerService1
{
    public class Program
    {
        public static void Main(string[] args)
        {
            CreateHostBuilder(args).Build().Run();
        }

        public static IHostBuilder CreateHostBuilder(string[] args) =>
            Host.CreateDefaultBuilder(args)
                .ConfigureServices((hostContext, services) =>
                {
                    services.AddDbContextPool<DataContext>(
                        options => options.UseSqlServer(hostContext.Configuration.GetConnectionString("DBConnection"))
                    );
                    services.AddHostedService<Worker>();
                });
    }
}

上面是我的program.cs我试图在其中添加实现的文件DBContext，但我在编译时收到以下错误：

System.AggregateException：“无法构造某些服务（验证服务描述符时出错”ServiceType：Microsoft.Extensions.Hosting.IHostedService Lifetime：Singleton ImplementType：WorkerService1.Worker”：无法使用范围服务“WorkerService1.DataContext”单例“Microsoft.Extensions.Hosting.IHostedService”。）

我从网上看的理解是这与依赖注入有关，但我真的很困惑我需要做什么。

任何帮助将不胜感激！ :)

问题是你正在尝试创建一个Scoped您的 DbContext 的服务，但是将使用它的类（Worker) is a Singleton类 - 请注意以下两行。

services.AddDbContextPool<DataContext>( /*omitted*/ );
services.AddHostedService<Worker>();

虽然这些都没有明确说明how该服务正在添加到 DI，AddHostedService<Worker>正在注册Worker类作为单例 - 只有一个实例Worker将被创造，永远。AddDbContextPool<DataContext>正在注册DataContext作为范围服务 - 每次创建范围时都应该构建一个服务，其中DataContext被要求。

问题是如果Worker要求DataContext在构造函数中，你会得到一个DataContext将在该持续时间内生存Worker- 这将是永远的，因为Worker是一个单例。

获得范围DataContext在你的Worker类，您需要从 DI 获取服务提供者，并在每次调用时创建一个范围Worker在主方法中迭代 - 例如：

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Management.Infrastructure;
using Microsoft.Management.Infrastructure.Options;
using System;
using System.Threading;
using System.Threading.Tasks;
private readonly ILogger<Worker> _logger;
private readonly IServiceProvider _serviceProvider;

public Worker (ILogger<Worker> logger, IServiceProvider serviceProvider)
{
    _logger = logger;
    _serviceProvider = serviceProvider;
}
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        _logger.Log("Creating scope to get a new DataContext.");
        // this will give us a scoped service
        using var scope = _serviceProvider.CreateScope();
        var services = scope.ServiceProvider;
        // if DataContext were configured as singleton through AddSingleton<DataContext> 
        // in ConfigureServices, this would always be the same instance. Since it's added 
        // as Scoped, we'll get the same instance every time we ask for the service from 
        // our scope but each time we create a new scope it'll be a new instance.
        var context = services.GetService<DataContext>();
        // do something with context
        // we can validate that within our scope it's always the same object reference:
        _logger.Log("Get scoped service multiple times yields the same reference: {0}", object.ReferenceEquals(context, services.GetService<DataContext>());
        context.Dispose();
    }
}

有关更多信息，请查看以下页面 - 特别注意提及“Scoped”、“Transient”和“Singleton”。https://learn.microsoft.com/en-us/aspnet/core/fundamentals/dependency-injection?view=aspnetcore-5.0 https://learn.microsoft.com/en-us/aspnet/core/fundamentals/dependency-injection?view=aspnetcore-5.0