【问题标题】:C# Handling DDD domain events with dynamically constructed event handlersC# 使用动态构造的事件处理程序处理 DDD 域事件
【发布时间】:2018-05-20 19:10:29
【问题描述】:

我正在使用 ASP.NET Core 2.0 和 EF Core 2.0 构建应用程序。至于在我的领域中解耦不同类型的逻辑,我使用 DDD(领域驱动设计)的领域事件。让我们深入研究实现,看看我有什么,然后我将讨论我的问题。 首先让我们看看我的领域事件相关类的通用实现。首先是一个marker接口,IDomainEvent

public interface IDomainEvent
{
}

在它旁边我有一个通用的IHandler 类:

public interface IHandler<in T> where T : IDomainEvent
{
    void Handle(T domainEvent);
}

然后我有一个DomainEvents 类:

private static List<Type> _handlers;

public static void Init()
{
    InitHandlersFromAssembly();
}

private static void InitHandlersFromAssembly()
{
    _handlers = Assembly.GetExecutingAssembly()
        .GetTypes()
        .Where(x => x.GetInterfaces().Any(y => y.IsGenericType && y.GetGenericTypeDefinition() == typeof(IHandler<>)))
        .ToList();
}

public static void Dispatch(IDomainEvent domainEvent)
{
    foreach (var handlerType in _handlers)
    {
        if (CanHandleEvent(handlerType, domainEvent))
        {
            dynamic handler = Activator.CreateInstance(handlerType);
            handler.Handle((dynamic)domainEvent);
        }
    }
}

private static bool CanHandleEvent(Type handlerType, IDomainEvent domainEvent)
{
    return handlerType.GetInterfaces()
        .Any(x => x.IsGenericType
                  && x.GetGenericTypeDefinition() == typeof(IHandler<>)
                  && x.GenericTypeArguments[0] == domainEvent.GetType());
}

如您所见,DomainEvents 类初始化了正在执行的程序集的所有域事件。 Dispatch 方法在我的域的自定义 DbContext 的覆盖 SaveChanges() 方法中调用。我在这里调用 dispatch 是为了在一个工作单元的事务中调度所有事件:

public override int SaveChanges()
{
    DomainEventsDispatcher.Dispatch(ChangeTracker);

    return base.SaveChanges();
}

以及DomainEventDispatcher的实现:

public static class DomainEventsDispatcher
{
    public static void Dispatch(ChangeTracker changeTracker)
    {
        var domainEvents = GetDomainEventEntities(changeTracker);

        HandleDomainEvents(domainEvents);
    }

    private static IEnumerable<IEntity> GetDomainEventEntities(ChangeTracker changeTracker)
    {
        return changeTracker.Entries<IEntity>()
            .Select(po => po.Entity)
            .Where(po => po.Events.Any())
            .ToArray();
    }

    private static void HandleDomainEvents(IEnumerable<IEntity> domainEventEntities)
    {
        foreach (var entity in domainEventEntities)
        {
            var events = entity.Events.ToArray();
            entity.Events.Clear();

            DispatchDomainEvents(events);
        }
    }

    private static void DispatchDomainEvents(IDomainEvent[] events)
    {
        foreach (var domainEvent in events)
        {
            DomainEvents.Dispatch(domainEvent);
        }
    }

到目前为止一切都很好,它与简单的域事件处理程序配合得很好,例如:

public class OrderCreatedEventHandler : IHandler<OrderCreatedEvent>
{
    public void Handle(OrderCreatedEvent domainEvent)
    {
        Console.WriteLine("Order is created!");
    }
}

但我还有一些其他的事件处理程序,我想在其中注入一些依赖项,即存储库:

public class OrderCreatedEventHandler : IHandler<OrderCreatedEvent>
{
    private readonly IOrderHistoryRepository _orderHistoryRepository;

    public OrderCreatedEventHandler(IOrderHistoryRepository orderHistoryRepository)
    {
        _orderHistoryRepository = orderHistoryRepository;
    }

    public void Handle(OrderCreatedEvent domainEvent)
    {
        _orderHistoryRepository.Insert(new OrderHistoryLine(domainEvent));
    }
}

我的问题如下:在DomainEventsDispatch 方法中,我使用Activator 类在运行时动态构造事件处理程序。在这一行会引发异常,并显示以下消息:

System.MissingMethodException: 'No parameterless constructor defined for this object.'

这是合乎逻辑的,因为在OrderCreatedEventHandler 中只有一个构造函数注入了存储库。我的问题是:是否可以在我的动态构造的处理程序中注入该存储库?如果不是,我的问题有什么解决方案或解决方法?

附加信息:

作为 IoC 框架,我使用 Autofac,并在 Startup.cs 中配置它,其中域事件也被初始化:

