Описание тега spring-reactor

Вопросы с тегом
1 ответ

Есть ли разница для веб-браузера, когда серверная часть использует webflux или простой контроллер отдыха?

Предположим, у нас есть 2 сервиса отдыха: // a rest controller @GetMapping private List<Employee> getAllEmployees() { return employeeRepository.findAllEmployees(); } // другой контроллер @GetMapping private Flux<Employee> getAllEmployees…
25 авг '20 в 20:37
1 ответ

Почему блокируется ConnectableFlux.connect()?

Я новичок в Spring Reactor. Я пытался понять, как работает класс ConnectableFlux. Я читал документы и видел примеры, размещенные в Интернете, но застрял в проблеме. Может кто подскажет, почему блокируется метод connect()? Я не вижу ничего в документ…
18 май '20 в 17:18
0 ответов

Связанные запросы Spring WebClient, выполняемые для синхронных API

Я знаю, что это слишком много контекста, но, пожалуйста, потерпите меня. Мы создаем службу на основе Spring Boot, которая в основном считывает некоторые данные из внешнего синхронного API через HTTP-вызовы и, в зависимости от некоторых конкретных фл…
14 апр '20 в 19:30
2 ответа

Преобразуйте Scala Future в Reactor Flux

Я вызываю API, который возвращает Future of Scala, и я хочу превратиться в Reactor Fluxочевидно без блокировки и ждем ответа будущего. Я пытаюсь использовать EmitterProcessor, и он отлично работает, когда будущее приносит успех, но, к сожалению, это…
01 окт '19 в 20:57
3 ответа

Как вызвать исключение в части ошибки реактивного вызова Spring WebClient?

Я хотел бы, чтобы следующий метод генерировал настраиваемое исключение в случае возникновения ошибки: @Service public class MyClass { private final WebClient webClient; public MatcherClient(@Value("${my.url}") final String myUrl) { this.webClient = …
02 окт '19 в 12:37
1 ответ

Можем ли мы использовать Spring Webflux с шаблоном jdbc данных Spring? Какое будет влияние? что делать в такой ситуации, когда мы не можем использовать R2DBC?

Я новичок в Spring web flux и не уверен, как интегрировать его с существующим шаблоном spring jdbc, который использует блокирующий драйвер постоянства для оракула. т.е. в моей ситуации R2DBC (oracle) не поддерживается / недоступен. Мне нужно использ…
08 фев '20 в 11:18
0 ответов

Reactor UnicastProcessor drop on backpressure when queue is full

I'm trying to use a UnicastProcessor to allow a certain number of events to be queued (to handle bursts of load and to be able to check the size of the queue). The problem is that the backpressure doesn't seem to be working as expected. According to…
12 фев '20 в 19:44
1 ответ

Spring Reactor - потребляющая конечная точка Pageable

Я впервые работаю с Spring Reactor и столкнулся со следующей проблемой: У меня есть служба, которая позволяет использовать ряд записей, определенных номером страницы и размером страницы: Mono<GetContactsForGroupResponse> getContactsForGroup(In…
12 фев '20 в 18:56
0 ответов

Столкновение с проблемой при доступе к объекту Map из Mono <Map <String,String>

Я новичок в программировании реакции Spring, я создал образец конечной точки отдыха, которая публикует сообщения для клиента, у меня есть Mono>, который я пытаюсь получить доступ к объекту карты, чтобы проверить, что значения присутствуют на карте д…
21 мар '20 в 19:31
0 ответов

Задержка подключения WebTestClient

Есть ли способ определить тайм-аут / задержку перед отправкой запроса с помощью WebTestClient в тестах spring-webflux? webClient.get().uri("/timeout/1000").exchange() // define delay around here .expectStatus().isOk();
24 мар '20 в 13:18
2 ответа

Как установить мост между нереактивным Spring EventListener и реактивным Flux

В чем разница между созданием потока напрямую путем вызова Flux.push и используйте раковину внутри pushвыражение ламбады по сравнению с использованием приемника, предоставляемого DirectProcessor? В минимальном примере, когда Flux просто генерирует п…
01 апр '20 в 09:47
0 ответов

Пружинное реактивное программирование противодавления

Я новичок в реактивном программировании. Может кто-нибудь объяснить, что происходит, когда вызывается mono.subscribe или какой-либо обработчик конвейера обработки данных? Я прочитал из документации, что концепция противодавления - это то, сколько да…
10 апр '20 в 18:38
1 ответ

Кеширование в Spring webflux

Удивился, что в Интернете было так сложно найти конкретную информацию об этом. Можно ли кешировать результаты в Spring WebFlux? Например: Могу ли я получить свою службу отдыха, а затем использовать mongodb в качестве основной базы данных и redis в к…
25 апр '20 в 23:44
2 ответа

вернуть Mono / Flux с 2 вложенными подписками

Мне нужно вернуть Mono / Flux для функции, но у нее есть 2 вложенные подписки. Я ищу лучшее решение для публикации Mono / Flux только после того, как будут доступны эти 2 значения подписки, а затем выполнить некоторую операцию для получения finalVal…
09 май '20 в 14:51
1 ответ

Приведет ли возврат Mono <ServerResponse> к (злой) синхронной, блокирующей связи клиент / сервер?

Я новичок в Spring Reactor и WebFlux и немного смущен потоком событий в функциональной сети Spring. Пример: у меня есть функция-обработчик, возвращающаяMono<ServerResponse>. Внутри негоfindAll() метод репозитория выполняется, возвращая Flux&lt…
10 май '20 в 16:48
1 ответ

CircuitBreaker не меняет состояние с HALF_OPEN на CLOSED

У меня есть эта конфигурация автоматического выключателя в моем реактивном приложении с пружинной загрузкой - CircuitBreakerConfig.custom().failureRateThreshold(5) .slowCallDurationThreshold(Duration.ofMillis(5000)) .slidingWindowType(SlidingWindowT…
14 май '20 в 17:42
0 ответов

Как не выполнить настоящий вызов, а сразу вернуть пользовательский ответ 200 в облачном шлюзе Spring?

Я знаю, что могу управлять входящим запросом и ответом, который получает вызывающий, с помощью filter / modifyRequestBody / modifyResponseBody. Что я хотел бы сделать, так это запретить spring-cloud-gateway выполнять целевой вызов прокси / шлюза и в…
30 мар '20 в 13:08
1 ответ

Условное излучение реактора Flux

Можно ли разрешить выдачу значений из потока условно на основе глобальной логической переменной? Я работаю с Flux delayUntil(...), но не могу полностью понять его функциональность или мои предположения неверны. У меня есть глобальный AtomicBoolean, …
24 май '20 в 01:16
2 ответа

Параллелизм планировщика Spring Reactor Webflux

Для полностью неблокирующих сквозных реактивных вызовов рекомендуется явно вызывать publishOn или subscribeOn для переключения планировщиков? Для задач, потребляющих или не потребляющих ЦП, выгодно ли всегда использовать параллельный поток для оптим…
25 май '20 в 19:53
0 ответов

Мост RabbitMQ слушателя к Flux

У меня есть приложение Reactive Spring Boot, получающее сообщения от RabbitMQ и сохраняющее их в репозитории (MongoDB): @RabbitListener(...) public void processMessage(Message message) { repository.persist(message).subscribe(); } Предполагая, что за…
26 май '20 в 21:56