网站建设手机字体大小,网站备案制作,定制网站制作系统,wordpress布局切换功能rx.observableSpring MVC现在已经支持异步请求处理流程了一段时间#xff0c;该支持内部利用了Tomcat / Jetty等容器的Servlet 3异步支持。 Spring Web Async支持 考虑一下需要花一点时间处理的服务呼叫#xff0c;该服务呼叫具有延迟#xff1a; public CompletableFutur… rx.observable Spring MVC现在已经支持异步请求处理流程了一段时间该支持内部利用了Tomcat / Jetty等容器的Servlet 3异步支持。 Spring Web Async支持 考虑一下需要花一点时间处理的服务呼叫该服务呼叫具有延迟 public CompletableFutureMessage getAMessageFuture() {return CompletableFuture.supplyAsync(() - {logger.info(Start: Executing slow task in Service 1);Util.delay(1000);logger.info(End: Executing slow task in Service 1);return new Message(data 1);}, futureExecutor);
} 如果要在用户请求流中调用此服务则传统的阻塞控制器流将如下所示 RequestMapping(/getAMessageFutureBlocking)
public Message getAMessageFutureBlocking() throws Exception {return service1.getAMessageFuture().get();
} 更好的方法是使用Spring异步支持以便在CompletableFuture可用时将结果返回给用户这样就不会占用容器线程了 RequestMapping(/getAMessageFutureAsync)
public DeferredResultMessage getAMessageFutureAsync() {DeferredResultMessage deffered new DeferredResult(90000);CompletableFutureMessage f this.service1.getAMessageFuture();f.whenComplete((res, ex) - {if (ex ! null) {deffered.setErrorResult(ex);} else {deffered.setResult(res);}});return deffered;
}在异步流中使用Observable 现在到本文的主题最近我一直在使用Rx-java的出色的Observable类型作为我的服务返回类型并想确保Web层在处理从服务调用返回的Observable类型时也保持异步。 考虑现在修改的上述服务以返回一个Observable public ObservableMessage getAMessageObs() {return Observable.Messagecreate(s - {logger.info(Start: Executing slow task in Service 1);Util.delay(1000);s.onNext(new Message(data 1));logger.info(End: Executing slow task in Service 1);s.onCompleted();}).subscribeOn(Schedulers.from(customObservableExecutor));
} 我可以通过在Web层进行阻塞调用来结束返回Observable的所有好处其中一个朴素的调用将是以下内容 RequestMapping(/getAMessageObsBlocking)
public Message getAMessageObsBlocking() {return service1.getAMessageObs().toBlocking().first();
} 为了使该流在Web层中异步以下是处理此调用的更好方法基本上是将Observable转换为Spring的DeferredResult类型 RequestMapping(/getAMessageObsAsync)
public DeferredResultMessage getAMessageAsync() {ObservableMessage o this.service1.getAMessageObs();DeferredResultMessage deffered new DeferredResult(90000);o.subscribe(m - deffered.setResult(m), e - deffered.setErrorResult(e));return deffered;
} 这将确保处理用户流的线程将在服务调用完成后立即返回并且一旦可观察到的开始发出值就将对用户响应进行React性处理。 如果您有兴趣进一步探索 这里是一个带有工作示例的github存储库https://github.com/bijukunjummen/spring-web-observable。 参考文献 Spring关于Web层中异步流的参考指南http://docs.spring.io/spring/docs/current/spring-framework-reference/html/mvc.html#mvc-ann-async NoBlogDefFound博客上无与伦比的Tomasz Nurkiewicz提供的有关Spring DeferredResult的更多详细信息 -http://www.nurkiewicz.com/2013/03/deferredresult-asynchronous-processing.html 翻译自: https://www.javacodegeeks.com/2015/03/using-rx-java-observable-in-a-spring-mvc-flow.htmlrx.observable
