Service Fabric 中的可靠并发队列

Question

我有一个带有一个无状态服务和多个有状态服务的服务结构应用程序。无状态服务从 RabtitMQ 读取（使用 MassTransit）并将消息传递给相应的有状态服务进行处理。传递给有状态服务的消息在 ConcurrentQueue 中排队，在 RunAsync 中出列并处理。直到那里的消息数量减少为止都很好。最近消息的数量增加了数倍。现在的情况是 RabbitMq 中的消息数以百万计，有状态服务队列超载。内存使用率变得非常高，集群卡住了。

1. 队列是否在 RunAsync 方法需要等待的入队过程中被锁定。排队人数非常多。
2. 如果队列计数非常高，我无法找到停止从 RabbitMq 获取的方法。至少集群不会挂起或崩溃。
3. 在输入负载非常高的情况下，最好的设计是什么？

谢谢

Answer 1

您如何对有状态服务进行分区？如果您有一个范围或命名分区，那么您的所有消息都不应该命中同一个副本。如果您正确应用了分区方案，您的消息将最终位于同一有状态服务的不同分区中，并且您可以横向扩展。