rx.observable

Spring MVC現在已經支持異步請求處理流程了一段時間，該支持內部利用了Tomcat / Jetty等容器的Servlet 3異步支持。

Spring Web Async支持

考慮一下需要花一點時間處理的服務呼叫，該服務呼叫具有延遲：

public CompletableFuture<Message> 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 DeferredResult<Message> getAMessageFutureAsync() {DeferredResult<Message> deffered = new DeferredResult<>(90000);CompletableFuture<Message> 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 Observable<Message> getAMessageObs() {return Observable.<Message>create(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 DeferredResult<Message> getAMessageAsync() {Observable<Message> o = this.service1.getAMessageObs();DeferredResult<Message> 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.html

rx.observable

總結

以上是生活随笔為你收集整理的rx.observable_在Spring MVC流中使用rx-java Observable的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。