我有一个处理不同类型消息的微服务。其中一种类型 (A) 需要先于其他类型进行处理。因此，如果队列有 1000 个 B 类型的条目，并且一条 A 类型的消息进入队列，那么该消息将在其他 1000 条消息之前被消耗。
我们计划使用优先级队列，但发现他们不支持 Quorum 类型队列。我们考虑过恢复使用经典队列，但我们不想在将来升级到更新版本的 RabbitMq。
有人以为我有两个队列。一个用于 A 类消息，一个用于其他消息。然后我们有一个“漏斗”服务，它会从两个更喜欢 A 队列中读取。然后，此服务会将消息移动到主处理队列，以便 A 消息先行。这样做的关键是不要压垮主处理队列，以免积压数千条消息。有什么方法可以计量消息以防止这种情况发生吗？或者有没有人有其他更好的想法来实现我们正在尝试做的事情？