在Spring WebFlux中處理錯(cuò)誤

1、 PAGE 1在Spring WebFlux中處理錯(cuò)誤 PAGE 6在Spring WebFlux中處理錯(cuò)誤概覽在本教程中，我們通過(guò)一個(gè)實(shí)際的例子來(lái)看一下可用于處理Spring WebFlux項(xiàng)目中的錯(cuò)誤的各種策略。我們還將指出在哪種情況下使用一種策略會(huì)比另外一種好，在本文最后將提供所有源碼的下載地址。配置實(shí)例上一篇文章 HYPERLINK /spring-webflux previous article 中已經(jīng)提到了maven的配置, 并對(duì) Spring Webflux做了簡(jiǎn)單的介紹。在這個(gè)例子中，我們?yōu)橐粋€(gè) RESTful 端點(diǎn)加上一個(gè)名為 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)建一個(gè)路由器函數(shù)，將/hello請(qǐng)求路由名為handleRequest的方法中：Beanpublic RouterFunction routeRequest(Handler handler) return RouterFunctions.route(RequestPredicates.GET(/hell

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

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

5、及其用法。使用 onErrorReturn當(dāng)出現(xiàn)錯(cuò)誤時(shí)，我們可以使用 onErrorReturn()來(lái)返回一個(gè)靜態(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í)，函數(shù)就會(huì)默認(rèn)返回Hello Stranger。使用onErrorResume

6、使用onErrorResume處理錯(cuò)誤有三種方式：計(jì)算動(dòng)態(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()捕獲，包裝和重新拋出錯(cuò)誤，例如 作為自定義業(yè)務(wù)異常讓我們看看怎么楊計(jì)算一個(gè)值：.flatMa

7、p(s - ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).syncBody(s);在這里，每當(dāng)sayHello()拋出異常時(shí)，我們將返回一個(gè)字符串，該字符串由附加到字符串“Error”的動(dòng)態(tài)獲取的錯(cuò)誤消息組成。接下來(lái)，當(dāng)錯(cuò)誤發(fā)生時(shí)我們調(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()拋出異常，我們就會(huì)調(diào)用替代方法sayHelloFallback()。使用onErrorResume()的最后一個(gè)選項(xiàng)是捕獲，包裝和重新拋出錯(cuò)誤，例如 作為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()拋出異常，我們就會(huì)拋出一個(gè)自定義異常，并帶有消息：username is required。全局級(jí)別的錯(cuò)誤處理到目前為止，我們提供的所有示例都在函數(shù)級(jí)別上處理了錯(cuò)誤處理。但是，我們可以選擇在全局范圍內(nèi)處理我們的WebFlux錯(cuò)誤。 要做到這

10、一點(diǎn)，我們只需要采取兩個(gè)步驟：自定義全局錯(cuò)誤響應(yīng)屬性實(shí)現(xiàn)全局錯(cuò)誤處理程序我們的處理程序拋出的異常將被自動(dòng)轉(zhuǎn)換為HTTP狀態(tài)和JSON錯(cuò)誤正文。 要自定義這些，我們可以簡(jiǎn)單地?cái)U(kuò)展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ā)生異常時(shí)作為錯(cuò)誤屬性的一部分返回。接下來(lái)，讓我們實(shí)現(xiàn)全局錯(cuò)誤處理程序。 為此，Spring提供了一個(gè)方便的AbstractErrorWebExceptionHandler類，供我們?cè)谔幚砣皱e(cuò)誤時(shí)進(jìn)行擴(kuò)展和實(shí)現(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);在這個(gè)例子中，我們將全局錯(cuò)誤處理程序的順序設(shè)置為-2。 這是為了給它一個(gè)比在Order(-1)注冊(cè)的DefaultErrorWebExceptionHandler更高的優(yōu)先級(jí)。errorAttributes對(duì)象將是我們?cè)赪eb異常處理程序的構(gòu)造函數(shù)中傳遞的副本的精確副本。 理想情況下， 這應(yīng)該是我們自定義的Error Attributes類。然后，我們清楚地說(shuō)明我們想要將所有錯(cuò)誤處理請(qǐng)求路由到renderErrorResponse()方法。最后，我們獲取錯(cuò)誤屬性并將它們插入服務(wù)器響應(yīng)主體中。然后，它會(huì)生成一個(gè)JSON響應(yīng)，其中包含錯(cuò)誤，HTTP狀態(tài)和計(jì)算機(jī)客戶端的異常消息的詳細(xì)