Постановка проблемы
При запуске несколько компьютеров станут подключенными.Есть планировщик, который будет работать на каждой из этих машин.Планировщик будет запускаться каждые 5 минут на каждой машине.Там он будет кучу данных для чтения с Кассандры.Однако только одна машина должна читать эти сообщения от Cassandra и должна удалять сообщения после того, как это сделано.Две или более машины, считывающие / обрабатывающие одни и те же данные, вызовут нежелательную загрузку в нисходящей системе.
Возможные решения:
Использование zookeeper для реализации распределенной блокировки.
Возможно, используйте Leaderшаблон проектирования выборов.
шаблон проектирования общих ресурсов также работает аналогичным образом.
измененный шаблон проектирования утечек, который может работать с распределенным приложением
существует ли шаблон проектирования, который можно использовать для решения этой проблемыпроблема