Spring-Integration: как проверить ответ http в AbstractRequestHandlerAdvice с помощью webflux?

Этот вопрос напрямую связан с другим вопросом: Spring-Integration AbstractRequestHandlerAdvice с webflux/reactive: вводит ли это синхронный процесс?

Возврат result, полученный вызовом от обработчика совета к http:outbound-gateway, является либо Message<?>, либо MessageBuilder (или, возможно, только последним).

public class MyLogger extends AbstractRequestHandlerAdvice {

   // ...

   @Override
   protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message( 
   {

      // ... logging before the call ...

      Object result = callback.execute();

      // ... logging after the call ...

      return result;
   }

}

При переходе на webflux и, следовательно, на webflux:outbound-gateway обработчик советов теперь получает тип MonoMapFuseable в result. Можно ли прочитать информацию из MonoMapFuseable, чтобы зарегистрировать возвращаемую полезную нагрузку без окончательного использования результата? Я немного не понимаю, как это сделать.

Спасибо за любые идеи.

Стоит ли изучать PHP в 2023-2024 годах?
Стоит ли изучать PHP в 2023-2024 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
0
0
54
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Я не эксперт по реакторам, но вы должны быть в состоянии вызвать share() на возвращенном моно; затем подпишитесь на этот моно, чтобы получить копию результата.

/**
 * Prepare a {@link Mono} which shares this {@link Mono} result similar to {@link Flux#shareNext()}.
 * This will effectively turn this {@link Mono} into a hot task when the first
 * {@link Subscriber} subscribes using {@link #subscribe()} API. Further {@link Subscriber} will share the same {@link Subscription}
 * and therefore the same result.
 * It's worth noting this is an un-cancellable {@link Subscription}.
 * <p>
 * <img class = "marble" src = "doc-files/marbles/shareForMono.svg" alt = "">
 *
 * @return a new {@link Mono}
 */
public final Mono<T> share() {

Я только что попробовал это с этим ...

@Bean
ApplicationRunner runner() {
    return args -> {
        One<Object> one = Sinks.one();
        Mono<Object> mono = one.asMono();
        Mono<Object> mono1 = mono.share();
        Mono<Object> mono2 = mono.share();
        subsMono(mono1, 1);
        subsMono(mono2, 2);
        subsMono(mono, 0);
        one.emitValue("foo", null);
    };
}

private void subsMono(Mono mono, int i) {
    mono.doOnNext(obj -> System.out.println(obj.toString() + i))
        .subscribe();
}
foo1
foo2
foo0

Глядя на комментарии в share() javadocs: It's worth noting this is an un-cancellable Subscription. Приведет ли выполнение share() к каждому ответу API к утечке памяти из-за неотмененных подписок? (Наверное, мне нужно спросить об этом в чате reactor.)

al.truisme 23.11.2022 17:46

Другие вопросы по теме