masstransit 相关问题

如何为通过 AddConsumer() 创建的队列配置 PurgeOnStartup？

防止 XY 问题的一些背景： 我正在开发一个系统，其中每 X 分钟发送一条消息以在服务中的 Pod 上运行作业。当所有 pod 都不健康或重新启动时，这些

如何在MassTransit中制作过滤器？

我正在尝试处理 MassTransit，我有许多带有 StableDefussion 的服务器，它们接受在队列中生成图像的任务 但事实是不同的服务器有不同的...

使用 MassTransit 使用交换和路由密钥发布消息

我已经关注大众交通几周了，我对它的可能性很好奇。但是，我似乎无法完全正确地理解这些概念。 预期行为 我想要

大众交通：领域与集成事件

在学习中介者模式时，我遇到了大众交通。 虽然我对理论有足够的理解（我希望），但我正在努力寻找支持的代码示例/文档......

Pythonnet 消息处理中的多个 python 实例

我有一个处理消息的 C# 应用程序，需要为收到的每条消息调用 python 代码。但是，如果我并行运行处理，我的 docker 容器就会崩溃并显示 139 退出代码。怎么可以...

MassTransit 与 Azure 服务总线主题订阅

我在 MassTransit 中有一个消费者，它似乎想默认监听队列上的消息。它创建一个带有订阅的主题和一个队列。消息从订阅者转发...

.NET - MassTransit - 所有人的 StateMachine 故障消息

我有一个关于公共交通图书馆中的 statmachine 的问题。这是我的代码： 公共活动？请求{得到; } 公共活动？开始{获取; } 公开活动<

重连后Batch有顺序保证吗？

如果我接受了Batch，然后消费者与代理的连接断开了，是否可以保证当消费者重新连接时相同的消息将进入Batch？对于

MassTransit 如何消耗 CPU

我正在使用 https://masstransit.io/ 库，发送 2000 条消息平均使用 100% CPU 15 分钟。 一开始我以为是因为消息要求的工作，但后来我尝试了

公共交通中请求客户端和 RoutingSlip 快递的典型用法的差异

我知道对于分布式和顺序服务，我们正在使用 RoutingSlip courier。想象一下，我有一个场景，我想要一个请求发布者，我们将其命名为 apiPublisher，它想要调用数据库...

MassTransit：尝试访问 ConsumeContext 的 MT-* 标头<Fault<T>>

我一直在尝试使用故障消费者来处理附加信息，但故障消费者的上下文似乎没有任何我可以在 RabbitMq Managem 中看到的 MT-* 标头...

捕获并处理 Saga 内消费者抛出的异常

我正在开发一个使用 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 事务发件箱来三...

MassTransit 状态机等待所有消息

我正在尝试使用公共交通创建一个状态机，在其中等待 3 个状态更改为“已完成”。然后当我确定所有 3 个都已完成时，我想调用一些最终代码或其他东西......

与 MassTransit 的未知交换类型“x-delay-message”RabbitMq

我已经安装了“RabbitMQ延迟消息插件”。可以在 RabbitMq 的插件列表中看到。 并使用 RabbitMq 配置 MassTnasit 使用以下代码： var services = 新的 ServiceCollecti...

MassTransit (C#) 中跨端点的并发限制

公共交通3.5， 兔子Mq 我有一个总线连接服务，可以侦听队列数量。 Q1 Q2 第三季度 第四季度 ETC 所有队列都接受相同的消息类型，并且所有队列都使用竞争的 con...