小编TjD*_*haw的帖子

我对我的 PoC 进行了一些性能测试。我看到的是我的演员没有收到发送给他的所有消息，而且表现非常低。我向我的应用程序发送了大约 150k 条消息，这导致我的处理器达到 100% 利用率的峰值。但是当我停止发送请求时，2/3 的消息没有传递给参与者。以下是来自应用洞察的简单指标：

为了证明我在 mongo 中持久化的事件数量与我的演员收到的消息数量几乎相同。

其次，处理消息的性能非常令人失望。我每秒收到大约 300 条消息。

我知道默认情况下 Akka.NET 消息传递最多一次，但我没有收到任何错误消息说消息已被丢弃。

这是代码：集群分片注册：

 services.AddSingleton<ValueCoordinatorProvider>(provider =>
 {
   var shardRegion = ClusterSharding.Get(_actorSystem).Start(
                    typeName: "values-actor",
                    entityProps: _actorSystem.DI().Props<ValueActor>(),
                    settings: ClusterShardingSettings.Create(_actorSystem),
                    messageExtractor: new ValueShardMsgRouter());
                   return () => shardRegion;
 });

控制器：

    [ApiController]
    [Route("api/[controller]")]
    public class ValueController : ControllerBase
    {
        private readonly IActorRef _valueCoordinator;

        public ValueController(ValueCoordinatorProvider valueCoordinatorProvider)
        {
            _valueCoordinator = valuenCoordinatorProvider();
        }

        [HttpPost]
        public Task<IActionResult> PostAsync(Message message)
        {
            _valueCoordinator.Tell(message);
            return Task.FromResult((IActionResult)Ok());
        }
    }

演员：

    public class ValueActor : ReceivePersistentActor
    {
        public override …

嘿伙计们,我想清理一些代码.我有重载方法.我可以以某种方式简单地使用这个代码并在另一个方法中调用一个方法吗？无法弄清楚如何做到这一点.

private async Task<T> DecorateWithWaitScreen<T>(Func<Task<T>> action)
{
    SplashScreenManager.ShowForm(this, typeof(WaitForm), true, true, false);
    try
    {
        return await action();

    }
    catch (Exception e)
    {
        MessageBox.Show(e.Message);
        throw;
    }
    finally
    {
        SplashScreenManager.CloseForm(false);
    }
}

private async Task DecorateWithWaitScreen(Func<Task> action)
{
    SplashScreenManager.ShowForm(this, typeof(WaitForm), true, true, false);
    try
    {
        await action();
    }
    catch (Exception e)
    {
        MessageBox.Show(e.Message);
        throw;
    }
    finally
    {
        SplashScreenManager.CloseForm(false);
    }
}

我试图在我的应用程序中实现CQRS模式.所以我在这里找到了如何从程序集中注册所有命令处理程序:Autofac解决CQRS CommandDispatcher中的依赖关系

但它对我来说效果不佳.这是代码:

        containerBuilder.RegisterAssemblyTypes(assembly)
            .AsClosedTypesOf(typeof(ICommandHandler<>));

        containerBuilder.RegisterAssemblyTypes(assembly)
            .AsClosedTypesOf(typeof(IQueryHandler<,>));

处理工厂

 public class CqrsHandlerFactory : ICqrsHandlerFactory
{
    private readonly IContainer container;

    public CqrsHandlerFactory(IContainer container)
    {
        this.container = container;
    }

    public ICommandHandler<TCommand> GetCommandHandler<TCommand>(TCommand command) where TCommand : class, ICommand
    {
        return container.Resolve<ICommandHandler<TCommand>>();
    }

    public IQueryHandler<TQuery, object> GetQueryHandler<TQuery>(TQuery query) where TQuery : class, IQuery
    {
        return container.Resolve<IQueryHandler<TQuery, object>>();
    }
}

总线

 public class CqrsBus : ICqrsBus
{
    private readonly ICqrsHandlerFactory cqrsHandlerFactory;

    public CqrsBus(ICqrsHandlerFactory cqrsHandlerFactory)
    {
        this.cqrsHandlerFactory = cqrsHandlerFactory;
    }

    public void ExecuteCommand(ICommand …