cqrs 相关问题

命令查询责任分离（CQRS）是一种体系结构模式，它将命令（更改数据）与查询（读取数据）分开。有关更多详细信息和对学习资料的参考，请参阅“关于cqrs标记”。不要与命令查询隔离（[CQS]）混淆，后者是CQRS所包含的对象方法设计原则。

我可以在CQRS中的另一个CommandHandler中调用QueryHandler/CommandHandler吗

我正在开发一个 ASP.NET Core 6.0 Web API 项目。我使用 CQRS 设计模式。我想更新航空公司表（代码优先 EF Core）。所以首先我需要找到航空公司的ID。我有

c# asp.net-core asp.net-core-webapi cqrs

回答 4 投票 0

CQRS 使用条件变量的单个命令或多个专用命令

对于每个条件，cqrs 中应该有单个还是多个命令？示例：如果有命令GenerateAndSendReportToClient，它可以通过SSN或TaxNumber找到客户，是否应该有

domain-driven-design cqrs

回答 1 投票 0

如何使用 MediatR 和 FluentValidation 实现通用 ValidationBehavion，以便 ValidationBehavion 仅在命令上触发

我正在使用 CQRS 并为了分隔命令和查询而创建了自定义接口，因此我希望我的 ValidationBehavion 仅在继承 IRequest 的自定义 ICommand 上触发我正在使用 CQRS 并分离命令和查询，我创建了自定义接口，因此我希望我的 ValidationBehavion 仅在继承 IRequest 的自定义 ICommand 上触发，而不是在所有 IRequest 请求上触发。为了分离命令和查询，我创建了自定义界面：（作为响应值，我使用 ErrorOr 库。但我认为不值得研究它，只需记住命令和查询总是有响应） public interface ICommand<TResponse> : IRequest<ErrorOr<TResponse>> { } public interface IQuery<TResponse> : IRequest<ErrorOr<TResponse>> { } public interface ICommandHandler<TCommand, TResponse> : IRequestHandler<TCommand, ErrorOr<TResponse>> where TCommand : ICommand<TResponse> { } public interface IQueryHandler<TQuery, TResponse> : IRequestHandler<TQuery, ErrorOr<TResponse>> where TQuery : IQuery<TResponse> { } 我知道一种标准方法，其中 IPipelineBehavior 会向任何请求者触发，然后我们检查该请求者是否有验证器： public class ValidationBehavion<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse> where TRequest : IRequest<TResponse> where TResponse : IErrorOr { private readonly IValidator<TRequest>? _validator; public ValidationBehavion(IValidator<TRequest>? validator = null) { _validator = validator; } public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken) { if(_validator is null) { return await next(); } var validationResult = await _validator.ValidateAsync(request); if (validationResult.IsValid) { return await next(); } var validationErrors = validationResult.Errors .ConvertAll(error => Errors.Wands.NotValid( error.PropertyName, error.ErrorMessage)); return (dynamic)validationErrors; } } 由于命令和查询是分离的，我想我可以指定 ICommand 而不是 IRequest 并重做 ValidationBehavion，如下所示： public class ValidationBehavion<TRequest, TResponse> : IPipelineBehavior<TRequest, ErrorOr<TResponse>> where TRequest : ICommand<TResponse> { private readonly IValidator<TRequest> _validator; public ValidationBehavion(IValidator<TRequest> validator) { _validator = validator; } public async Task<ErrorOr<TResponse>> Handle(TRequest request, RequestHandlerDelegate<ErrorOr<TResponse>> next, CancellationToken cancellationToken) { var validationResult = await _validator.ValidateAsync(request); if (validationResult.IsValid) { return await next(); } var validationErrors = validationResult.Errors .ConvertAll(error => Errors.Wands.NotValid( error.PropertyName, error.ErrorMessage)); return validationErrors; } } 但是这个 IPipelineBehavior 根本不起作用，我不知道为什么。您可能需要注册该行为。你的startup.cs应该看起来像这样： public class Startup { public void ConfigureServices(IServiceCollection services) { services.AddControllers(); services.AddMediatR(typeof(Startup)); services.AddValidatorsFromAssemblyContaining<Startup>(); // Register pipeline behaviors services.AddTransient(typeof(IPipelineBehavior<,>), typeof(LoggingBehavior<,>)); services.AddTransient(typeof(IPipelineBehavior<,>), typeof(AuthorizationBehavior<,>)); services.AddTransient(typeof(IPipelineBehavior<,>), typeof(PerformanceBehavior<,>)); services.AddTransient(typeof(IPipelineBehavior<,>), typeof(UnhandledExceptionBehavior<,>)); // Register request pre-processors and post-processors services.AddTransient(typeof(IRequestPreProcessor<>), typeof(ValidationPreProcessor<>)); services.AddTransient(typeof(IRequestPostProcessor<,>), typeof(LoggingPostProcessor<,>)); } public void Configure(IApplicationBuilder app, IWebHostEnvironment env) { if (env.IsDevelopment()) { app.UseDeveloperExceptionPage(); } app.UseRouting(); app.UseAuthorization(); app.UseEndpoints(endpoints => { endpoints.MapControllers(); }); } } 您在这里有完整的教程：https://argosco.io/using-ipipelinebehavior-irequestpreprocessor-and-irequestpostprocessor-in-a-net-core-api/net/

asp.net-web-api cqrs fluentvalidation mediatr

回答 1 投票 0

当实体切换上下文时处理事件源中的相关 ID 更改

我正在开发一个事件源应用程序，该应用程序可以抓取来自不同博彩公司的体育博彩游戏。我的系统中有两个主要聚合：游戏：代表体育博彩赛事...

domain-driven-design correlation cqrs distributed-system event-sourcing

回答 1 投票 0

NestJS CQRS 配方中处理“事件溯源”的首选方式

我一直在尝试找出使用 NestJS CQRS 配方（https://docs.nestjs.com/recipes/cqrs）时进行“事件溯源”的首选方式。我一直在看 NestJS fra...

node.js typescript nestjs cqrs event-sourcing

回答 4 投票 0

Nestjs 事件溯源 - 事件持久化

Nestjs 中如何处理事件持久化？文档（阅读 CQRS 配方）中并不清楚我们应该如何保存事件以及如何使用快照回复它们。也不清楚如何