-2
голосов
0ответы
10 просмотров

Не удалось получить соединение R2DBC; вложенное исключение - io.r2dbc.spi.R2dbcNonTransientResourceException: ошибка проверки соединения

В чем может быть причина, по которой я столкнулся с вышеуказанной проблемой. Мы используем spring webflux с r2dbc Не удалось получить соединение R2DBC; вложенное исключение - io.r2dbc.spi.R2dbcNonTransientResourceException: ...
1
голосование
1отвечать
29 просмотров

Как записать ошибку в БД и возобновить выполнение в реакторе проекта?

Я хочу записать ошибку в коллекцию mongo db и продолжить распространение ошибки в конвейере. Как я могу сделать это в проектном реакторе? Текущий код использует экстрактор (Mono.block ()), ...
0
голосов
0ответы
18 просмотров

Как изменить HTTP-статус ответа Spring WebClient

У меня возникла ситуация, когда необходимо вернуть HTTP 2XX, когда WebClient возвращает какой-либо тип 4XX. Мой существующий код ниже, public Mono <ResponseEntity <> String> postMethodA (String valueA) {...
1
голосование
0ответы
16 просмотров

Как загрузить файл и сразу передать его в потоковом режиме - загрузка - с помощью Spring Reactive WebClient

Я ищу способ загрузить файл с URL-адреса и немедленно передать его (загрузить) на другой URL-адрес (местоположение). Я не хочу сбрасывать его на диск или загружать весь файл в память. Я новичок в ...
0
голосов
0ответы
28 просмотров

Генерация UUID в WebFlux

Допустим, у меня есть такой метод в классе, реализующий BeforeConvertCall <Object> @Override public Publisher <Object> onBeforeConvert (Object o, SqlIdentifier sqlIdentifier) ​​{...
0
голосов
1отвечать
29 просмотров

Spring Boot MongoDB Aggregation $ не работает

Я использую MongoDB в реактивном приложении Spring Boot (используя Webflux), и я хочу выполнить агрегирование в одной из наших коллекций, но оно просто возвращает пустой список. В приведенном ниже коде показан ...
0
голосов
0ответы
16 просмотров

Как транслировать видео с помощью Spring boot (webflux) и angular

Привет, я создаю приложение для потоковой передачи видео, используя Spring boot и angular. Я думаю, что вызов API на угловой стороне не дает желаемого типа ответа. Взгляните на мою частную статику контроллера ...
0
голосов
0ответы
8 просмотров

Режим потока Webflux для веб-приложения с привязкой к вводу-выводу

Я создал приложение на основе webflux, которое, по сути, должно сериализовать некоторый объект, прочитанный из источника данных newo4j, реактивным способом в потоковом режиме (новая строка JSON для каждого объекта). Мы говорим о ...
-1
голосов
0ответы
23 просмотра

Spring Boot - авторизация на основе ролей

У меня есть внешнее приложение, которое извлекает роли пользователей на основе зарегистрированного пользователя, и внутреннее приложение, которое разрешает доступ на основе этих ролей. Мой бэкэнд - это Spring Boot (spring-boot-starter -...
0
голосов
1отвечать
33 просмотра

Mono возвращает пустой список

Я пытаюсь вызвать getProductContract (), но он возвращает пустой список. Я думаю, это потому, что Mono не исполняется. Может ли кто-нибудь помочь мне, как выполнять звонки, чтобы я получил ...
1
голосование
1отвечать
41 просмотр

Как создать несколько экземпляров KafkaReceiver в Spring Reactor Kafka

У меня есть реактивное приложение kafka, которое считывает данные из темы и записывает в другую тему. Тема имеет несколько разделов, и я хочу создать такое же количество потребителей (в одном и том же потребителе ...
1
голосование
0ответы
19 просмотров

Восстановление из OOM при выделении DirectByteBuffer на веб-сервере WebFlux

Я не уверен, имеет ли это смысл, поэтому прокомментируйте, если мне нужно предоставить дополнительную информацию: мой веб-сервер используется для загрузки файлов (принимает файлы как Multipart / form-data и загружает их в другую службу). ...
1
голосование
0ответы
21 просмотр

Статический контент не загружается в весеннем облачном шлюзе

Недавно я обновил свою весеннюю версию с 2.5.5 до 2.5.6, в результате чего моя зависимость spring-webflux была обновлена ​​с 5.3.10 до 5.3.12. После этого статический контент не загружается. Я предполагаю, что в ...
0
голосов
1отвечать
Просмотров: 43

Реактивное программирование - Webflux Webfilter работает некорректно

Я немного новичок в реактивном программировании, и я пытаюсь собрать следующее: используя Java, Springboot 2, Webflux и ядро ​​реактора, я хочу обрабатывать очень конкретные запросы, требующие дополнительных ...
1
голосование
1отвечать
31 просмотр

Как перенести микросервис, использующий RESTFul, на Spring Webflux Reactive

Допустим, у меня есть микросервис с весенней загрузкой, с вводом PersonsRestController, например: @GetMapping (value = "/ world / {countryId} / people", производит = APPLICATION_JSON_UTF8_VALUE) public ...