在Spring WebFlux中處理錯誤

1、 PAGE 1在Spring WebFlux中處理錯誤 PAGE 6在Spring WebFlux中處理錯誤概覽在本教程中，我們通過一個實際的例子來看一下可用于處理Spring WebFlux項目中的錯誤的各種策略。我們還將指出在哪種情況下使用一種策略會比另外一種好，在本文最后將提供所有源碼的下載地址。配置實例上一篇文章 HYPERLINK /spring-webflux previous article 中已經(jīng)提到了maven的配置, 并對 Spring Webflux做了簡單的介紹。在這個例子中，我們?yōu)橐粋€ RESTful 端點加上一個名為 username 的查詢參數(shù)，并以“Hello

2、username”作為結(jié)果返回。First, lets create a router function that routes the /hello request to a method named handleRequest in the passed-in handler:首先，讓我們創(chuàng)建一個路由器函數(shù)，將/hello請求路由名為handleRequest的方法中：Beanpublic RouterFunction routeRequest(Handler handler) return RouterFunctions.route(RequestPredicates.GET(/hell

3、o).and(RequestPredicates.accept(MediaType.TEXT_PLAIN), handler:handleRequest);接下來，我們將定義handleRequest()方法，該方法調(diào)用sayHello()方法并在ServerResponse主體中包 含/返回其結(jié)果的方法：public Mono handleRequest(ServerRequest request) return/.sayHello(request)/.最后，sayHello()是一個簡單的實用工具方法，它將“Hello”和 username 連接起來返回。private Mono sayH

4、ello(ServerRequest request) /.return Mono.just(Hello, + request.queryParam(name).get();/.只要用 username 作為我們請求的一部分存在，例如使用“/hello?username=Tonni”訪問，我們的端點就可以正確運行。然而，如果我們調(diào)用/hello的時候沒有使用 username 這個參數(shù)，它會拋出一個異常。下面，我們將看看我們在何處如何重新組織我們的代碼才能在WebFlux中處理此異常。在函數(shù)級別處理錯誤Mono和Flux API內(nèi)置了兩個關(guān)鍵操作符，用于處理功能級別的錯誤。讓我們簡要地探討它們

5、及其用法。使用 onErrorReturn當(dāng)出現(xiàn)錯誤時，我們可以使用 onErrorReturn()來返回一個靜態(tài)的默認(rèn)值。public Mono handleRequest(ServerRequest request) return sayHello(request).onErrorReturn(Hello Stranger).flatMap(s - ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).syncBody(s);當(dāng) sayHello()拋出異常時，函數(shù)就會默認(rèn)返回Hello Stranger。使用onErrorResume

6、使用onErrorResume處理錯誤有三種方式：計算動態(tài)返回值使用fallback方法 跳轉(zhuǎn)到備份路徑public Mono handleRequest(ServerRequest request) return sayHello(request).flatMap(s - ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).syncBody(s).onErrorResume(e - Mono.just(Error + e.getMessage()捕獲，包裝和重新拋出錯誤，例如 作為自定義業(yè)務(wù)異常讓我們看看怎么楊計算一個值：.flatMa

7、p(s - ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).syncBody(s);在這里，每當(dāng)sayHello()拋出異常時，我們將返回一個字符串，該字符串由附加到字符串“Error”的動態(tài)獲取的錯誤消息組成。接下來，當(dāng)錯誤發(fā)生時我們調(diào)用 fallback 方法：public Mono handleRequest(ServerRequest request) return sayHello(request).flatMap(s - ServerResponse.ok().contentType(MediaType.TEXT_PLAI

8、N).syncBody(s).onErrorResume(e - sayHelloFallback().flatMap(s -; ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).syncBody(s);在這里，只要sayHello()拋出異常，我們就會調(diào)用替代方法sayHelloFallback()。使用onErrorResume()的最后一個選項是捕獲，包裝和重新拋出錯誤，例如 作為NameRequiredException：public Mono handleRequest(ServerRequest request) retur

9、n ServerResponse.ok().body(sayHello(request).onErrorResume(e - Mono.error(new NameRequiredException( HttpStatus.BAD_REQUEST,username is required, e), String.class);在這里，只要sayHello()拋出異常，我們就會拋出一個自定義異常，并帶有消息：username is required。全局級別的錯誤處理到目前為止，我們提供的所有示例都在函數(shù)級別上處理了錯誤處理。但是，我們可以選擇在全局范圍內(nèi)處理我們的WebFlux錯誤。 要做到這

10、一點，我們只需要采取兩個步驟：自定義全局錯誤響應(yīng)屬性實現(xiàn)全局錯誤處理程序我們的處理程序拋出的異常將被自動轉(zhuǎn)換為HTTP狀態(tài)和JSON錯誤正文。 要自定義這些，我們可以簡單地擴展DefaultErrorAttributes類并覆蓋其getErrorAttributes()方法：public class GlobalErrorAttributes extends DefaultErrorAttributesOverridepublic Map getErrorAttributes(ServerRequest request, boolean includeStackTrace) Map map =

11、 super.getErrorAttributes( request, includeStackTrace);map.put(status, HttpStatus.BAD_REQUEST); map.put(message, username is required); return map;在這里，我們希望狀態(tài)：BAD_REQUEST和消息：username is required在發(fā)生異常時作為錯誤屬性的一部分返回。接下來，讓我們實現(xiàn)全局錯誤處理程序。 為此，Spring提供了一個方便的AbstractErrorWebExceptionHandler類，供我們在處理全局錯誤時進(jìn)行擴展和實現(xiàn)

12、：Component Order(-2)public class GlobalErrorWebExceptionHandler extends AbstractErrorWebExceptionHandler / constructorsOverrideprotected RouterFunction getRoutingFunction( ErrorAttributes errorAttributes) return RouterFunctions.route( RequestPredicates.all(), this:renderErrorResponse);private Mono r

13、enderErrorResponse( ServerRequest request) Map errorPropertiesMap = getErrorAttributes(request, false);return ServerResponse.status(HttpStatus.BAD_REQUEST).contentType(MediaType.APPLICATION_JSON_UTF8).body(BodyInserters.fromObject(errorPropertiesMap);在這個例子中，我們將全局錯誤處理程序的順序設(shè)置為-2。 這是為了給它一個比在Order(-1)注冊的DefaultErrorWebExceptionHandler更高的優(yōu)先級。errorAttributes對象將是我們在Web異常處理程序的構(gòu)造函數(shù)中傳遞的副本的精確副本。 理想情況下， 這應(yīng)該是我們自定義的Error Attributes類。然后，我們清楚地說明我們想要將所有錯誤處理請求路由到renderErrorResponse()方法。最后，我們獲取錯誤屬性并將它們插入服務(wù)器響應(yīng)主體中。然后，它會生成一個JSON響應(yīng)，其中包含錯誤，HTTP狀態(tài)和計算機客戶端的異常消息的詳細(xì)