前言
spring cloud gateway是spring官方基于spring 5.0，spring boot 2.0和project reactor等技術(shù)開發(fā)的網(wǎng)關(guān)，spring cloud gateway旨在為微服務(wù)架構(gòu)提供一種簡(jiǎn)單而有效的統(tǒng)一的api路由管理方式。spring cloud gateway作為spring cloud生態(tài)系中的網(wǎng)關(guān)，目標(biāo)是替代netflix zuul，其不僅提供統(tǒng)一的路由方式，并且基于filter鏈的方式提供了網(wǎng)關(guān)基本的功能，例如：安全，監(jiān)控/埋點(diǎn)，和限流等。
spring cloud gateway 的特征：
- 基于 spring framework 5，project reactor 和 spring boot 2.0動(dòng)態(tài)路由
- predicates 和 filters 作用于特定路由
- 集成 hystrix 斷路器
- 集成 spring cloud discoveryclient
- 易于編寫的 predicates 和 filters
- 限流
- 路徑重寫
spring cloud gateway中的全局異常處理不能直接用@controlleradvice來處理，通過跟蹤異常信息的拋出，找到對(duì)應(yīng)的源碼，自定義一些處理邏輯來符合業(yè)務(wù)的需求。
網(wǎng)關(guān)都是給接口做代理轉(zhuǎn)發(fā)的，后端對(duì)應(yīng)的都是rest api，返回?cái)?shù)據(jù)格式都是json。如果不做處理，當(dāng)發(fā)生異常時(shí)，gateway默認(rèn)給出的錯(cuò)誤信息是頁(yè)面，不方便前端進(jìn)行異常處理。
需要對(duì)異常信息進(jìn)行處理，返回json格式的數(shù)據(jù)給客戶端。下面先看實(shí)現(xiàn)的代碼，后面再跟大家講下需要注意的地方。
自定義異常處理邏輯：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
package com.cxytiandi.gateway.exception;import java.util.hashmap;import java.util.map;import org.springframework.boot.autoconfigure.web.errorproperties;import org.springframework.boot.autoconfigure.web.resourceproperties;import org.springframework.boot.autoconfigure.web.reactive.error.defaulterrorwebexceptionhandler;import org.springframework.boot.web.reactive.error.errorattributes;import org.springframework.context.applicationcontext;import org.springframework.http.httpstatus;import org.springframework.web.reactive.function.server.requestpredicates;import org.springframework.web.reactive.function.server.routerfunction;import org.springframework.web.reactive.function.server.routerfunctions;import org.springframework.web.reactive.function.server.serverrequest;import org.springframework.web.reactive.function.server.serverresponse;/** * 自定義異常處理 * * <p>異常時(shí)用json代替html異常信息<p> * * @author yinjihuan * */public class jsonexceptionhandler extends defaulterrorwebexceptionhandler { public jsonexceptionhandler(errorattributes errorattributes, resourceproperties resourceproperties, errorproperties errorproperties, applicationcontext applicationcontext) { super(errorattributes, resourceproperties, errorproperties, applicationcontext); } /** * 獲取異常屬性 */ @override protected map<string, object> geterrorattributes(serverrequest request, boolean includestacktrace) { int code = 500; throwable error = super.geterror(request); if (error instanceof org.springframework.cloud.gateway.support.notfoundexception) { code = 404; } return response(code, this.buildmessage(request, error)); } /** * 指定響應(yīng)處理方法為json處理的方法 * @param errorattributes */ @override protected routerfunction<serverresponse> getroutingfunction(errorattributes errorattributes) { return routerfunctions.route(requestpredicates.all(), this::rendererrorresponse); } /** * 根據(jù)code獲取對(duì)應(yīng)的httpstatus * @param errorattributes */ @override protected httpstatus gethttpstatus(map<string, object> errorattributes) { int statuscode = (int) errorattributes.get("code"); return httpstatus.valueof(statuscode); } /** * 構(gòu)建異常信息 * @param request * @param ex * @return */ private string buildmessage(serverrequest request, throwable ex) { stringbuilder message = new stringbuilder("failed to handle request ["); message.append(request.methodname()); message.append(" "); message.append(request.uri()); message.append("]"); if (ex != null) { message.append(": "); message.append(ex.getmessage()); } return message.tostring(); } /** * 構(gòu)建返回的json數(shù)據(jù)格式 * @param status 狀態(tài)碼 * @param errormessage 異常信息 * @return */ public static map<string, object> response(int status, string errormessage) { map<string, object> map = new hashmap<>(); map.put("code", status); map.put("message", errormessage); map.put("data", null); return map; }} |
覆蓋默認(rèn)的配置：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package com.cxytiandi.gateway.exception;import java.util.collections;import java.util.list;import org.springframework.beans.factory.objectprovider;import org.springframework.boot.autoconfigure.web.resourceproperties;import org.springframework.boot.autoconfigure.web.serverproperties;import org.springframework.boot.context.properties.enableconfigurationproperties;import org.springframework.boot.web.reactive.error.errorattributes;import org.springframework.boot.web.reactive.error.errorwebexceptionhandler;import org.springframework.context.applicationcontext;import org.springframework.context.annotation.bean;import org.springframework.context.annotation.configuration;import org.springframework.core.ordered;import org.springframework.core.annotation.order;import org.springframework.http.codec.servercodecconfigurer;import org.springframework.web.reactive.result.view.viewresolver;/** * 覆蓋默認(rèn)的異常處理 * * @author yinjihuan * */@configuration@enableconfigurationproperties({serverproperties.class, resourceproperties.class})public class errorhandlerconfiguration { private final serverproperties serverproperties; private final applicationcontext applicationcontext; private final resourceproperties resourceproperties; private final list<viewresolver> viewresolvers; private final servercodecconfigurer servercodecconfigurer; public errorhandlerconfiguration(serverproperties serverproperties, resourceproperties resourceproperties, objectprovider<list<viewresolver>> viewresolversprovider, servercodecconfigurer servercodecconfigurer, applicationcontext applicationcontext) { this.serverproperties = serverproperties; this.applicationcontext = applicationcontext; this.resourceproperties = resourceproperties; this.viewresolvers = viewresolversprovider.getifavailable(collections::emptylist); this.servercodecconfigurer = servercodecconfigurer; } @bean @order(ordered.highest_precedence) public errorwebexceptionhandler errorwebexceptionhandler(errorattributes errorattributes) { jsonexceptionhandler exceptionhandler = new jsonexceptionhandler( errorattributes, this.resourceproperties, this.serverproperties.geterror(), this.applicationcontext); exceptionhandler.setviewresolvers(this.viewresolvers); exceptionhandler.setmessagewriters(this.servercodecconfigurer.getwriters()); exceptionhandler.setmessagereaders(this.servercodecconfigurer.getreaders()); return exceptionhandler; } } |
注意點(diǎn)
異常時(shí)如何返回json而不是html?
在org.springframework.boot.autoconfigure.web.reactive.error.defaulterrorwebexceptionhandler中的getroutingfunction()方法就是控制返回格式的，原代碼如下：
|
1
2
3
4
5
6
|
@overrideprotected routerfunction<serverresponse> getroutingfunction( errorattributes errorattributes) { return routerfunctions.route(acceptstexthtml(), this::rendererrorview) .androute(requestpredicates.all(), this::rendererrorresponse);} |
這邊優(yōu)先是用html來顯示的，想用json的改下就可以了，如下：
|
1
2
3
|
protected routerfunction<serverresponse> getroutingfunction(errorattributes errorattributes) { return routerfunctions.route(requestpredicates.all(), this::rendererrorresponse);} |
gethttpstatus需要重寫
原始的方法是通過status來獲取對(duì)應(yīng)的httpstatus的，代碼如下：
|
1
2
3
4
|
protected httpstatus gethttpstatus(map<string, object> errorattributes) { int statuscode = (int) errorattributes.get("status"); return httpstatus.valueof(statuscode);} |
如果我們定義的格式中沒有status字段的話，這么就會(huì)報(bào)錯(cuò)，找不到對(duì)應(yīng)的響應(yīng)碼，要么返回?cái)?shù)據(jù)格式中增加status子段，要么重寫，我這邊返回的是code，所以要重寫，代碼如下：
|
1
2
3
4
5
|
@overrideprotected httpstatus gethttpstatus(map<string, object> errorattributes) { int statuscode = (int) errorattributes.get("code"); return httpstatus.valueof(statuscode);} |
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)服務(wù)器之家的支持。
原文鏈接：https://juejin.im/post/5bbad1405188255c4a7137e1
