masstransit 相关问题

多种消息类型的批量消费者

是否可以批量使用多种消息类型？消费者应该在单个批次中处理各种类型的消息。

使用 saga 处理微服务架构中的并发请求和回滚

下面的场景我们应该如何处理？假设我们有三个微服务。我们收到两个并发请求，更新这些微服务中的相同记录。第一次请求成功...

在内存中运行 MassTransit/RabbitMQ 实例

我想实施集成测试。我不想为其启动 RabbitMQ 实例，我想要的唯一更改是修改测试中的连接设置（以使用内存实例）。 可以吗...

公共交通消息拓扑

配置接收端点时，虽然可以为通用类型消息配置使用者，但似乎没有任何方法可以为通用类型配置消息拓扑

.NET - Azure Function - Azure 服务总线重复调用

我知道这可能是一个微不足道的问题，但我不知道该怎么办。我将 Azure 服务总线与 MassTransit 一起使用。 我有两项服务。 Service1 是一个 WebApi 应用程序，Service2 是一个...

ASP.NET Core 服务未创建 RabbitMQ 队列

作为 MassTransit 和 RabbitMQ 的新用户，我目前正在尝试使我的 ASP.NET 核心服务与 MassTransit 一起使用。 使用本文档部分来配置 MassTransit 和 ASP.NET C...

访客拒绝访问虚拟主机，使用 MassTransit Sample-RequestResponse 示例

我在最新的 RabbitMQ 服务器上使用默认配置（来宾是管理员），但是当我运行 RequestResponse 示例时，我遇到了下一个异常。 OperationInterruptedException：AMQP 操作...

.NET - 服务总线 - 将消息移动到 DLQ

我在 .NET WebApi 应用程序中使用 Azure 服务总线和公共交通库。我有一个 ServiceA，我在其中发布 StartProcess 消息。该消息也用于状态机 -

使用 MassTransit 在 Mediator ConsumeContext 范围内发布/发送

在我的 ASP.NET Core 控制器中，我使用 IMediator.Send 发送命令 等待 mediator.Send(new SubmitOrder()); SubmitOrder 的消费者看起来像这样 公共类 SubmitOrderConsumer ： ICon...

MassTransit 帮助注册多个传奇

我正在努力将旧应用程序移植到.net6，并遇到了通过公共交通注册多个传奇的问题。 services.AddMassTransit(busCfg => { 总线配置。

部署到同一服务器中设置了开发和演示两个环境的服务器时，MassTransit 服务总线无法工作

基本上，我们在 .Net 核心应用程序中使用 MassTransit 和 RabbitMQ 来发布和使用消息。我们在同一台服务器上维护 2 个环境 - 开发环境和演示环境。 为此，我们有

在同一进程中使用 MassTransit 运行多个 Web 应用程序时出现奇怪的事务发件箱行为

我有多个 Web 应用程序，每个应用程序都有自己单独的 DI 容器，在同一进程中运行（侦听不同端口）。每个应用程序将 MassTransit（使用 RabbitMq）添加到 DI 中，并使用

如何在消费者范围内使用BusOutbox？

总线配置如下（使用RabbitMq）： BusConfigurator.AddEntityFrameworkOutbox(o => { o.UsePostgres(); o.UseBusOutbox(); }); 它在控制器中运行良好： ...

MassTransit 与 SQL Server 数据库传输

对于我的客户，我们正在调查大众交通的使用。 MassTransit 似乎专注于 RabbitMQ 的消息传输。由于客户的“内部结构限制”，我们陷入困境

MassTransit IBusControl.StartAsync“代理无法访问”异常

我正在使用 MassTransit（版本 8.1.3）。我们有 2 个不同的 RabbitMQ 集群，到目前为止我一直在使用其中之一。一切都运转良好。现在，我已经换了一个不同的俱乐部...

MassTransit 仅发送消息正文

考虑使用 MassTransit 来替换我公司正在使用的一些旧的、脆弱的 ActiveMQ 库。目前我们发送到AMQ的消息基本上只是对象 { “clientId”...

如何使用 OpenTelemetry 添加 RabbitMQ 跟踪？

我正在使用 OpenTelemetry 来跟踪我的 Web API (ASP.NET)。我使用 Jaeger 来显示痕迹。我有 HTTP、SQL、EF 和 Redis 跟踪。我的 Web API 使用 RabbitMQ 和 MassTransit。我怎样才能将他们的痕迹添加到...

处理RabbitMQ错误队列的最理想方式

我的应用程序有一个用于处理通知的.net core微服务，并且它已部署在Kubernetes上。其中NotificationRequestConsumer如下，（请注意这只是一个代码

如何使用 .NET Core 7 控制台向 MassTransit 消费者发送数据

我的解决方案中有两个项目，一个是控制台，另一个是API。在 API 项目中，我按如下方式设置 MassTransit： 使用大众运输； 使用通知； var builder = WebApplication.

MassTransit - 如何设置作业消费者一次处理 1 个作业？

我正在发布一条消息来开始工作。我有一个消费者设置，据我所知，我已将其配置为一次处理 1 个作业。所有其他作业都应保留在队列中，直到...