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

Описание тега Вопросы с тегом
Spring Framework 5 включает новый модуль spring-webflux. Модуль содержит поддержку реактивных клиентов HTTP и WebSocket, а также реактивных серверных веб-приложений, включая REST, HTML-браузер и взаимодействия в стиле WebSocket.WebFlux может работать в контейнерах сервлетов с поддержкой API-интерфейса ввода-вывода Servlet 3.1, а также на другие асинхронные среды выполнения, такие как Netty и Undertow.
1 ответ

Как ограничить количество открытых сокетов в Spring-webflux WebClient?

У меня есть RESTful-сервис, и у меня была идея подготовить простой тест производительности с Reactor и Spring WebClient. Бенчмарк просто создает N пользователей, а затем за каждый созданный пользовательский пост M голосует. К сожалению, следующий ко…
02 сен '18 в 00:07
3 ответа

Spring Security WebFlux - тело с аутентификацией

Я хочу реализовать простое приложение Spring Security WebFlux.Я хочу использовать JSON сообщение как { 'username': 'admin', 'password': 'adminPassword' } в теле (запрос POST к /signin), чтобы войти в мое приложение. Что я сделал? Я создал эту конфиг…
25 апр '18 в 06:46
0 ответов

Spring Web Flux Websocket push после того, как данные получили существующий ресурс

package org.springframework.webflux.websocket.webfluxwebsocketdemo; import java.net.URISyntaxException; import java.time.Duration; import java.util.Date; import java.util.HashMap; import java.util.Map; import org.springframework.boot.SpringApplicati…
28 сен '18 в 06:19
1 ответ

Получение исключения после смены Webflux на Jetty вместо Netty

Я хочу запустить приложение Spring Boot Webflux на Jetty вместо NettyЯ нашел по этой ссылке, что я могу просто сделать: <dependency> <groupId>org.springframework.security</groupId> <artifactId>spring-security-webflux</arti…
11 май '18 в 18:42
2 ответа

Как преобразовать Reactor Flux<String> в InputStream

Учитывая, что у меня есть Flux&lt;String&gt; неизвестного размера, как я могу преобразовать его в InputStream что другая библиотека ожидает? Например, с помощью WebClient я могу добиться этого, используя этот подход WebClient.get('example.com').exch…
05 авг '18 в 14:17
1 ответ

403 Запрещено для каждого запроса с использованием весны-лимона

