Я пытаюсь оптимизировать микросервисную архитектуру, которая в настоящее время использует HTTP/REST для внутренней связи между узлами. Одним из вариантов является реализация возможности обратного давления в сервисах, например, путем интеграции...

Я хочу наблюдать за событием mousewheel с помощью RxJS-DOM, чтобы, когда срабатывает первое событие, я пересылаю его, а затем отбрасываю все значения до тех пор, пока задержка между последующими значениями не пройдет ранее заданную...

Я был свидетелем странного поведения onBackpressureBuffer, я не уверен, является ли это допустимым поведением или ошибкой. У меня есть вызов tcp, который отправляет элементы с определенной скоростью (используя потоковую передачу и inputStream, но...

Рассмотрите возможность использования оператора zip для объединения двух бесконечных Observable, один из которых испускает элементы в два раза чаще, чем другие. Текущая реализация без потерь, то есть, если я продолжу излучать эти Observable в...

Я новичок в распределенной потоковой обработке (Spark). Я читал несколько руководств/примеров, в которых показано, как обратное давление приводит к замедлению производительности в ответ на перегрузку потребителей. Приведенный классический пример —...

Фон Я пытаюсь реализовать что-то похожее на простой неблокирующий ограничитель скорости с помощью Spring Project Reactor версии 3.3.0. . Например, чтобы ограничить число до 100 запросов в секунду, я использую эту реализацию: myFlux...

Я создал Flowable (RxJava v3), который анализирует файл. Я бы хотел, чтобы он поддерживал обратное давление. Это важно, потому что файлы могут быть довольно большими, и я не хочу, чтобы они загружались в память сразу. Вот моя первая попытка:...

Как справиться с обратным давлением в Java с помощью пула потоков? Как отклонить новые задачи, чтобы было отправлено не более N задач. N - максимально допустимое количество задач в очереди на отправку, включая новые, запущенные,...

Я учусь обрабатывать потоковые данные с помощью Flink. Мне удалось создать пример, который должен получить и десериализовать потоковые данные из источника данных, преобразовать их и распечатать результат. Сейчас думаю, как обработать исключение...

Я пытаюсь написать приложение, которое будет интегрироваться с Kafka с помощью Camel. (Версия - 3.4.2) У меня есть подход, заимствованный из ответа на этот вопрос . У меня есть маршрут, который прослушивает сообщения из темы Kafka. Обработка...