В моем webflux-приложении я принимаю сообщения от AWS-SQS и использую их для вызова нескольких HTTP-запросов на медленном бэкэнде (время ответа до 5 секунд).
Я понял, что чем больше сообщений я потребляю, тем медленнее становится бэкэнд, пока он не умрет, из-за слишком большого трафика.
Как я могу использовать механизм реактора / webflux, чтобы контролировать количество запросов, которые я отправляю бэкэнду? Я пробовал некоторые вещи с помощью limit / limitRate, но он не сработал, как ожидалось.
Есть ли у вас образцы / идеи?