Вопросы по теме 'spring-webflux'

Конкатенация потока не возвращается
Я экспериментирую с репозиториями Spring Boot 2.0, webflux и reactiv Mongo. У меня есть два варианта: сначала удалить, а затем добавить данные в коллекцию. В первом варианте поток блокируется до завершения удаления, во втором варианте добавление...
476 просмотров

Проверка Spring Webflux Bean
У меня есть простой контроллер отдыха (использующий Spring web-FLUX ), который получает bean-компонент для сохранения в базе данных. Но, как обычно, я хотел бы проверить некоторые поля перед сохранением. У меня есть метод проверки, который нужно...
705 просмотров

Поддерживает ли Spring Data REST реактивные репозитории crud?
У меня очень простой и стандартный OrderRepository: @RepositoryRestResource(collectionResourceRel="orders", path="orders") public interface OrderRepository extends ReactiveCrudRepository<Order, String> { } После попадания на сервер с...
2977 просмотров

Как создать класс данных, реализующий специфичные для Spring Secuirty UserDetails
Я пытаюсь перенести некоторые примеры кода spring-webflux в kotlin. В настоящее время я хочу преобразовать мой Spring Data Mongo образец для котлина. Есть User , оригинальная версия Data Mongo выглядит так: @Data @ToString @Builder...
1907 просмотров
schedule 25.11.2022

Как включить журнал доступа для Spring WebFlux?
Для Spring WebFlux, работающего на Netty, я хочу иметь журналы доступа, как в Tomcat, но ничего не нахожу в документация Spring . Кто-нибудь может помочь?
8367 просмотров
schedule 01.10.2022

Как заставить AuditorAware работать с Spring Data Mongo Reactive
Spring Security 5 предоставляет ReactiveSecurityContextHolder для извлечения SecurityContext из контекста Reactive , но когда я хочу реализовать AuditorAware и получить работу для прослушивания автоматически, но не работает. В настоящее...
2476 просмотров

Можно ли запустить Mono параллельно и агрегировать результат
Я знаю, что можно связать Моно, например ... Mono<String> resultAMono = loadA(); Mono<String> resultBMono = resultA.flatMap(resultA -> loadB()); Это будет цепочка, и resultBMono будет запущен, когда resultAMono вернется .......
12342 просмотров
schedule 04.10.2022

Нетти, поэтому загрузка исключения при запуске webflux в контейнере докеров
Приложение хорошо работает в локальной системе, но когда я запустил его в докере, у меня не получилось. Dockerfile находится здесь . Следующая ошибка в консоли при запуске этой службы в Docker. auth-service | ... 185 common...
853 просмотров
schedule 11.03.2024

webflux: кросс-домен + базовая авторизация не работает?
Я использовал Spring 2.0.1, вот мой SecurityWebFilterChain @Bean SecurityWebFilterChain springSecurityFilterChain(ServerHttpSecurity http) { return http // Demonstrate that method security works // Best practice to use...
175 просмотров
schedule 27.11.2023

Обработчик времени ожидания соединения
Я хочу использовать веб-клиент Spring 5 для соединений REST. WebClient.Builder builder = WebClient.builder().baseUrl(gatewayUrl); ClientHttpConnector httpConnector = new ReactorClientHttpConnector(opt -> opt.sslContext(sslContext));...
66 просмотров
schedule 19.04.2024

Контроллер отдыха Spring 5 Webflux — как выполнить проверку ввода?
Я создаю веб-приложение с некоторым Rest Controller как: @RestController @RequestMapping(value = Path.ROOT) public class TestController { @Autowired private AService service; @RequestMapping(method = RequestMethod.POST) public...
1919 просмотров

Команды соединения реактора
Я практикую Reactor в Spring WebFlux и считаю, что кривая обучения довольно крутая. Все, что я хотел сделать, это что-то вроде: Данные, поступающие от контроллера. Я запрашиваю настройки сайта, которые возвращают Mono. Я делаю запрос к...
1118 просмотров
schedule 15.11.2023

Как заставить отправить запрос на запуск и забыть в весеннем веб-клиенте webflux?
Рассмотрим код: private WebClient webClient; public void some(MyObject myObject) { return webClient.post() .uri("/log/my-path") .body(BodyInserters.fromObject(myObject)) .retrieve()...
5566 просмотров
schedule 04.04.2024

Может ли Undertow использовать один и тот же рабочий поток ввода-вывода для обработки двух разных запросов?
Вот моя ситуация, когда я написал демо, которое одновременно отправляет два разных запроса на мой сервер. Обычно: Undertow будет использовать два рабочих потока XNIO. [ XNIO-1 I/O-3 XNIO-1 I/O-4] для обработки этих двух запросов:...
809 просмотров
schedule 05.11.2022

Springboot. Реактивный веб-клиент. Соединение преждевременно закрыто ДО ответа
Я столкнулся с этой проблемой В объединенном соединении обнаружена ошибка response.netty.http.client.HttpClientOperations $ PrematureCloseException: соединение преждевременно закрыто ДО ответа ". Я собираю метрики с графитового сервера...
3730 просмотров

Почему я получаю «Разрешено только одно подключение для получения подписчика», когда в ответе есть код состояния ошибки HTTP?
В запросе на отдых я отправляю другой запрос в веб-службу с помощью Spring WebClient и хочу вернуть результат вызывающей стороне: return webClient.post() .uri(url) .body(...) .retrieve() .bodyToMono(String::class.java) .map {...
1691 просмотров

Как исправить ошибку декодирования JSON в Spring?
Я отправляю объект пользователя через REST, который содержит набор объектов SimpleGrantedAuthority . На стороне получателя я получаю исключение: org.springframework.core.codec.DecodingException: ошибка декодирования JSON: невозможно создать...
3840 просмотров
schedule 20.04.2024

Вызовы веб-служб с разбивкой на страницы Reactor
Я использую реактор в весеннем проекте, где мне нужно вызвать API с разбивкой на страницы. API возвращает что-то вроде этого: { "last": false, "totalPages": 2, "totalElements": 4178, "sort": { "sorted": false, "unsorted": true...
296 просмотров
schedule 05.05.2024

как использовать конечную точку webflux для создания json-потоков из React
Я хочу узнать, как использовать Restcontroller WebFlux, создающий потоки json из React. Моя первая попытка заставила меня разобрать текст вместо json, но у меня такое чувство, что я делаю что-то странное. Я решил потратить силы на чтение примеров и...
1430 просмотров

Проект "Реактор". Mono.map () против Mono.flatMap ()
В чем принципиальная разница между ними с точки зрения Mono ? Из документации я прочитал, что flatMap действует асинхронно и map синхронно. Но для меня это не имеет смысла, потому что Mono - это все о параллелизме, и этот момент непонятен....
16584 просмотров
schedule 01.06.2024