Я использую весна-лимон. Я создал простое приложение, очень похожее на лимонно-демо-реактивный (с User, UserRepository и т. Д.). Но после отправки любого запроса (регистрация нового пользователя или авторизация автоматически созданного администратор…
13 сен '18 в 18:30
3 ответа

Как вы получаете IP-адрес клиента? (Spring WebFlux WebSocket)

Как говорится в названии, как вы получаете, так сказать, подробности о соединении. Есть ли способ получить его через WebSocketSession? Я чувствую, что что-то упустил... Мне нужен способ, чтобы запретить IP-адреса плохих пользователей, а также я хоте…
05 июл '18 в 13:29
1 ответ

Ограничить размер HTTP-ответа на Spring WebFlux

Я пишу http crawler, используя Spring WebFlux, и его легко выполнять параллельно и иметь таймауты HTTP: val sitesToCrawl: Flux&lt;String&gt; = streamOfUrl() val concurrencyLimit = 100 sitesToCrawl.flatMap( { WebClient.create().get().uri(it).exchange…
24 авг '18 в 07:25
1 ответ

Поддержка Spring Boot Servlet 4

Какая версия Spring Boot официально поддерживает (или поддерживает) Servlet 4 spec? Где можно увидеть новые функции, которые идут вместе с ним, задокументированы? Спасибо.
03 окт '17 в 00:28
1 ответ

WebFlux: как применять разные наборы WebFilters для разных RestController

Скажем, у меня есть 2 @RestController и несколько WebFilters. Теперь я хотел бы: Применить WebFitler A, B, C к контроллеру X Применить WebFilter A, D, E, F к контроллеру Y Как я должен это сделать? Спасибо Леон
03 сен '18 в 11:17
2 ответа

Cant autowire `WebTestClient` - без автоматической настройки

Мы используем Spring Framework 5 и Spring Boot 2.0.0.M6, и мы также используем WebClient для реактивного программирования. Мы создали тестовые методы для наших конечных точек реактивного отдыха, и поэтому я нашел пример того, как это сделать. Я наше…
12 янв '18 в 12:50
1 ответ

Пустой принципал, возвращаемый ServerRequest в обработчике запросов webflux

Я настроил аутентификацию в приложении Spring WebFlux. Механизм аутентификации работает нормально. Например, следующий код используется для настройки цепочки веб-фильтров безопасности: @Bean public SecurityWebFilterChain securityWebFilterChain(Serve…
08 янв '18 в 19:03
0 ответов

Получить одну конкретную часть составной части как DTO, а остальные как часть, использующую Spring Webflux?

Я разрабатываю контроллер Spring Webflux, который ожидает несколько "частей" в одном многочастном запросе. Есть только одна обязательная часть, которая известна заранее, а остальные являются динамическими и неизвестными для сервера. Т.е. я пытаюсь с…
13 авг '18 в 14:47
1 ответ

spring-boot-starter-webflux не может использовать AcceptHeaderLocaleResolver

spring-boot-starter-webflux не может использовать org.springframework.web.servlet.i18n.AcceptHeaderLocaleResolver так как же spring-boot-starter-webflux может использовать resolLocale? Другими словами, что в реакторе похоже на resolLocale?
10 авг '18 в 06:37
1 ответ

Атрибуты ServerWebExchange пусты

У меня есть контроллер Spring Boot на основе аннотаций, построенный на WebFlux. Я реализую WebFilterвнутри WebFilter Я призвал serverWebExchange.getAttributes() и он вернул 4 атрибута, что нормально. Но после этого он перестал работать и теперь всег…
14 авг '18 в 09:34
1 ответ

Mono.flatMap не работает во время проверки ответа с помощью MockWebServer

Делая HTTP-вызов с использованием WebClient, из вывода Mono я хочу сделать некоторую логику, для которой я использую метод flatMap. Mono&lt;Response&gt; authResponseMono = webClient.post().syncBody(requestBody) .retrieve() .bodyToMono(Response.class…
19 ноя '18 в 12:15
1 ответ

IllegalArgumentException при использовании ReactiveCouchbaseRepository Ожидается найти реактивный адаптер для класса rxSingle, но не может

Я работаю над реактивным приложением, которое использует среду Springboot WebFlux и Couchbase DB. Spring предоставляет реализацию JPA для Couchbase, и мой интерфейс репозитория выглядит следующим образом. @Repository public interface ExampleReposito…
27 фев '18 в 06:49
4 ответа

Проверка бина не работает для весеннего webflux

Я реорганизовал мой код для использования Spring Webflux, но сейчас @Valid перестал работать. Это не проверка тела запроса. @PostMapping(value = "/getContactInfo",produces = "application/json",consumes = "application/json") public Flux&lt;UserContac…
21 дек '18 в 16:21
1 ответ

Reactor Flux прокси для Socket.IO-клиента Java

Я реализую конечную точку Spring WebFlux, которая должна получать данные из Socket.IO-клиента Java. Я не понимаю, как собрать входящие данные в поток Flux. Могу ли я создать новый Flux как-нибудь и подписать его на эти входящие данные? Спасибо за со…
04 ноя '17 в 11:41
0 ответов

Spring WebFlux неблокирующая операция ввода-вывода под капотом

Я нашел отличную статью ( https://www.kotlindevelopment.com/kotlin-webflux/), в которой объясняется, как в основном работает неблокирующий сервер ввода-вывода. Мне интересно: когда мы выполняем неблокирующий запрос, используя Spring WebClient или ре…
21 фев '19 в 12:43