Описание тега webflux
0
ответов
Салат-латук намного быстрее, чем Redisson?
При тестировании этих двух клиентов Java Redis в простом приложении Spring Boot я обнаружил, что Lettuce по сравнению с Redisson обрабатывает на 20-30% больше запросов в секунду. Я покопался и не нашел никаких ресурсов, подтверждающих такую резкую…
16 мар '21 в 10:34
4
ответа
Таблица взаимно-однозначных соотношений задач Webflux R2dbc
Привет всем, я пишу проект Rest api с R2dbc (неблокирующий), но проблема связана с таблицей Модель задачи @Getter @Setter @Entity(name = "task") @Table(name = "task") public class Task { @Id @Column(name = "id",unique = true,nullable = false) privat…
20 мар '21 в 18:58
0
ответов
Многопоточное решение проблемы - RxJava vs ExecutorService
Я пытаюсь создать приложение, требующее некоторого параллелизма, поскольку важна пропускная способность. Шаги можно резюмировать следующим образом: У меня несколько классов AccountCollector. Каждый из них извлекает UserAccounts из двух разных конечн…
19 мар '21 в 02:53
2
ответа
Установить контекст сопрограммы из Spring webflux WebFilter
Как установить контекст сопрограммы из Spring WebFlux WebFilter? Является ли это возможным? Я знаю, что могу использовать контекст реактора, но не могу установить контекст сопрограммы.
04 май '21 в 23:03
1
ответ
блокировка вызова фиктивного клиента из службы реактивной пружины
Я пытаюсь вызвать сгенерированного имитационного клиента из реактивного пружинного потока следующим образом: .doOnNext(user1 -> { ResponseEntity<Void> response = recorderClient.createUserProfile(new UserProfileDto().principal(user1.getLogin…
04 май '21 в 13:15
0
ответов
Решение для интервала sse весной webflux
Я создаю с помощью Spring webflux, и сервер отправляет события одной конечной точки, которая должна уведомлять мой интерфейс при изменении MongoDB. Но для этого мне пришлось использовать Flux.interval и читать мой MongoDb каждую секунду. Есть ли луч…
06 май '21 в 00:00
1
ответ
r2dbc проверяет, существует ли идентификатор, а затем вставляет строку
У меня есть следующий запрос sql с r2dbc: client.sql("INSERT INTO relation(id,rel_id) " + "VALUES(:id,:rel_id)") .filter((statement, executeFunction) -> statement.returnGeneratedValues("id").execute()) .bind("id", id) .bind("rel_id", rel_id) .fet…
07 май '21 в 14:08
1
ответ
Как проверить reposebody Webclient?
Я разработал внешний API с помощью WebClient, но я не знаю, как проверить тело ответа. public class Call { public Mono<Object> get() { Mono<Object> http = webClient.get() .uri(EXTERNAL_URL) .retrieve() .bodyToMono(Object.class); return h…
12 май '21 в 04:39
1
ответ
Как использовать метод «кеширования» в Mono
Я новичок в Spring webflux. Во время исследования я нашел такой код, как: Mono result = someMethodThatReturnMono().cache(); Название «кеш» говорит мне о кешировании чего-либо, но где находится кеш и как получить кешированные вещи? Это что-то вроде к…
11 май '21 в 15:47
0
ответов
Как заменить EmitterProcessor на Sinks для повторного подключения ReactorNettyWebSocketClient?
Я новый с springFlux, нашел пример ReactorNettyWebSocketClient примера здесь с RECONNECT механизма на провал. Все работает, как ожидалось, но в примере используется устаревший EmitterProcessor, который следует как-то заменить на Sinks. Любая помощь …
13 май '21 в 00:27
1
ответ
Компонент ServerHttpSecurity не найден
У меня есть класс конфигурации безопасности, в котором есть bean-компонент SecurityWebFilterChain. Для этого bean-компонента требуется экземпляр ServerHttpSecuirty, но spring сообщает, что он не может найти никаких bean-компонентов этого типа, хотя …
14 май '21 в 20:32
0
ответов
У меня вопрос по поводу поведения WebFlux
Я не понимаю части контента, который считается преимуществом при разработке внутреннего сервера с помощью WebFlux. (** Если 10 пользователей делают запрос одновременно, он написан в предположении, что требуется 10 секунд для получения данных из RDB …
15 май '21 в 09:14
0
ответов
Почему мой Spring MVC (Tomcat NIO, RestHighLevelClient) превосходит Webflux (Netty, ReactiveElasticsearchClient) при нагрузочном тесте?
Я новичок в реактивном программировании и webflux, и я оцениваю миграцию из приложения Spring Data Elasticsearch в стек сервлетов с WebMVC в реактивный стек с Spring Webflux. Я разработал два идентичных простых приложения для весенней загрузки, кото…
16 май '21 в 21:37
0
ответов
В чем преимущество использования MockWebServer?
Я сумасшедший вызов API от WebClient. (WebFlux) поэтому я хочу сделать хороший тест JUnit. Я слышал, что MockWebServer хорош для сквозного тестирования вызовов API. Но есть некоторые моменты, которых я не понимаю. MockWebServer просто показывает пре…
17 май '21 в 04:36
0
ответов
как использовать тип части webflux?
Я собираюсь загрузить данные частичного типа на S3 после получения их от webflux. return request .multipartData() // .publishOn(Schedulers.newSingle("worker-")) // .single() .flatMap(parts -> { System.out.println(parts); parts.get("image"); Part …
17 май '21 в 07:56
0
ответов
Используйте @ControllerAdvice в проекте Spring WebFlux Rest API
Я хотел бы знать, безопасно ли использовать @ControllerAdvice в проекте WebFlux или реализовать собственный класс, расширяющий DefaultErrorAttributes. Или реализовать оба варианта? Нравиться: Пользовательский класс с аннотацией @ControllerAdvice для…
18 май '21 в 03:46
0
ответов
Spring webflux oauth2 resourceserver autoconfig authenticationconverter
Кто-нибудь знает, зачем мне кодовая строка внизу, чтобы она работала? Я думал, что это должно быть применено через Configuration Bean автоматически? .jwtAuthenticationConverter(reactiveJwtAuthenticationConverter()) //<- ПОЧЕМУ МНЕ НУЖНА ЭТА СТРОК…
20 май '21 в 15:24
1
ответ
Spring Cloud GlobalFilter: повторно отправить измененный запрос в случае сбоя
Мы используем Spring Cloud Gateway с GlobalFilter для обработки инъекции токена в запрос. Вот код фильтра: @Override public Mono<Void> filter(final ServerWebExchange exchange, final GatewayFilterChain chain) { log.info("We received a request")…
21 май '21 в 21:30
0
ответов
Как инициализировать данные по умолчанию из базы данных в Spring Webflux SSE Endpoint?
Привет, я только изучаю Spring Webflux и пробую функцию под названием SSE Server Sent Event, мне уже удалось отправить значение объекта в мою конечную точку потоковой передачи, но я не могу инициализировать данные по умолчанию из моей базы данных Mo…
26 май '21 в 19:14
2
ответа
Как использовать Spring WebClient для последовательного выполнения нескольких вызовов?
Я прочитал тему Как использовать Spring WebClient для одновременного выполнения нескольких вызовов?, но мой случай немного другой. Я вызываю 2 разные внешние службы с помощью веб-клиента, скажем, из метода Mono <Void> A(), за которым следует M…
01 июн '21 в 16:37