如何处理 .NET Core 控制台应用程序中注入的类之间的事件调用

如何解决如何处理 .NET Core 控制台应用程序中注入的类之间的事件调用

我有一个 .Net Core(3.1) 控制台应用程序，它有 2 个服务类，一个有一个事件，另一个用该事件的处理程序侦听它。我已经设置获取 DI 容器，但事件字段始终为空，因此无法调用其 Invoke()。关于我在 ConfigureServices() 中设置涉及事件处理的服务时缺少什么的任何指示。以下是完整的测试代码：

public class RefreshEventArgs : EventArgs
{
    public string RefreshEventData { get; set; }
}
public interface INotifierService
{
    event EventHandler<RefreshEventArgs> RefreshEventHandler;
}

public class NotifierService : INotifierService
{
    public event EventHandler<RefreshEventArgs> RefreshEventHandler;
    public RefreshEventArgs RefreshEventData { get; set; }

    // GeneralAppSettings is a POCO class to read all appsettings.json key values.
    private readonly IOptions<GeneralAppSettings> myAppSettings;
    public NotifierService(IOptions<GeneralAppSettings> appSettings)
    {
        myAppSettings = appSettings;
    }
    
    public void RunInvokingRefreshEvent()
    {
        RefreshEventData = new RefreshEventArgs();
        RefreshEventData.RefreshEventData = "somedata";
        
        // Main problem! In the below line,RefreshEventHandler is null all the time           
        RefreshEventHandler?.Invoke(this,RefreshEventData);            
    }
    
    public void SomeBackgroundThreadMonitorsExternalEvents()
    {
        // Some external events triggers below method
        RunInvokingRefreshEvent();
    }       
}

刷新服务

public interface IRefreshService
{
    void Refresh(RefreshEventArgs eventData = null);
}
public class RefresherService : IRefreshService
{
    private readonly IOptions<GeneralAppSettings> myAppSettings;
    private readonly INotifierService notify;

    public RefresherService(IOptions<GeneralAppSettings> _appSettings,INotifierService _notifyService)
    {
        myAppSettings = _appSettings;
        notify = _notifyService;
        notify.RefreshEventHandler += _notify_RefreshEventHandler;
    }

    private void _notify_RefreshEventHandler(object sender,RefreshEventArgs e)
    {
        // Call Refresh() based say based on a config value from myAppSettings
        Refresh(e);
    }
    public void Refresh(RefreshEventArgs eventData = null)
    {
        // final business logic processing based on eventData
    }
}
public class GeneralAppSettings // POCO
{
    public string SomeConfigKeyInAppSettingsJson { get; set; }      
}  

程序

class Program
{
    public static IConfiguration Configuration { get; set; }
    static void Main(string[] args)
    {
        // read appsettings
        var builder = new ConfigurationBuilder().SetBasePath(Directory.GetCurrentDirectory())
           .AddJsonFile("appsettings.json",optional: false,reloadOnChange: true)
           .AddEnvironmentvariables();
        Configuration = builder.Build();

        // Host builder,setting up container 
        var host = Host.CreateDefaultBuilder()
            .ConfigureAppConfiguration((hostingContext,config) =>
            {
                config.AddConfiguration(Configuration);
            })
            .ConfigureServices((context,services) =>
            {
                services.Configure<GeneralAppSettings>(Configuration.GetSection("GeneralAppSettings"));
                services.AddSingleton<INotifierService,NotifierService>();
                services.AddSingleton<IRefreshService,RefresherService>();
            })
            .Build();
        
        // Need to get NotifierService instance to run some initial logic,so using ActivatorUtilities
        var svc = ActivatorUtilities.GetServiceOrCreateInstance<NotifierService>(host.Services);
        svc.someBackgroundThreadMonitorsExternalEvents();      

        // Need to get RefresherService instance to have initial Refresh logic so using ActivatorUtilities
        var refresh = ActivatorUtilities.GetServiceOrCreateInstance<RefresherService>(host.Services);
        refresh.Refresh(null);
        
        // need to keep this main thread alive 
        Thread.Sleep(Timeout.Infinite);
    }
}

解决方法

当您从 DI 容器请求某些内容时，您必须请求“服务”类型（接口或第一个/唯一的通用参数）。如果您请求未注册的类型并使用 ActivatorUtilities，当且仅当构造它所需的所有类型都可用时，它才会创建一个实例。发生在你身上的是你得到了两个不同的对象（一个注册为接口，一个伪注册为具体类型）！您的类是否实现了接口并且您在注册中将其用作“实现”类型并不重要。 DI始终基于服务类型，并且您尚未注册任何NotifierService 直接类型的服务。

您的问题是您的类和您想要调用的方法之间存在奇怪的耦合 NotifierService 实际上不是接口的一部分。通常的技巧是将具体类型注册并请求为服务类型：

services.AddSingleton<NotiferService>();
//...
var notifier = services.GetService<NotifierService>();

那会起作用，除非您现在还没有注册 INotifierService 以注入 RefresherService。

别担心，我们有解决办法。将具体类型注册为单例，然后使用工厂注册接口：

// register the concrete type directly 
services.AddSingleton<NotifierService>();
// use a factory to register the interface 
services.AddSingleton<INotifierService>(sp => sp.GetRequiredService<NotifierService>());

现在，无论您请求的是接口还是具体类型，都将返回相同的实例。您也不再需要使用 ActivatorUtilities（实际上您不应该）--您现在可以直接使用主机的服务：

var notifier = host.Services.GetRequiredService<NotifierService>();
notifier.SomeBackgroundThreadMonitorsExternalEvents();

综上所述，您的项目非常适合IHostedService/BackgroundService。您可以稍微重构一下（将 NotifierService 分成两类：一类只包含事件，另一类用于后台服务），这样您就可以只处理接口和 'd 能够实际调用 Host.Run() ，它将依次等待关闭。这是此类事情的标准模式，而不是简单地为 DI 容器滥用主机并包括奇怪的 Thread.Sleep。