    // This method gets called by the runtime. Use this method to add services to the container.
    public IServiceProvider ConfigureServices(IServiceCollection services)
    {
        services.AddMokaKukaTrackerDbContext(CurrentEnvironment, Configuration);
        services.RegisterIdentityFramework();
        services.AddAndConfigureMvc(CurrentEnvironment);

        var autofacServiceProvider = new AutofacServiceProvider(CreateIoCContainer(services));
        DomainEvents.Init();

        return autofacServiceProvider;
    }

    private static IContainer CreateIoCContainer(IServiceCollection services)
    {
        var builder = new ContainerBuilder();
        builder.Populate(services);
        builder.RegisterModule(new AutofacInjectorBootstrapperModule());

        return builder.Build();
    }

如果您需要有关我的问题的更多信息/代码,请告诉我,然后我会尽快将它们包括在内。提前致谢!

【问题讨论】:

  • IContainer 实例传递给DomainEvents.Init(),然后使用该容器创建处理程序实例
  • 这只是一个想法,但也许您可以在 autofac 中注册所有事件处理程序及其依赖项,并使用 autofac 容器而不是使用 Activator 来解决。 Autofac 能够自动选择正确的构造函数。 Autofac 很强大。
  • 首先,你根本不应该使用这样的静态类,它是一种反模式。只需将其创建为常规类(带有接口)并将其注入到您的上下文中。如果您想使用一次性的作用域或瞬态服务(DbContext 是,因为它的默认生命周期是作用域的),那么您当前的方法存在很大问题。最后但同样重要的是,DomainEventDispatcher 不应该依赖于 EntityFramework,这样混合和紧密耦合它违反了关注点
  • @ConstantinGalbenu 和 bart-256 感谢 cmets,可能是解决此问题的方法!但根据 Tseng 的回答,整个实现存在很大问题。
  • 这不是大问题,你只需要不使用静态/全局变量;做一些重构,应该没问题。

标签: c# asp.net-core domain-driven-design autofac


【解决方案1】:

我决定按照@Devesh Tipe 的要求为这个问题提供最终解决方案。批准的解决方案解决了我的问题,但我已经在我的代码库中进行了几次重构,以便以更优雅的方式处理域事件。通过以下解决方案,我们能够创建具有依赖关系的域处理程序,这些依赖关系在运行时通过 Autofac 依赖框架解决。让我们深入研究代码,包括整个解决方案:

首先我有一个域事件的标记界面:

public interface IDomainEvent
{
}

然后我有一个用于域处理程序的接口:

public interface IHandler<in T> where T : IDomainEvent
{
    void Handle(T domainEvent);
}

此外,我有一个 EventDispatcher 负责调度/处理一个事件:

public class EventDispatcher : IEventDispatcher
{
    private readonly ILifetimeScope _lifetimeScope;

    public EventDispatcher(ILifetimeScope lifetimeScope)
    {
        _lifetimeScope = lifetimeScope;
    }

    public void Dispatch<TEvent>(TEvent eventToDispatch) where TEvent : IDomainEvent
    {
        foreach (dynamic handler in GetHandlers(eventToDispatch))
        {
            handler.Handle((dynamic)eventToDispatch);
        }
    }

    private IEnumerable GetHandlers<TEvent>(TEvent eventToDispatch) where TEvent : IDomainEvent
    {
        return (IEnumerable) _lifetimeScope.Resolve(
            typeof(IEnumerable<>).MakeGenericType(
                typeof(IHandler<>).MakeGenericType(eventToDispatch.GetType())));
    }
}

如您所见,此处检索并调用了相应的处理程序及其已解析的依赖项。该调度程序用于执行程序类中,例如:

public class DomainEventHandlingsExecutor : IDomainEventHandlingsExecutor
{
    private readonly IEventDispatcher _domainEventDispatcher;

    public DomainEventHandlingsExecutor(IEventDispatcher domainEventDispatcher)
    {
        _domainEventDispatcher = domainEventDispatcher;
    }

    public void Execute(IEnumerable<IEntity> domainEventEntities)
    {
        foreach (var entity in domainEventEntities)
        {
            var events = entity.Events.ToArray();
            entity.Events.Clear();

            foreach (var @event in events)
            {
                _domainEventDispatcher.Dispatch(@event);
            }
        }
    }
}

注入到我的数据库上下文中:

    public MokaKukaTrackerDbContext(DbContextOptions<MokaKukaTrackerDbContext> options, IDomainEventHandlingsExecutor domainEventHandlingsExecutor) : base(options)
    {
        _domainEventHandlingsExecutor = domainEventHandlingsExecutor;
    }

    public override int SaveChanges()
    {
        var numberOfChanges = base.SaveChanges();

        _domainEventHandlingsExecutor.Execute(GetDomainEventEntities());

        return numberOfChanges;
    }

