全新的rabbitMQ,但考虑将其用作GKE中的排队机制。我有一个问题可能很简单。有没有一种方法可以在给定的时间只处理来自用户(我的应用程序中的用户)的单个消息(即使我有多个工作者)。从本质上讲,我有一些上游第三方,张贴到我的一个端点重复的消息。我可以确认是否已经有一个重复的文件POSTed如果我同步工作(每用户)。如果我有多个工作者节点同时为同一个用户处理不同的消息,就会出现问题。这在RabbitMQ中可能吗?是否有推荐的方法来处理此问题?非常感谢
llycmphe1#
如果多个工作进程从同一个队列消费,这是不可能的。要么有一个工作者,确保处理消息是幂等的,要么在工作者之间进行协调。
1条答案
按热度按时间llycmphe1#
如果多个工作进程从同一个队列消费,这是不可能的。要么有一个工作者,确保处理消息是幂等的,要么在工作者之间进行协调。