我的 Asp.net 核心应用程序事件处理程序不起作用

Question

我正在使用洋葱架构创建一个 ASP.net Core 应用程序。我想在业务逻辑层中引发一些事件并从基础设施层订阅这些事件。（从内到外的层：域 - 合同 - 业务逻辑 -基础设施 - API）

我的 BL 类和事件实现之一：

public class LiveStreamBusinessLogic : ILiveStreamBusinessLogic
    {
       
        public event ILiveStreamBusinessLogic.LiveStreamEventHandler LiveStreamEventOccured;        
        
        public async Task<IBusinessLogicResult<PagedList<LiveStreamForShowDto>>> GetAllLiveStreamAsync(LiveStreamParameters liveStreamParameters)
        {
            // some logic
            OnDomainEventOccured();
            return new BusinessLogicResult<PagedList<LiveStreamForShowDto>>
                {Success = true, Result = livesListForTransferPaged};
        }

        

        protected virtual void OnDomainEventOccured()
        {
            LiveStreamEventOccured?.Invoke(this, EventArgs.Empty);
        }

        
    }

我也在使用 DI 来创建具有此接口的上层：

public interface ILiveStreamBusinessLogic
    {
        public delegate void LiveStreamEventHandler(object sender, EventArgs args);
        public event LiveStreamEventHandler LiveStreamEventOccured;

        Task<IBusinessLogicResult<PagedList<LiveStreamForShowDto>>> GetAllLiveStreamAsync(LiveStreamParameters liveStreamParameters);
        
    }

这个类将通过 StartUp 类实例化：

services.AddScoped<ILiveStreamBusinessLogic, LiveStreamBusinessLogic>();

我的订阅者是：

public class ElasticLogger
    {
        private readonly ILoggerManager _loggerManager;
        private readonly ILiveStreamBusinessLogic _liveStreamBusinessLogic;

        public ElasticLogger(ILoggerManager loggerManager, ILiveStreamBusinessLogic liveStreamBusinessLogic)
        {
            _loggerManager = loggerManager;
            _liveStreamBusinessLogic = liveStreamBusinessLogic;
            Subscribe();
        }

        private void Subscribe()
        {
            _liveStreamBusinessLogic.LiveStreamEventOccured += OnDomainEventOccured;
        }
        
        private void OnDomainEventOccured(object sender, EventArgs e)
        {
            _loggerManager.LogInfo(Serialize(e).ToString());    
        }
        
    }

和启动：

services.AddScoped<ElasticLogger>();

问题是事件会正确引发，但处理程序不执行。我想在启动时实例化我的类的过程存在问题，但不知道如何解决？这个问题的任何解决方案甚至更好的模式？

Answer 1

通过查看您的示例代码，我看不出您正在创建ElasticLogger 的实例。这意味着没有创建ElasticLogger，因此它不能创建Subscribe。

您可以通过在ElasticLogger 的构造函数中放置一个断点来检查我的理论是否正确。如果你从来没有遇到断点，那我是对的。

我建议你重构ElasticLogger，不要从构造函数中调用Subscribe。但是这样做：

public class ElasticLogger
{
    private readonly ILoggerManager _loggerManager;
    private readonly ILiveStreamBusinessLogic _liveStreamBusinessLogic;

    public ElasticLogger(ILoggerManager loggerManager, ILiveStreamBusinessLogic liveStreamBusinessLogic)
    {
        _loggerManager = loggerManager;
        _liveStreamBusinessLogic = liveStreamBusinessLogic;
    }

    public void Subscribe()
    {
        _liveStreamBusinessLogic.LiveStreamEventOccured += OnDomainEventOccured;
    }

    private void OnDomainEventOccured(object sender, EventArgs e)
    {
        _loggerManager.LogInfo(Serialize(e).ToString());
    }
}

但是，请确保您在外部调用它，在您的应用程序启动后，在外部调用它：elasticLogger.Subscribe()。那么你的事件应该被处理。