Пружинный реактор join 2 Mono
Мне нужно подключиться к базе данных реактивным способом, используя пружинный реактор. Вот сценарий, который я бы хотел получить->
1. Подключитесь к БД и получите ответ1
2. Затем подключитесь к базе данных и получите response2, указав параметр response1.
- Объедините эти два в один ответ и отправьте обратно пользователю как String
Поскольку все объекты уникальны, я планировал использовать Mono
Mono<Response1> r1 = qrepo.findByID(id)
Mono<Response2> r2 = qrepo.findByID(r1.getParam())
Mono<String> combined = Mono.when(r1, r2).map(t -> {
StringBuffer sb = new StringBuffer();
sb.append(r1.getProp1());
sb.append(r2.getProp2());
Но меня это не беспокоит
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
0
0
1 420
2
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 2
Ответ принят как подходящий
Вы должны получить response1, затем отобразить его результат для доступа к параметру и передать его в репозиторий, а затем отобразить результат в строку
Mono<String> resultMono = qrepo.findByID(id)
.flatMap(response1 -> qrepo.findByID(response1.getParam())
.map(response2 -> {
StringBuilder sb = new StringBuilder();
sb.append(response1.getProp1());
sb.append(response2.getProp2());
return sb.toString();
}));
Используйте Mono.zip
Пример:
Mono.zip(Mono.just("hello"), Mono.just("world")).map(tuple2 -> {
return tuple2.getT1() + tuple2.getT2();
});
Mono.zip объединяет данные monos в новый Mono, который будет выполнен, когда все данные Monos создадут элемент.
Другие вопросы по теме
Предпочтительно ли использовать плоскую карту несколько раз в одном конвейере Mono <Object>
Приложение в реальном времени, Reactor Netty vs Netty
Динамическое слияние потоков
Кэшировать результат Mono из вызова WebClient в веб-приложении Spring WebFlux
Java Reactor - условное выполнение потока
Реактивное программирование
Асинхронный поток PublishOn Reactor и блокировка потоков
Использование Flux.cache для повторного использования подписки на канал Redis в webflux
Reactor, как отладить исключение OverflowException?
Метка времени не обновляется при вызове реактора Mono.defer
Похожие вопросы
Spring boot: создайте uri "/ {id}" с помощью ServletUriComponentsBuilder
Как прочитать файл из хост-сети в контейнере Windows Docker
Могу ли я отправить объект json в restApi без использования файлов cookie в angular 2+
Весенняя аутентификация LDAP с использованием атрибута uniqueMember
Модульный тест службы загрузки Spring с частными полями и @PostConstruct
Spring Integration Mail Google IMAP как установить частоту проверки почтового ящика
Как отключить метрики в Spring-Boot?
Использование JPA для запроса статуса репликации postgres
Spring Boot + Jackson: сериализовать объект по-разному в зависимости от вызываемого REST API
Пул нескольких соединений Spring JPA Hikari с одним и тем же источником данных