Описание тега spring-mono
1
ответ
Spring Reactor - потребляющая конечная точка Pageable
Я впервые работаю с Spring Reactor и столкнулся со следующей проблемой: У меня есть служба, которая позволяет использовать ряд записей, определенных номером страницы и размером страницы: Mono<GetContactsForGroupResponse> getContactsForGroup(In…
12 фев '20 в 18:56
1
ответ
Как сгенерировать случайную строку и вытолкнуть ее с помощью Mono для отображения в браузере каждые X секунд или со случайной задержкой через Spring Reactive?
Я бы хотел, чтобы браузер отображал случайно сгенерированную строку в браузере, как только API генерирует это, используя Spring Reactive Mono. Ниже приведен пример моей программы, которая работает, генерирует случайную строку и каждую секунду отобра…
24 сен '19 в 22:12
1
ответ
Класс Mono в Java: что такое и когда использовать?
У меня есть следующий код: import org.springframework.http.MediaType; import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.BodyInserters; import org.springframework.web.reactive.function.server.ServerRequ…
16 мар '20 в 14:45
1
ответ
Как решить проблему, вызывая Mono <Token>, тогда результат будет использован для другого Mono <Collection>, который затем вернет Mono <collection>?
Привет, я только начал изучать реактивное программирование У меня есть этот фрагмент кода, и мой процесс здесь должен заключаться в том, что я вызову tokenRepository, чтобы получить токен, а затем использую token.getAccessToken(), который будет испо…
25 апр '20 в 07:32
2
ответа
Разница между Mono.then и Mono.flatMap / map
Скажем, я хочу вызвать webservice1, а затем вызвать webservice2, если первый был успешным. Я могу сделать следующее (только ориентировочный псевдокод):- Mono.just(reqObj) .flatMap(r -> callServiceA()) .then(() -> callServiceB()) или Mono.just(…
12 июл '20 в 22:53
1
ответ
Java Spring WebClient, как получить атрибут из ответа тела и установить для данного класса?
Я пытаюсь использовать данный API, который возвращает такой ответ тела: "access_token": "xkeo94s4qviHSTDIuTCbgRQSeNfrrMamiCN0w6wu", "token_type": "Bearer", "expires_in": 9600, "refresh_token&quo…
24 июл '20 в 09:21
1
ответ
Spring 5 Reactive Mono - передать значение Mono в свойство объекта и вызвать другое моно
Я новичок во всем Spring реактивном webflux. Моя проблема довольно проста. В моем addActions() я пытаюсь получить Mono, вызывая getCurrentVal(). Это прекрасно работает. Но мне нужно получить его значение и обновить свойство (submission.stateVal). За…
16 авг '20 в 00:35
0
ответов
Как создать объект SimpleMongoClientDbFactory с разными строками подключения
Когда использовать: org.springframework.data.mongodb.core.SimpleMongoClientDbFactory ------------------------------------------------------------------- org.springframework.data.mongodb.MongoDbFactory uri: "mongodb://server1:27017/ABC" uri: "mongodb…
17 окт '19 в 13:57
1
ответ
Spring Webflux Mono <Void> всегда отвечает успешным ответом
У меня есть конечная точка, которая принимает параметр id и отправляет api для удаления продукта для удаления. productService.delete также возвращает Mono. Проблема в том, что когда метод productService.delete возвращает моно-ошибку, конечная точка …
18 июн '20 в 12:22
1
ответ
Выбросить new RuntimeException() из Mono в AOP
У меня есть реактивное приложение springboot, в нем аспект @Before("approveRejectPointcut()") public void logAfterReturning(JoinPoint joinPoint) { Status newStatus = AspectUtils.returnFirstParameterOfTypeOrFail(allParameters, Status.class,…
09 сен '20 в 23:50
1
ответ
Обновление объекта Mono другим объектом Mono
Уважаемые, я застрял в реализации функции (это в основном операция обновления), которая может принимать Mono в качестве параметра и возвращать обновленную версию Mono, где: возвращенный экземпляр является производным от запроса базы данных; обновлен…
01 окт '20 в 12:03
1
ответ
Как остановить основной поток для завершения всех вызовов Mono?
Я делаю несколько моно-вызовов к БД. И результат всех моно-ответов необходим для вычисления окончательного результата, который записывается после объявленной логики моно. if (SomeObject.getAccountLevelActiveList() != null) { SomeObject.getAccountLev…
25 сен '20 в 19:39
0
ответов
Реактивный веб-поток Mono для возврата кода ответа 302 с заголовком местоположения
У меня есть сценарий, чтобы вернуть Mono с помощью 302 код и Location заголовок в ответе, если контент redirect:url в противном случае мне нужно вернуть File с участием Content-Type, Content-Size а также Content-Disposition: attachment; filename="&l…
06 июл '21 в 16:56
1
ответ
Spring WebFlux Junit Асинхронный / Параллельный
У меня есть класс со следующими двумя методами. public class Test1 { public Mono<String> blah1() { Mono<String> blah = Mono.just("blah1"); try { Thread.sleep(5000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.…
15 ноя '21 в 01:53
0
ответов
Извлечение значений ответа WebClient GET в фильтре Spring Cloud Gateway
Моя конечная цель — реализовать способ выполнения составных вызовов API в теле фильтра маршрута шлюза. У меня есть очень простое демонстрационное приложение, работающее на порту 9000и раскрывая несколько конечных точек. Вот контроллер REST: @RestCon…
13 май '22 в 12:06
0
ответов
Аннотация @DBRef хранит только ссылку на _id другой таблицы
У меня есть таблица пользователей и таблица ролей, и в таблице пользователей я ссылаюсь на таблицу ролей, чтобы сохранить полный документ роли в виде массива. Но при создании пользователя с ролью и запросе его в Mongo я вижу только это: roles" : [ D…
09 фев '23 в 12:24
0
ответов
Определение конкретных результатов Mono при слиянии через Mono.zip
У меня есть задача - получить результаты из нескольких запросов параллельно с помощью WebClient. Количество запросов может варьироваться. После получения результатов мне нужно изменить их в зависимости от источника. Подскажите пожалуйста, с помощью …
26 июн '22 в 03:15
1
ответ
Spring Cloud: поставщик постоянно публикует события Kafka вместо одного?
Spring Cloud: поставщик постоянно публикует события Kafka, как публиковать только одно? public static HashMap<String, Ticker> transactionsOfAccount = new HashMap<>(0); public LinkedList<Ticker> lists = new LinkedList<>(); Про…
12 дек '22 в 00:08
0
ответов
Обработка исключений асинхронных вызовов веб-клиента для вызовов, отличных от REST
Я вызываю веб-клиент Spring следующим образом и получаю ответ Mono (асинхронный). Обратите внимание, что вызов не заблокирован. Я вызываю это в запланированном задании, поэтому этот асинхронный вызов не инициируется вызовом REST. Проблема в том, что…
01 июл '22 в 07:39
0
ответов
Весенняя загрузка Mongo DB — запрос Bson
Я использую spring-boot-starter-data-mongodb и создаю запрос BSON для выполнения операции updateMany. Запрос довольно простой. Я хочу найти все документы, чьи_idсодержится в списке строк listOfStrings = List.of("123", "456"); Запрос Bson = and(in("_…
13 фев '23 в 12:23