Я новичок в Spring WebFlux, но я пытаюсь добиться этого, как указано ниже.
First Service -> AuthService Mono<String> ->gives auth token
Second Service -> ServiceSecodn Uses output from above service
Third service -> Uses output from both above specified services.
Невозможно выразить это с помощью API плоской карты webFlux.
service1.dologin().flatmap(info->service2.apiCall(info))
Я хочу сделать третий сервисный звонок service3.apiCall(loginInfo,infoFromSecondServiceCall)
Tuple2, чтобы объединить несколько выходных данных.Вы можете хранить всю информацию полностью, удерживая ее в одной структуре, как в следующем примере:
service1.dologin()
.flatMap(lInfo ->
service2.apiCall(lInfo)
.map(result -> Tuples.of(lInfo, result))
)
.flatMap(lInfoAndResultTuple ->
service3.apiCall(
lInfoAndResultTuple.getT1(),
lInfoAndResultTuple.getT2()
)
)
В этом примере мы используем дополнительную структуру, чтобы полностью сохранить необходимые данные. Основное преимущество этого примера – ровный поток. Основным недостатком этого метода является дополнительная структура, которая затрудняет работу с данными внутри нее.
В свою очередь, чтобы избежать избыточной структуры данных, мы можем использовать метод замыкания и всегда иметь доступ к родительским данным замыкания, как показано в следующем примере:
service1.dologin()
.flatMap(lInfo ->
service2.apiCall(lInfo)
.flatMap(result ->
service3.apiCall(lInfo, result)
)
)
По сравнению с предыдущим примером здесь нам не нужно использовать дополнительную структуру данных для доступа к восходящим данным. Язык Java предоставляет нам встроенный доступ к данным родительских замыканий, чтобы мы могли использовать их в любое время в дочерних замыканиях. Основное преимущество этого метода — отсутствие избыточной структуры данных. Основным недостатком является сложная структура Flux/Closures, которая выглядит как хорошо известный обратный вызов Ад
