Вопросы по теме 'spring-webflux'
Пример реального контроллера с Spring 5: Web Reactive
Я хочу участвовать в мире реактивного программирования с помощью Spring. Как я понял, это дает мне выбор между двумя разными парадигмами : основанной на аннотациях (с известными нам @Controller , @RequestMapping ) и реактивной ( который...
7194 просмотров
schedule
01.12.2022
Объединение результата от Flux с результатом от Mono
Я начал использовать Project Reaction, и в одном месте, где я немного борюсь, является то, как мне комбинировать вещи, исходящие от Mono, с Flux. Вот мой вариант использования:
public interface GroupRepository {
Mono<GroupModel>...
7941 просмотров
schedule
04.06.2022
как правильно обрабатывать ошибки в spring-webflux
Я провел некоторое исследование с использованием spring-webflux, и мне нравится понимать, каким должен быть правильный способ обработки ошибок с помощью функций маршрутизатора.
Я создал небольшой проект для тестирования нескольких сценариев, и мне...
32246 просмотров
schedule
18.05.2022
Как использовать Reactive Spring Rest API с WebClient
Мне нужно использовать API реактивного отдыха (построенный с помощью spring webflux) на задании бэкэнд (исполняемый jar).
Я читал о Spring WebClient, но не понимаю некоторых моментов.
Например:
WebClient webClient =...
7753 просмотров
schedule
17.05.2023
Как я могу вернуть Flux‹Order›, когда мой ответ заключен в объект разбиения на страницы json с помощью Spring 5?
У меня есть веб-служба, которую я пытаюсь использовать с новым веб-клиентом Spring 5.
Рабочий пример
# GET /orders/
[
{ orderId: 1, ... },
{ orderId: 1, ... }
]
И java-код для вызова
// Java
Flux<Order> ordersStream =...
1969 просмотров
schedule
22.04.2023
Spring Web-Flux: как вернуть Flux веб-клиенту по запросу?
Мы работаем с Spring boot 2.0.0.BUILD_SNAPSHOT и spring boot webflux 5.0.0, и в настоящее время мы не можем передавать поток клиенту по запросу.
В настоящее время я создаю поток из итератора:
public Flux<ItemIgnite> getAllFlux() {...
4371 просмотров
schedule
27.02.2023
Использование Spring HATEOAS с Spring Webflux Functional Web Framework (reactor-netty)
Можем ли мы использовать пружину HATEOAS поверх RouterFunction ? Я предполагаю, что мы можем указать ресурс, но что будет эквивалентно linkto(Controller.class) ? или есть ли эквивалент, чтобы указать ссылку и использовать состав RouterFunction
1870 просмотров
schedule
17.09.2023
Возникновение NPE при использовании `WebTestClient.mutateWith()` в сквозных тестах
Когда я написал несколько тестов для webflux приложений. И я попытался добавить учетные данные через mutateWith(mockUser().password("password")) в WebTestClient , но это вызвало выброс NPE.
Я использовал bindToServer для подключения...
605 просмотров
schedule
08.11.2023
Spring 5 Reactive WebSockets: рекомендуемое использование
Я немного узнал о Spring 5 WebFlux, реактивном программировании и веб-сокетах. Я смотрел Spring Tips: Reactive WebSockets with Spring Framework 5 Джоша Лонга. Код, который отправляет данные с сервера на клиент через соединение WebSocket,...
1862 просмотров
schedule
12.09.2023
Как получить Person вместо Mono ‹Person›?
В приведенном ниже коде извлечения, пожалуйста, как получить Person вместо Mono или как получить Person из Mono?
23.2.3 Преобразование тела запроса и ответа
Тело ответа может быть одним из следующих:
Аккаунт - сериализовать без блокировки...
752 просмотров
schedule
20.04.2022
Spring WebFlux 5.0.RELEASE и Spring Security 5.0.M5
Я пытаюсь создать веб-сервис с помощью WebFlux. Когда я пытался настроить Spring Security с помощью Spring WebFlux, Spring Security не перехватывала запросы. Моя конфигурация безопасности Spring:
@EnableWebFlux
@EnableWebFluxSecurity...
368 просмотров
schedule
22.05.2024
Реактивный дизайн конечных точек
Я изучаю WebFlux. Wiki говорит, что реактивное программирование это:
Например, в параметрах императивного программирования a:=b+c будет означать, что a присваивается результат b+c в в момент вычисления выражения и позже значения b...
139 просмотров
schedule
20.01.2024
Spring Boot 5 WebClient Сначала проверьте HTTPStatus перед проверкой заголовка ответа HTTP
Я пытаюсь подтвердить значение заголовка ответа HTTP с помощью Spring 5 WebClient, но только если веб-вызов отвечает кодом состояния HTTP 200. В этом случае использования, если аутентификация не удалась, вызов API возвращается с HTTP 401 без...
4696 просмотров
schedule
06.06.2023
Могу ли я получить доступ к телу запроса/ответа в ExchangeFilterFunction?
Учитывая обмен с использованием WebClient , отфильтрованный по пользовательскому ExchangeFilterFunction :
@Override
public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next) {
return next.exchange(request)...
1427 просмотров
schedule
15.11.2022
Как проверить JSON @RequestBody с помощью org.springframework.validation.Validator в Spring WebFlux?
Я пытаюсь проверить JSON @RequestBody с помощью org.springframework.validation.Validator в Spring WebFlux, но получаю «Внутренняя ошибка сервера» со следующим сообщением.
java.lang.IllegalStateException: Failed to resolve argument 1 of type...
1210 просмотров
schedule
28.08.2023
Переменная пути Spring WebFlux WebSocket
Как я могу получить переменную пути в обработчике веб-сокетов с помощью Spring WebFlux? Я пробовал это:
@Bean
public HandlerMapping webSocketMapping() {
Map<String, WebSocketHandler> map = new HashMap<>();...
1092 просмотров
schedule
29.10.2022
Java Reactor: как создать поток из стандартного ввода?
Я хотел бы асинхронно читать сообщения, созданные пользователем из stdin. Что-то вроде:
Flux.from(stdinPublisher())
.subscribe(msg -> System.out.println("Received: " + msg));
Так как же здесь реализовать такой stdin publisher?
537 просмотров
schedule
06.07.2022
Почему клиент webflux выдает 404?
Я пытаюсь сделать клиент webflux для подключения к удаленному веб-сокету. Пример веб-сокета находится по адресу https://www.websocket.org/echo.html . . Я могу заставить свой браузер сделать запрос wss, просто нажав «подключиться». На панели...
2023 просмотров
schedule
10.08.2023
Как создать Flux из Mono
У меня есть Mono A. Объект A содержит два списка. Я хочу создать сразу два Flux. Возможно ли это без block()?
Mono<A> a = ... ;
Flux<AList1> a1 = Flux.fromIterable(a.block().getList1());
12897 просмотров
schedule
14.05.2023
Реактивные потоки: Spring WebFlux - подпишитесь на существующего издателя
В настоящее время я переношу нашу существующую асинхронную REST-архитектуру Spring на новую библиотеку WebFlux Spring, и у меня есть вопрос по объединению нескольких запросов, чтобы они могли прослушивать один и тот же опубликованный ответ.
Пример...
2361 просмотров
schedule
08.04.2022
