java-Spring MVC与反应流集成

2019-11-18 18:02:03 阅读：265 来源： 互联网

标签：project-reactor rx-java reactive-programming java spring-mvc

我在Spring MVC上构建了一个RESTful API应用程序.

最近,我在spring mvc和反应式流之间进行了一些集成(例如rxjava和project-reactor),并尝试使应用程序更具反应性.

我刚刚在下面建立了一些演示：

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的CompletableFuture在控制器方法之间提供什么区别.

我所了解的反应式流以及我想要的是将servlet请求视为流,并使用诸如反压之类的功能来处理它.

我想知道：
1.是否有更好的方法使应用程序更具反应性？
2.将spring mvc与反应流集成在一起是否正确或兼容？如果是,我该如何执行背压功能？

我意识到也许我忘记声明为什么/如何在控制器中返回completablefuture了,实际上我注入了自定义的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);
}
}

解决方法:

Spring MVC基于Servlet API,并且大部分在内部进行阻塞,因此无法利用响应流行为.为Controller层编写适配器是不够的.

为此,Spring团队正在一项单独的计划中.关注SPR-14161和Spring博客(包括this和this)以了解有关反应式Spring的更多信息.

标签：project-reactor,rx-java,reactive-programming,java,spring-mvc
来源： https://codeday.me/bug/20191118/2029918.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java-Spring MVC与反应流集成