Spring MVC интегрируется с реактивным потоком

У меня есть приложение RESTful api, построенное на spring mvc.

недавно я делал что-то интеграцию между spring mvc и реактивным потоком (например, rxjava и project -actor) и пытался сделать приложение более реактивным.

Я только что собрал демо, подобное приведенному ниже:

1. для rxjava я использую PublishSubject

private SerializedSubject<StreamResult, StreamResult> subject = PublishSubject.<StreamResult>create().toSerialized();

public ReactiveStreamController() {
    this.subject.subscribe(streamResult -> {
        String id = streamResult.getRequest().getParameter("id");
        System.out.println("[" + Thread.currentThread().getName() + "] request received. id = " + id);
        String random = StringUtils.isBlank(id) ? StringUtils.EMPTY : id;
        ResponseVO vo = new ResponseVO(200, "success = " + random);
        streamResult.getFuture().complete(vo);
    }, Throwable::printStackTrace);
}

@ResponseBody
@RequestMapping(value = "/rxJava", method = RequestMethod.GET)
public CompletableFuture<ResponseVO> rxJavaController(HttpServletRequest httpServletRequest) {
    StreamResult sr = new StreamResult();
    sr.setRequest(httpServletRequest);
    subject.onNext(sr);
    return sr.getFuture();
}

2. для проектного реактора

@ResponseBody
@RequestMapping(value = "/reactorCodeNew", method = RequestMethod.GET)
public CompletableFuture<ResponseVO> reactorCoreNewParadigm(HttpServletRequest servletRequest) {
    Mono<ResponseVO> mono = Mono.just(servletRequest)
            .subscribeOn(executorService)
            .map(request -> {
                String id = request.getParameter("id");
                System.out.println("[" + Thread.currentThread().getName() + "] request received. id = " + id);
                String random = StringUtils.isBlank(id) ? StringUtils.EMPTY : id;
                ResponseVO vo = new ResponseVO(200, "success = " + random);
                return vo;
            })
            .timeout(Duration.ofSeconds(2), Mono.just(new ResponseVO(500, "error")));
    return mono.toCompletableFuture();
}

при запуске обеих демонстраций я не вижу особой разницы между простым использованием java's CompletableFuture для предоставления среди методов контроллера.

Я понимаю реактивный поток и хочу обрабатывать запрос сервлета как поток и использовать его с некоторой функцией, такой как противодавление.

я хочу знать: 1. есть ли лучший способ сделать приложение более реактивным? 2. правильно или совместимо интегрировать Spring mvc с реактивными потоками? если да, как я могу выполнить такую ​​функцию, как противодавление?

Я понимаю, что, возможно, я забыл объявить, почему / как я возвращаю Completetablefuture в контроллер, на самом деле я ввожу настроенный MethodReturnValueHandler, чтобы преобразовать CompletableFuture в DefferdResult.

public class CompletableFutureMethodReturnValueHandler extends DeferredResultMethodReturnValueHandler {

@Override
public boolean supportsReturnType(MethodParameter returnType) {
    return CompletableFuture.class.isAssignableFrom(returnType.getParameterType());
}

@Override
public void handleReturnValue(Object returnValue, MethodParameter returnType, ModelAndViewContainer mavContainer, NativeWebRequest webRequest) throws Exception {

    CompletableFuture<?> completableFuture = (CompletableFuture<?>) returnValue;

    super.handleReturnValue(CompletableDeferredResult.newInstance(completableFuture), returnType, mavContainer, webRequest);
}
}