【发布时间】:2021-09-07 07:45:18
【问题描述】:
我正在使用 MediatR 9.0.0(带有 MediatR.Extensions.Microsoft.DependencyInjection 9.0.0)。我有这样的事件通知处理程序:
public class StatusChangedEventHandler : INotificationHandler<StatusChangedEvent>
{
public StatusChangedEventHandler ()
{
}
public async Task Handle(StatusChangedEvent evnt, CancellationToken cancellationToken)
{
//some code
}
}
事件正在从另一个命令处理程序发布:
public class ChangeStatusCommandHandler : IRequestHandler<ChangeStatusCommand, bool>
{
...
private readonly IMediator _mediator;
public ChangeStatusCommandHandler(...,IMediator mediator)
{
...
_mediator = mediator;
}
public async Task<bool> Handle(ChangeStatusCommand command, CancellationToken cancellationToken)
{
...
await _mediator.Publish(new StatusChangedEvent(int id, string message));
...
}
}
问题是多次调用 StatusChangedEventHandler.Handle 方法 - 我注意到它似乎与在 Startup.cs 中注册的命令处理程序的数量有关,例如
services.AddMediatR(typeof(CommandA));
=> 处理程序将被调用一次
services.AddMediatR(typeof(CommandA));
services.AddMediatR(typeof(CommandB));
=> 处理程序将被调用两次
services.AddMediatR(typeof(CommandA));
services.AddMediatR(typeof(CommandB));
services.AddMediatR(typeof(CommandC));
=> 处理程序将被调用 3 次等等。
如何解决这个问题以使处理程序只被调用一次?
【问题讨论】:
-
您能展示一下您是如何发布活动的吗?
-
添加事件发布代码