MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。
在学习中介者模式时,我遇到了大众交通。 虽然我对理论有足够的理解(我希望),但我正在努力寻找支持的代码示例/文档......
我有一个处理消息的 C# 应用程序,需要为收到的每条消息调用 python 代码。但是,如果我并行运行处理,我的 docker 容器就会崩溃并显示 139 退出代码。怎么可以...
我在 MassTransit 中有一个消费者,它似乎想默认监听队列上的消息。它创建一个带有订阅的主题和一个队列。消息从订阅者转发...
.NET - MassTransit - 所有人的 StateMachine 故障消息
我有一个关于公共交通图书馆中的 statmachine 的问题。这是我的代码: 公共活动?请求{得到; } 公共活动?开始{获取; } 公开活动<
我正在使用 https://masstransit.io/ 库,发送 2000 条消息平均使用 100% CPU 15 分钟。 一开始我以为是因为消息要求的工作,但后来我尝试了
公共交通中请求客户端和 RoutingSlip 快递的典型用法的差异
我知道对于分布式和顺序服务,我们正在使用 RoutingSlip courier。想象一下,我有一个场景,我想要一个请求发布者,我们将其命名为 apiPublisher,它想要调用数据库...
MassTransit:尝试访问 ConsumeContext 的 MT-* 标头<Fault<T>>
我一直在尝试使用故障消费者来处理附加信息,但故障消费者的上下文似乎没有任何我可以在 RabbitMq Managem 中看到的 MT-* 标头...
我正在开发一个使用 Kafka 并应用 Saga 模式的 POC。我能够创建一条快乐的路径,在其中我可以消费来自某个主题的消息并通过其他 Kafka 将其发送到多个服务
我正在尝试将单个消费者绑定到多个端点。这可能吗? 我的消费者 OrderPlacedConsumer 类:IConsumer { 公共任务消耗(ConsumeContext 我正在尝试将单个消费者绑定到多个端点。这可能吗? 我的消费者 class OrderPlacedConsumer : IConsumer<OrderPlaced> { public Task Consume(ConsumeContext<OrderPlaced> context) { //do stuff } } 我注册消费者和巴士的方式。 services.AddMassTransit(x => { x.AddConsumer<OrderPlacedConsumer>(); x.UsingRabbitMq((ctx, cfg) => { //Read RabbitMq setting from config string connectionString = config.ConnectionStrings.RabbitMQConnString; RabbitMQSetting rabbitMQSetting = GetRabbitMQSetting(connectionString); cfg.Host(rabbitMQSetting.Host, (ushort)rabbitMQSetting.Port, "/", h => { h.PublisherConfirmation = false; h.Username(rabbitMQSetting.UserName); h.Password(rabbitMQSetting.Password); h.Heartbeat(TimeSpan.FromSeconds(rabbitMQSetting.Heartbeat)); }); cfg.ReceiveEndpoint("endpoint1", e => { e.ConfigureConsumer(ctx, OrderPlacedConsumer); #region Exchange e.ConfigureConsumeTopology = false; e.Bind("OrderExchange", x => { x.ExchangeType = ExchangeType.Direct; x.RoutingKey = "endpoint1"; }); #endregion }); cfg.ReceiveEndpoint("endpoint2", e => { e.ConfigureConsumer(ctx, OrderPlacedConsumer); #region Exchange e.ConfigureConsumeTopology = false; e.Bind("OrderExchange", x => { x.ExchangeType = ExchangeType.Direct; x.RoutingKey = "endpoint2"; }); #endregion }); }); }); 但是,“OrderPlacedConsumer”消费者仅绑定到“endpoint1”。是否也可以将其绑定到“endpoint2”。 它应该使用正确的语法正确配置消费者: e.ConfigureConsumer<OrderPlacedConsumer>(ctx);
我正在尝试为我的状态机创建单元测试,以检查每个状态是否执行其应该执行的操作。 我可以通过发布启动状态的事件将状态机带入任何状态
实现 C# .NET 7 RestAPI RabbitMQ 时出错 - MassTransit 死信队列 (DLQ)
我正在尝试更好地使用微服务,但我陷入了困境。我正在与: ASP.NET Core 7 Web API(用于微服务) C# SQL服务器 RabbitMQ 和 MassTransit Docker 撰写 (
我将 MassTransit v8.0.8 库与 Azure 服务总线和 EF Core 结合使用。以下是我设置服务的方式。其中一个消费者运行时间稍长,因为它处理大量记录......
在以下场景中,API 使用 SqlServer 事务发件箱将消息发布到队列。 另一个组件使用该消息并使用 SqlServer 事务发件箱来三...
我正在尝试使用公共交通创建一个状态机,在其中等待 3 个状态更改为“已完成”。然后当我确定所有 3 个都已完成时,我想调用一些最终代码或其他东西......
与 MassTransit 的未知交换类型“x-delay-message”RabbitMq
我已经安装了“RabbitMQ延迟消息插件”。可以在 RabbitMq 的插件列表中看到。 并使用 RabbitMq 配置 MassTnasit 使用以下代码: var services = 新的 ServiceCollecti...
公共交通3.5, 兔子Mq 我有一个总线连接服务,可以侦听队列数量。 Q1 Q2 第三季度 第四季度 ETC 所有队列都接受相同的消息类型,并且所有队列都使用竞争的 con...
MassTransit Kafka Consumer Console 应用程序无法重复连接到 Kafka 主题端点
我正在尝试使用 MassTransit 创建一个使用主题中的数据的 Kafka Consumer。作为其中的一部分,我正在使用测试容器(特别是 Kafka)为其创建集成测试
MassTransit Consumer 不消费服务总线主题消息
我们正在使用 MassTransit 生成消息并写入 Azure 服务总线,我们有一个消费者,它是使用相同的包编写的来消费消息,但它无法消费消息...
更新到 MassTransit 5.3.0 导致 ScopedConsumeContextProvider 未注册
我正在使用 MassTransit 5.2.0。我必须更新,因为我们要使用 AWS,并且它需要 amqps 协议才能使用rabbit mq,而 5.2.0 不支持该协议。我最终可能想要