Возможно ли одно сообщение RabbitMQ для каждого пользователя?
Совершенно новый для rabbitMQ, но рассматривает возможность использования его в качестве механизма организации очередей в GKE. У меня вопрос, наверное, очень простой.
Есть ли способ обрабатывать только одно сообщение от пользователя (GUID в моем приложении) в данный момент времени (даже если у меня несколько рабочих). По сути, у меня есть несколько вышестоящих третьих сторон, которые отправляют на одну из моих конечных точек дублирующие сообщения. Я могу подтвердить, что дубликат документа уже отправлен, если я работаю синхронно (для каждого пользователя). Проблема возникает, если у меня есть несколько рабочих узлов, одновременно обрабатывающих отдельные сообщения для одного и того же пользователя.
Возможно ли это в RabbitMQ? Есть ли рекомендуемый способ справиться с этим? Спасибо большое.
Ответы 1
Это невозможно, если несколько рабочих процессов используют одну и ту же очередь. Либо используйте одного рабочего, убедитесь, что обработка сообщений является идемпотентной, либо координируйте свои действия между вашими рабочими процессами.
NOTE: the RabbitMQ team monitors the rabbitmq-usersmailing list and only sometimes answers questions on StackOverflow.
Спасибо большое. Это то, что я нашел, а также.