    private IEnumerable<IEntity> GetDomainEventEntities()
    {
        return ChangeTracker.Entries<IEntity>()
            .Select(po => po.Entity)
            .Where(po => po.Events.Any())
            .ToArray();
    }

最后但并非最不重要的一点是,我在AutofacModule 中注册了与域事件处理相关的所有处理程序和逻辑:

public class AutofacEventHandlingBootstrapperModule : Module
{
    protected override void Load(ContainerBuilder builder)
    {
        builder.RegisterType<EventDispatcher>().As<IEventDispatcher>().InstancePerLifetimeScope();
        builder.RegisterType<DomainEventHandlingsExecutor>().As<IDomainEventHandlingsExecutor>().InstancePerLifetimeScope();

        RegisterEventHandlersFromDomainModel(builder);
    }

    private static void RegisterEventHandlersFromDomainModel(ContainerBuilder builder)
    {
        var domainModelExecutingAssembly = new DomainModelExecutingAssemblyGetter().Get();

        builder.RegisterAssemblyTypes(domainModelExecutingAssembly)
            .Where(t => t.GetInterfaces().Any(i => i.IsClosedTypeOf(typeof(IHandler<>))))
            .AsImplementedInterfaces()
            .InstancePerLifetimeScope();
    }
}

当然要在Startup.cs注册:

   public IServiceProvider ConfigureServices(IServiceCollection services)
    {
        services.AddMokaKukaTrackerDbContext(CurrentEnvironment, Configuration);

        return new AutofacServiceProvider(CreateIoCContainer(services));
    }

    private static IContainer CreateIoCContainer(IServiceCollection services)
    {
        var builder = new ContainerBuilder();
        builder.Populate(services);
        builder.RegisterModule(new AutofacInjectorBootstrapperModule());
        builder.RegisterModule(new AutofacEventHandlingBootstrapperModule());

        return builder.Build();
    }

就是这样,希望对大家有所帮助!

【讨论】:

  • 当然可以!我现在在国外,但星期一我回来了,我会把它放在这里;)
  • 我使用上述解决方案,但在最后状态下 ApplicationUserRepository 用于更新数据我收到此错误:无法访问已处置的对象。此错误的一个常见原因是释放从依赖注入中解析的上下文,然后尝试在应用程序的其他地方使用相同的上下文实例。如果您在上下文上调用 Dispose() 或将上下文包装在 using 语句中,则可能会发生这种情况。如果你使用依赖注入,你应该让依赖注入容器负责处理上下文实例。对象名称:'AppIdentityDbContext'。
【解决方案2】:

解决方案是使用依赖注入容器来创建具有依赖关系的对象的实例。为此,您需要将 IContainer 向下传递给 DomainEvents 实例,即将作为参数传递给 DomainEvents.Init() 方法调用。

    // This method gets called by the runtime. Use this method to add services to the container.
    public IServiceProvider ConfigureServices(IServiceCollection services)
    {
        services.AddMokaKukaTrackerDbContext(CurrentEnvironment, Configuration);
        services.RegisterIdentityFramework();
        services.AddAndConfigureMvc(CurrentEnvironment);

        var container = CreateIoCContainer(services);
        var autofacServiceProvider = new AutofacServiceProvider(container);
        DomainEvents.Init(container);

        return autofacServiceProvider;
    }

然后,DomainEvents 类应该存储对container 的引用并在Dispatch 方法中使用它。

注 1:我没有很多 C# 经验,所以我不确定是否应该将 IContainerIServiceProvider 注入 DomainEvents

注 2: 正如@TSeng 在 cmets 中所说,尽量不要使用静态方法;重构为使用类的实例。

【讨论】:

  • 感谢您的回答,感谢您的帮助!所以我应该将Icontainer 传递给我的DomainEvents 类,然后构造事件处理程序,对吗?我应该如何以及为什么在Dispatch 方法中使用container
  • @mirind4 正如我所提到的,我没有使用 C# 的经验,但在其他 OOP 语言(即 PHP)中,容器可用于实例化简单或复杂的对象(有很多嵌套依赖项)。我不知道您究竟是如何调用容器来创建特定类型的实例。
  • 好的,谢谢,我会深入研究代码并检查我能想出什么;)
  • 无论如何! :)
  • 我成功解决了。好吧,我已经做了几次重构,但解决方案确实是将容器注入到我的域事件初始化器类中并在那里解决依赖关系。确切地说,我不得不注入 ILifetimeScope 而不是 IContainer,因为这是使用 Autofac IoC 框架应该如何完成的方式。无论如何我接受你的回答,谢谢你的帮助!最良好的祝愿;)
猜你喜欢
  • 1970-01-01
  • 2010-12-04
  • 2021-07-22
  • 1970-01-01
  • 1970-01-01
  • 2012-08-17
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多