В настоящее время у нас есть 2 системы, которые общаются напрямую.
Сервис A постоянно (но не периодически) отправляет сообщения в сервис B. Сообщение в простом формате ключ / значение.Ключ - это целое число, а значение - текущая местная дата и время.
Служба B, чтобы решить, обрабатывать ли запрос, имеет эту логику для проверки последнего входящего запроса;Если есть разница во времени относительно системного времени (для каждого ключа), и разница больше 10 минут, тогда он начинает обрабатывать запрос.
Теперь, когда мы внедряем RabbitMQ в наше решение, нам нужнопересмотреть эту модель связи.Я подумывал использовать отложенный обмен сообщениями для временного окна 10 минут, а затем переписать и сбросить время (перепланировать еще на 10 минут) для дубликатов сообщений, поступающих от службы A.
Не могли бы вы поделиться своими идеями об этом предлагаемом решении?