MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。
在同一进程中使用 MassTransit 运行多个 Web 应用程序时出现奇怪的事务发件箱行为
我有多个 Web 应用程序,每个应用程序都有自己单独的 DI 容器,在同一进程中运行(侦听不同端口)。每个应用程序将 MassTransit(使用 RabbitMq)添加到 DI 中,并使用
总线配置如下(使用RabbitMq): BusConfigurator.AddEntityFrameworkOutbox(o => { o.UsePostgres(); o.UseBusOutbox(); }); 它在控制器中运行良好: ...
MassTransit 与 SQL Server 数据库传输
对于我的客户,我们正在调查大众交通的使用。 MassTransit 似乎专注于 RabbitMQ 的消息传输。由于客户的“内部结构限制”,我们陷入困境
MassTransit IBusControl.StartAsync“代理无法访问”异常
我正在使用 MassTransit(版本 8.1.3)。我们有 2 个不同的 RabbitMQ 集群,到目前为止我一直在使用其中之一。一切都运转良好。现在,我已经换了一个不同的俱乐部...
考虑使用 MassTransit 来替换我公司正在使用的一些旧的、脆弱的 ActiveMQ 库。目前我们发送到AMQ的消息基本上只是对象 { “clientId”...
如何使用 OpenTelemetry 添加 RabbitMQ 跟踪?
我正在使用 OpenTelemetry 来跟踪我的 Web API (ASP.NET)。我使用 Jaeger 来显示痕迹。我有 HTTP、SQL、EF 和 Redis 跟踪。我的 Web API 使用 RabbitMQ 和 MassTransit。我怎样才能将他们的痕迹添加到...
我的应用程序有一个用于处理通知的.net core微服务,并且它已部署在Kubernetes上。其中NotificationRequestConsumer如下,(请注意这只是一个代码
如何使用 .NET Core 7 控制台向 MassTransit 消费者发送数据
我的解决方案中有两个项目,一个是控制台,另一个是API。在 API 项目中,我按如下方式设置 MassTransit: 使用大众运输; 使用通知; var builder = WebApplication.
MassTransit - 如何设置作业消费者一次处理 1 个作业?
我正在发布一条消息来开始工作。我有一个消费者设置,据我所知,我已将其配置为一次处理 1 个作业。所有其他作业都应保留在队列中,直到...
MassTransit RateLimit,一个队列上有多个消费者
我正在寻求有关 UseRateLimit(...) 功能如何在以下情况下工作的说明:我们有许多消费者共享同一队列。每个消费者都有自己独特的混乱......
我有一个项目,以前的 ef 命令(例如 add-migration 和 update-database)工作正常。 但我做了一些事情之后这些命令就不再起作用了。 1-添加 Resharper p...
将达到最大传递计数的消息移至错误/新队列而不是死信 - 公共交通 Azure 服务总线
我们需要一种方法来处理死信队列中的消息,但Azure服务总线资源管理器似乎不支持application/vnd.masstransit+json内容类型来重新发送所选消息。 很少
我正在尝试对我的 MassTransit saga 状态机进行单元测试 期间( 加工, 何时(创建协议失败) 。然后(
使用 MassTransit 调用 DurableTaskClient 函数
我有一个 Azure Function,它使用 Orchestrator 从外部源同步产品。 直到今天,这个函数都是由 TimerTrigger 或 HttpTrigger 调用,并传递一个 InventoryId
我希望在我的应用程序中将 MassTransit 用于各种用例。一种用例是处理应用程序中的“域事件”。在这个用例中,我有一些正在变化的业务数据......
如何使用 RabbitMQ 服务总线加过滤器实现 MassTransit 的请求/响应模式?
我正在使用 RabbitMQ 使用 IBusControl 对象和仅 1 个队列来实现 MassTransit 的请求/响应模式。 我们将运行 1 个请求发起者应用程序(当前是单元测试)并且
MassTransit 会使用其默认名称格式化程序创建主题/订阅,无论配置如何
使用公共交通。一切工作正常,并且消费/发布到预先创建的正确主题/队列。 但它正在创建额外的主题/订阅,而你却没有......
我通过 RabbitMQ 传递大量数据并卸载队列,我使用声明检查模式将字节 blob 存储在队列本身之外。它工作得很好,但我有一个关于 cl 的问题...
我正在尝试使用 Masstransit 来消费一条带有空正文的消息,因为我只对它的标头感兴趣,但是当我发送带有空正文的消息时,它会直接路由到 _error 队列...
我已在 Azure 上成功使用 MassTransit,它为每个消费服务/应用程序生成一个“队列”,其中包含许多主题和订阅。 现在我已经将一些代码移植到 AWS,它似乎可以工作......