masstransit 相关问题

我正在使用 MassTransit 和 Amazon MQ 实施请求/响应。 (.NET 6 WebApi) 主机配置如下：服务 .AddMassTransit(x => { x.添加消费者我正在使用 MassTransit 和 Amazon MQ 实施请求/响应。 (.NET 6 WebApi) 主机配置如下： services .AddMassTransit(x => { x.AddConsumer<ConfigurationConsumer>(); x.UsingRabbitMq((context, cfg) => { cfg.Host(new Uri($"amqps://{rabbitMqSettings.Host}:{rabbitMqSettings.Port}/{Uri.EscapeDataString("/vhostname")}"), h => { h.Username(rabbitMqSettings.Username); h.Password(rabbitMqSettings.Password); }); cfg.ConfigureEndpoints(context); }); x.AddRequestClient<IConfigurationCommand>(); }) .AddMassTransitHostedService(); 客户端使用相同的配置，无需 x.AddConsumer() 和 cfg.ConfigureEndpoints(context)。问题是：在客户端调用 GetResponse 将成功执行主机上的消费者，该消费者似乎按预期响应，但客户端永远不会得到结果并超时。另一方面，当我在同一主机上使用 Web api 控制器来启动 GetResponse 时，一切都按预期工作。确保主机和客户端应用程序之间的消息类型相同。另外，请确保使用托管服务或其他方式在客户端上启动总线。在我的响应类型上使用继承类时，我遇到了同样的超时问题，其中父类有一个失败响应的方法！最后，当将响应强制转换为子类时，问题得到了解决。 MyCommon-lib： public partial interface IEvent { bool Succeeded { get; } string Message { get; } } public abstract record Event<TModel> : IEvent where TModel : IEvent { public bool Succeeded { get; set; } = true; public string Message { get; set; } = string.Empty; public TModel Failed(Exception exception) { Succeeded = false; Message = exception.InnerException?.Message ?? exception.Message; return (TModel)(object)this; //! problem was here, where I cannot return this as simple as 'return this;' } public TModel Failed(string message) { Succeeded = false; Message = message; return (TModel)(object)this; } } public partial interface IEvent { public record PointHistory(IList<PointHistoryDto>? Group, IEnumerable<PointHistoryDto>? Filtered) : Event<PointHistory>, IEvent; public record PointApplied() : Event<PointApplied>, IEvent; } 微服务1::MyMediator: public async Task DoSomething() { ... var pointHistory = await bus.Request<ICommand.PointHistory, IEvent.PointHistory>( ... ); if (!pointHistory.Message.Succeeded) throw new UserException(pointHistory.Message.Message); ... var pointApplied = await bus.Request<ICommand.PointApply, IEvent.PointApplied>( ... ); if (!pointHistory.Message.Succeeded) throw new UserException(pointHistory.Message.Message); ... } 微服务2::我的消费者1: internal class MyConsumer1( IPointService service ) : IConsumer<ICommand.PointApply> { public async Task Consume(ConsumeContext<ICommand.PointApply> context) { try { ICommand.PointApply request = context.Message; ... //! response await context.RespondAsync(new IEvent.PointApplied()); } catch (UserException err) { await context.RespondAsync(new IEvent.PointApplied().Failed(err)); } } }

.net-core masstransit

回答 2 投票 0

StartJobAttempt<StartJobAttempt>（事件）执行失败

我在 .NET 8 上使用 MassTransit 8.25.0。我有一个带有调度程序和作业使用者的 Windows 服务。无法弄清楚如何对作业进行排队，示例中的 IPublishEndpoint 是一个范围服务，所以我可以...

c# masstransit .net-8.0

回答 1 投票 0

MassTransit 中的自定义消息消费

我有一个要求，我有两个具有相同代码库的 ASP.NET Core 应用程序（A 和 B）。每个应用程序都会发布一些它使用和处理的命令。现在，当应用程序 A

c# rabbitmq masstransit

回答 1 投票 0

如何有条件地创建 MassTransit 传奇？

我有一个传奇，每当两个事件之一发生时就应该触发。但是，如果数据库中的条件未满足，则不应创建传奇。我已经尝试过类似的事情，但它......