MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。
MASSTRANSITRESPESTCLIENT超时在Azure上 - 响应队列和托管身份的可能问题
我正在使用Azure ServiceBus在
services.AddMassTransit(x => { x.AddSagaStateMachine<MonitoringJobStateMachine, MonitoringJobState>() .InMemoryRepository(); x.UsingRabbitMq((context, cfg) => { cfg.Host(new Uri(rabbitHost), h => { h.Username(rabbitUser); h.Password(rabbitPass); }); cfg.UseDelayedMessageScheduler(); cfg.ReceiveEndpoint(sagaQueue, e => { e.StateMachineSaga( context.GetRequiredService<MonitoringJobStateMachine>(), context.GetRequiredService<ISagaRepository<MonitoringJobState>>()); }); }); });
用Redis Pub/Sub在低水平的Redis客户端进行交流可能是非常痛苦的经历。您可以使用具有更高级别抽象的ServiceStack之类的库来使其更易于管理。
.Net 8 - MassTransit/RabbitMQ:根据路由键路由消息
我有三个微服务:ImageService、ProductService 和 UserService。 ImageService 存储图像并为其他两个(甚至更多)服务发布消息。这些消费者必须拦截...
使用 MassTransit 与 postgres 传输和 EF Core 进行持久化时如何实现消息重复数据删除
当队列消息具有共同的关联 ID 时,如何确保不存在重复的队列消息?当队列中已存在带有
我使用卡夫卡公共交通。我认为大众交通会处理我的消费者异常,而不是确认消息。 消费者将消息保存在收件箱中,如果数据库不可用,例外...
MassTransit 和 RabbitMQ:为消费者实现重复消息检测
我正在运行多个服务,它们都引用相同的消息契约库。 服务在 MassTransit 上发布事件。 我几乎经常在
尝试在 MassTransit 中设置请求/响应,但遇到依赖注入问题
因此,我尝试在 MassTransit 中设置请求/响应,但遇到了依赖项注入问题,我不知道它是什么,但我将提供与该问题相关的代码。 这是
如何在 EF Core 7.0 中为 ExecuteUpdateAsync 编写单元测试用例。 例如,像 GetAll 方法一样,我们可以如下模拟。我可以模拟executeupdateasync 方法吗? repositoryMock.Setup(x => x.GetAll()).
MassTransit SendFilter 无法停止消息发送
我在多租户应用程序中将 MassTransit 与 RabbitMQ 结合使用。我使用 IFilter 实现了自定义发件箱模式,该模式应该只将消息保存在我的数据库中,但我发现它也......
我有一个使用 MassTransit 的工作状态机,但是,我想使用 EF Core 持久存储状态。我按照 MassTransit 网站上的指南进行操作,但它不起作用,它确实...
我已经将公共交通与rabbit mq和.NET 6一起使用了一段时间,现在对于另一个项目,我正在尝试使用Azure服务总线。 我已经阅读了文档到一定程度,并且我了解...