Spring Cloud 中 Zuul 網(wǎng)關(guān)原理及其配置看它就夠了

SpringCloud中Zuul網(wǎng)關(guān)原理及其配置，看它就夠了！Zuul是springcloud中的微服務(wù)網(wǎng)關(guān)。網(wǎng)關(guān)：是一個(gè)網(wǎng)絡(luò)整體系統(tǒng)中的前置門戶入口。請(qǐng)求首先通過(guò)網(wǎng)關(guān)，進(jìn)行路徑的路由，定位到具體的服務(wù)節(jié)點(diǎn)上。Zuul是一個(gè)微服務(wù)網(wǎng)關(guān)，首先是一個(gè)微服務(wù)。也是會(huì)在Eureka注冊(cè)中心中進(jìn)行服務(wù)的注冊(cè)和發(fā)現(xiàn)。也是一個(gè)網(wǎng)關(guān)，請(qǐng)求應(yīng)該通過(guò)Zuul來(lái)進(jìn)行路由。Zuul網(wǎng)關(guān)不是必要的。是推薦使用的。使用Zuul，一般在微服務(wù)數(shù)量較多（多于10個(gè)）的時(shí)候推薦使用，對(duì)服務(wù)的管理有嚴(yán)格要求的時(shí)候推薦使用，當(dāng)微服務(wù)權(quán)限要求嚴(yán)格的時(shí)候推薦使用。一、Zuul網(wǎng)關(guān)的作用網(wǎng)關(guān)有以下幾個(gè)作用：統(tǒng)一入口：未全部為服務(wù)提供一個(gè)唯一的入口，網(wǎng)關(guān)起到外部和內(nèi)部隔離的作用，保障了后臺(tái)服務(wù)的安全性。鑒權(quán)校驗(yàn)：識(shí)別每個(gè)請(qǐng)求的權(quán)限，拒絕不符合要求的請(qǐng)求。動(dòng)態(tài)路由：動(dòng)態(tài)的將請(qǐng)求路由到不同的后端集群中。減少客戶端與服務(wù)端的耦合：服務(wù)可以獨(dú)立發(fā)展，通過(guò)網(wǎng)關(guān)層來(lái)做映射。二、Zuul網(wǎng)關(guān)的應(yīng)用1、網(wǎng)關(guān)訪問(wèn)方式通過(guò)zuul訪問(wèn)服務(wù)的，URL地址默認(rèn)格式為：http://zuulHostIp:port/要訪問(wèn)的服務(wù)名稱/服務(wù)中的URL服務(wù)名稱：properties配置文件中的。服務(wù)的URL：就是對(duì)應(yīng)的服務(wù)對(duì)外提供的URL路徑監(jiān)聽(tīng)。2、網(wǎng)關(guān)依賴注入

<dependency>

<groupId>org.springframework.cloudgroupId>

<artifactId>spring-cloud-starter-eurekaartifactId>

dependency>

<dependency>

<groupId>org.springframework.cloudgroupId>

<artifactId>spring-cloud-starter-zuulartifactId>

dependency>

<dependency>

<groupId>org.springframework.retrygroupId>

<artifactId>spring-retryartifactId>

dependency>3、網(wǎng)關(guān)啟動(dòng)器/**

*

@EnableZuulProxy

-

開(kāi)啟Zuul網(wǎng)關(guān)。

*

當(dāng)前應(yīng)用是一個(gè)Zuul微服務(wù)網(wǎng)關(guān)。會(huì)在Eureka注冊(cè)中心中注冊(cè)當(dāng)前服務(wù)。并發(fā)現(xiàn)其他的服務(wù)。

*

Zuul需要的必要依賴是spring-cloud-starter-zuul。

*/

@SpringBootApplication

@EnableZuulProxy

public

class

ZuulApplication

{

public

static

void

main(String[]

args)

{

SpringApplication.run(ZuulApplication.class,

args);

}

}4、網(wǎng)關(guān)全局變量配置4.1URL路徑匹配#

URL

pattern

#

使用路徑方式匹配路由規(guī)則。

#

參數(shù)key結(jié)構(gòu)：zuul.routes.customName.path=xxx

#

用于配置路徑匹配規(guī)則。

#

其中customName自定義。通常使用要調(diào)用的服務(wù)名稱，方便后期管理

#

可使用的通配符有：

*

**?

#

?

單個(gè)字符

#

*

任意多個(gè)字符，不包含多級(jí)路徑

#

**

任意多個(gè)字符，包含多級(jí)路徑

zuul.routes.eureka-application-service.path=/api/**

#

參數(shù)key結(jié)構(gòu)：zuul.routes.customName.url=xxx

#url用于配置符合path的請(qǐng)求路徑路由到的服務(wù)地址。

zuul.routes.eureka-application-service.url=:8080/4.2服務(wù)名稱匹配#

service

id

pattern

通過(guò)服務(wù)名稱路由

#key結(jié)構(gòu)

：zuul.routes.customName.path=xxx

#

路徑匹配規(guī)則

zuul.routes.eureka-application-service.path=/api/**

#key結(jié)構(gòu)

：zuul.routes.customName.serviceId=xxx

#serviceId用于配置符合path的請(qǐng)求路徑路由到的服務(wù)名稱。

zuul.routes.eureka-application-service.serviceId=eureka-application-service服務(wù)名稱匹配也可以使用簡(jiǎn)化的配置：#

simple

service

id

pattern

簡(jiǎn)化配置方案

#

如果只配置path，不配置serviceId。則customName相當(dāng)于服務(wù)名稱。

#

符合path的請(qǐng)求路徑直接路由到customName對(duì)應(yīng)的服務(wù)上。

zuul.routes.eureka-application-service.path=/api/**4.3路由排除配置#

ignored

service

id

pattern

#

配置不被zuul管理的服務(wù)列表。多個(gè)服務(wù)名稱使用逗號(hào)','分隔。

#

配置的服務(wù)將不被zuul代理。

zuul.ignored-services=eureka-application-service

#

此方式相當(dāng)于給所有新發(fā)現(xiàn)的服務(wù)默認(rèn)排除zuul網(wǎng)關(guān)訪問(wèn)方式，只有配置了路由網(wǎng)關(guān)的服務(wù)才可以通過(guò)zuul網(wǎng)關(guān)訪問(wèn)

#

通配方式配置排除列表。

zuul.ignored-services=*

#

使用服務(wù)名稱匹配規(guī)則配置路由列表，相當(dāng)于只對(duì)已配置的服務(wù)提供網(wǎng)關(guān)代理。

zuul.routes.eureka-application-service.path=/api/**

#

通配方式配置排除網(wǎng)關(guān)代理路徑。所有符合ignored-patterns的請(qǐng)求路徑都不被zuul網(wǎng)關(guān)代理。

zuul.ignored-patterns=/**/test/**

zuul.routes.eureka-application-service.path=/api/**4.4路由前綴配置#

prefix

URL

pattern

前綴路由匹配

#

配置請(qǐng)求路徑前綴，所有基于此前綴的請(qǐng)求都由zuul網(wǎng)關(guān)提供代理。

zuul.prefix=/api

#

使用服務(wù)名稱匹配方式配置請(qǐng)求路徑規(guī)則。

#

這里的配置將為：http://ip:port/api/appservice/**的請(qǐng)求提供zuul網(wǎng)關(guān)代理，可以將要訪問(wèn)服務(wù)進(jìn)行前綴分類。

#

并將請(qǐng)求路由到服務(wù)eureka-application-service中。

zuul.routes.eureka-application-service.path=/appservice/**5.Zuul網(wǎng)關(guān)配置總結(jié)網(wǎng)關(guān)配置方式有多種，默認(rèn)、URL、服務(wù)名稱、排除|忽略、前綴。網(wǎng)關(guān)配置沒(méi)有優(yōu)劣好壞，應(yīng)該在不同的情況下選擇合適的配置方案。擴(kuò)展：大公司為什么都有API網(wǎng)關(guān)？聊聊API網(wǎng)關(guān)的作用zuul網(wǎng)關(guān)其底層使用ribbon來(lái)實(shí)現(xiàn)請(qǐng)求的路由，并內(nèi)置Hystrix，可選擇性提供網(wǎng)關(guān)fallback邏輯。使用zuul的時(shí)候，并不推薦使用Feign作為applicationclient端的開(kāi)發(fā)實(shí)現(xiàn)。畢竟Feign技術(shù)是對(duì)ribbon的再封裝，使用Feign本身會(huì)提高通訊消耗，降低通訊效率，只在服務(wù)相互調(diào)用的時(shí)候使用Feign來(lái)簡(jiǎn)化代碼開(kāi)發(fā)就夠了。而且商業(yè)開(kāi)發(fā)中，使用Ribbon+RestTemplate來(lái)開(kāi)發(fā)的比例更高。三、Zuul網(wǎng)關(guān)過(guò)濾器Zuul中提供了過(guò)濾器定義，可以用來(lái)過(guò)濾代理請(qǐng)求，提供額外功能邏輯。如：權(quán)限驗(yàn)證，日志記錄等。Zuul提供的過(guò)濾器是一個(gè)父類。父類是ZuulFilter。通過(guò)父類中定義的抽象方法filterType，來(lái)決定當(dāng)前的Filter種類是什么。有前置過(guò)濾、路由后過(guò)濾、后置過(guò)濾、異常過(guò)濾。前置過(guò)濾：是請(qǐng)求進(jìn)入Zuul之后，立刻執(zhí)行的過(guò)濾邏輯。路由后過(guò)濾：是請(qǐng)求進(jìn)入Zuul之后，并Zuul實(shí)現(xiàn)了請(qǐng)求路由后執(zhí)行的過(guò)濾邏輯，路由后過(guò)濾，是在遠(yuǎn)程服務(wù)調(diào)用之前過(guò)濾的邏輯。后置過(guò)濾：遠(yuǎn)程服務(wù)調(diào)用結(jié)束后執(zhí)行的過(guò)濾邏輯。異常過(guò)濾：是任意一個(gè)過(guò)濾器發(fā)生異常或遠(yuǎn)程服務(wù)調(diào)用無(wú)結(jié)果反饋的時(shí)候執(zhí)行的過(guò)濾邏輯。無(wú)結(jié)果反饋，就是遠(yuǎn)程服務(wù)調(diào)用超時(shí)。3.1過(guò)濾器實(shí)現(xiàn)方式繼承父類ZuulFilter。在父類中提供了4個(gè)抽象方法，分別是：filterType,filterOrder,shouldFilter,run。其功能分別是：搜索公眾號(hào)后端架構(gòu)師后臺(tái)回復(fù)“架構(gòu)整潔”，獲取一份驚喜禮包。filterType：方法返回字符串?dāng)?shù)據(jù)，代表當(dāng)前過(guò)濾器的類型。可選值有-pre,route,post,error。pre-前置過(guò)濾器，在請(qǐng)求被路由前執(zhí)行，通常用于處理身份認(rèn)證，日志記錄等；route-在路由執(zhí)行后，服務(wù)調(diào)用前被調(diào)用；error-任意一個(gè)filter發(fā)生異常的時(shí)候執(zhí)行或遠(yuǎn)程服務(wù)調(diào)用沒(méi)有反饋的時(shí)候執(zhí)行（超時(shí)），通常用于處理異常；post-在route或error執(zhí)行后被調(diào)用，一般用于收集服務(wù)信息，統(tǒng)計(jì)服務(wù)性能指標(biāo)等，也可以對(duì)response結(jié)果做特殊處理。filterOrder：返回int數(shù)據(jù)，用于為同filterType的多個(gè)過(guò)濾器定制執(zhí)行順序，返回值越小，執(zhí)行順序越優(yōu)先。shouldFilter：返回boolean數(shù)據(jù)，代表當(dāng)前filter是否生效。run：具體的過(guò)濾執(zhí)行邏輯。如pre類型的過(guò)濾器，可以通過(guò)對(duì)請(qǐng)求的驗(yàn)證來(lái)決定是否將請(qǐng)求路由到服務(wù)上；如post類型的過(guò)濾器，可以對(duì)服務(wù)響應(yīng)結(jié)果做加工處理（如為每個(gè)響應(yīng)增加footer數(shù)據(jù)）。3.2過(guò)濾器的生命周期3.3代碼示例/**

*Zuul過(guò)濾器，必須繼承ZuulFilter父類。

*

當(dāng)前類型的對(duì)象必須交由Spring容器管理。使用@Component注解描述。

*

繼承父類后，必須實(shí)現(xiàn)父類中定義的4個(gè)抽象方法。

*

shouldFilter、

run、

filterType、

filterOrder

*/

@Component

public

class

LoggerFilter

extends

ZuulFilter

{

private

static

final

Logger

logger

=

LoggerFactory.getLogger(LoggerFilter.class);

/**

*

返回boolean類型。代表當(dāng)前filter是否生效。

*

默認(rèn)值為false。

*

返回true代表開(kāi)啟filter。

*/

@Override

public

boolean

shouldFilter()

{

return

true;

}

/**

*run方法就是過(guò)濾器的具體邏輯。

*return可以返回任意的對(duì)象，當(dāng)前實(shí)現(xiàn)忽略。（spring-cloud-zuul官方解釋）

*

直接返回null即可。

*/

@Override

public

Object

run()

throws

ZuulException

{

//

通過(guò)zuul，獲取請(qǐng)求上下文

RequestContext

rc

=

RequestContext.getCurrentContext();

HttpServletRequest

request

=

rc.getRequest();

("LogFilter1.....method={},url={}",

request.getMethod(),request.getRequestURL().toString());

//

可以記錄日志、鑒權(quán)，給維護(hù)人員記錄提供定位協(xié)助、統(tǒng)計(jì)性能

return

null;

}

/**

*

過(guò)濾器的類型。可選值有：

*

pre

-

前置過(guò)濾

*

route

-

路由后過(guò)濾

*

error

-

異常過(guò)濾

*

post

-

遠(yuǎn)程服務(wù)調(diào)用后過(guò)濾

*/

@Override

public

String

filterType()

{

return

"pre";

}

/**

*

同種類的過(guò)濾器的執(zhí)行順序。

*

按照返回值的自然升序執(zhí)行。

*/

@Override

public

int

filterOrder()

{

return

0;

}

}四、Zuul網(wǎng)關(guān)的容錯(cuò)（與Hystrix的無(wú)縫結(jié)合）在springcloud中，Zuul啟動(dòng)器中包含了Hystrix相關(guān)依賴，在Zuul網(wǎng)關(guān)工程中，默認(rèn)是提供了HystrixDashboard服務(wù)監(jiān)控?cái)?shù)據(jù)的(hystrix.stream)，但是不會(huì)提供監(jiān)控面板的界面展示?？梢哉f(shuō)，在springcloud中，zuul和Hystrix是無(wú)縫結(jié)合的。4.1Zuul中的服務(wù)降級(jí)處理在Edgware版本之前，Zuul提供了接口ZuulFallbackProvider用于實(shí)現(xiàn)fallback處理。從Edgware版本開(kāi)始，Zuul提供了ZuulFallbackProvider的子接口FallbackProvider來(lái)提供fallback處理。Zuul的fallback容錯(cuò)處理邏輯，只針對(duì)timeout異常處理，當(dāng)請(qǐng)求被Zuul路由后，只要服務(wù)有返回（包括異常），都不會(huì)觸發(fā)Zuul的fallback容錯(cuò)邏輯。因?yàn)閷?duì)于Zuul網(wǎng)關(guān)來(lái)說(shuō)，做請(qǐng)求路由分發(fā)的時(shí)候，結(jié)果由遠(yuǎn)程服務(wù)運(yùn)算的。那么遠(yuǎn)程服務(wù)反饋了異常信息，Zuul網(wǎng)關(guān)不會(huì)處理異常，因?yàn)闊o(wú)法確定這個(gè)錯(cuò)誤是否是應(yīng)用真實(shí)想要反饋給客戶端的。4.2代碼示例/**

*

如果需要在Zuul網(wǎng)關(guān)服務(wù)中增加容錯(cuò)處理fallback，需要實(shí)現(xiàn)接口ZuulFallbackProvider

*

spring-cloud框架，在Edgware版本(包括)之后，聲明接口ZuulFallbackProvider過(guò)期失效，

*

提供了新的ZuulFallbackProvider的子接口

-

FallbackProvider

*

在老版本中提供的ZuulFallbackProvider中，定義了兩個(gè)方法。

*

-

String

getRoute()

*

當(dāng)前的fallback容錯(cuò)處理邏輯處理的是哪一個(gè)服務(wù)?？梢允褂猛ㄅ浞?’代表為全部的服務(wù)提供容錯(cuò)處理。

*

如果只為某一個(gè)服務(wù)提供容錯(cuò)，返回對(duì)應(yīng)服務(wù)的值。

*

-

ClientHttpResponse

fallbackResponse()

*

當(dāng)服務(wù)發(fā)生錯(cuò)誤的時(shí)候，如何容錯(cuò)。

*

新版本中提供的FallbackProvider提供了新的方法。

*

-

ClientHttpResponse

fallbackResponse(Throwable

cause)

*

如果使用新版本中定義的接口來(lái)做容錯(cuò)處理，容錯(cuò)處理邏輯，只運(yùn)行子接口中定義的新方法。也就是有參方法。

*

是為遠(yuǎn)程服務(wù)發(fā)生異常的時(shí)候，通過(guò)異常的類型來(lái)運(yùn)行不同的容錯(cuò)邏輯。

*/

@Component

public

class

TestFallBbackProvider

implements

FallbackProvider

{

/**

*return-

返回fallback處理哪一個(gè)服務(wù)。返回的是服務(wù)的名稱

*

推薦

-

為指定的服務(wù)定義特性化的fallback邏輯。

*

推薦

-

提供一個(gè)處理所有服務(wù)的fallback邏輯。

*

好處

-

服務(wù)某個(gè)服務(wù)發(fā)生超時(shí)，那么指定的fallback邏輯執(zhí)行。如果有新服務(wù)上線，未提供fallback邏輯，有一個(gè)通用的。

*/

@Override

public

String

getRoute()

{

return

"eureka-application-service";

}

/**

*fallback邏輯。在早期版本中使用。

*

Edgware版本之后，ZuulFallbackProvider接口過(guò)期，提供了新的子接口FallbackProvider

*

子接口中提供了方法ClientHttpResponsefallbackResponse(Throwablecause)。

*

優(yōu)先調(diào)用子接口新定義的fallback處理邏輯。

*/

@Override

public

ClientHttpResponse

fallbackResponse()

{

System.out.println("ClientHttpResponse

fallbackResponse()");

List>

result

=

new

ArrayList<>();

Map

data

=

new

HashMap<>();

data.put("message",

"服務(wù)正忙，請(qǐng)稍后重試");

result.add(data);

ObjectMapper

mapper

=

new

ObjectMapper();

String

msg

=

"";

try

{

msg

=

mapper.writeValueAsString(result);

}

catch

(JsonProcessingException

e)

{

msg

=

"";

}

return

this.executeFallback(HttpStatus.OK,

msg,

"application",

"json",

"utf-8");

}

/**

*fallback邏輯。優(yōu)先調(diào)用?？梢愿鶕?jù)異常類型動(dòng)態(tài)決定處理方式。

*/

@Override

public

ClientHttpResponse

fallbackResponse(Throwable

cause)

{

System.out.println("ClientHttpResponse

fallbackResponse(Throwable

cause)");

if(cause

instanceof

NullPointerException){

List>

result

=

new

ArrayList<>();

Map

data

=

new

HashMap<>();

data.put("message",

"網(wǎng)關(guān)超時(shí)，請(qǐng)稍后重試");

result.add(data);

ObjectMapper

mapper

=

new

ObjectMapper();

String

msg

=

"";

try

{

msg

=

mapper.writeValueAsString(result);

}

catch

(JsonProcessingException

e)

{

msg

=

"";

}

return

this.executeFallback(HttpStatus.GATEWAY_TIMEOUT,

msg,

"application",

"json",

"utf-8");

}else{

return

this.fallbackResponse();

}

}

/**

*

具體處理過(guò)程。

*

@param

status容錯(cuò)處理后的返回狀態(tài)，如200正常GET請(qǐng)求結(jié)果，201正常POST請(qǐng)求結(jié)果，404資源找不到錯(cuò)誤等。

*

使用spring提供的枚舉類型對(duì)象實(shí)現(xiàn)。HttpStatus

*

@param

contentMsg自定義的響應(yīng)內(nèi)容。就是反饋給客戶端的數(shù)據(jù)。

*

@param

mediaType響應(yīng)類型，是響應(yīng)的主類型，

如：application、text、media。

*

@param

subMediaType響應(yīng)類型，是響應(yīng)的子類型，

如：json、stream、html、plain、jpeg、png等。

*

@param

charsetName響應(yīng)結(jié)果的字符集。這里只傳遞字符集名稱，如：utf-8、gbk、big5等。

*

@return

ClientHttpResponse就是響應(yīng)的具體內(nèi)容。

*

相當(dāng)于一個(gè)HttpServletResponse。

*/

private

final

ClientHttpResponse

executeFallback(final

HttpStatus

status,

String

contentMsg,

String

mediaType,

String

subMediaType,

String

charsetName)

{

return

new

ClientHttpResponse()

{

/**

*

設(shè)置響應(yīng)的頭信息

*/

@Override

public

HttpHeaders

getHeaders()

{

HttpHeaders

header

=

new

HttpHeaders();

MediaType

mt

=

new

MediaType(mediaType,

subMediaType,

Charset.forName(charsetName));

header.setContentType(mt);

return

header;

}

/**

*

設(shè)置響應(yīng)體

*zuul會(huì)將本方法返回的輸入流數(shù)據(jù)讀取，并通過(guò)HttpServletResponse的輸出流輸出到客戶端。

*/

@Override

public

InputStream

getBody()

throws

IOException

{

String

content

=

contentMsg;

return

new

ByteArrayInputStream(content.getBytes());

}

/**

*

ClientHttpResponse的fallback的狀態(tài)碼

返回String

*/

@Override

public

String

getStatusText()

throws

IOException

{

return

this.getStatusCode().getReasonPhrase();

}

/**

*

ClientHttpResponse的fallback的狀態(tài)碼

返回HttpStatus

*/

@Override

public

HttpStatus

getStatusCode()

throws

IOException

{

return

status;

}

/**

*

ClientHttpResponse的fallback的狀態(tài)碼

返回int

*/

@Override

public

int

getRawStatusCode()

throws

IOException

{

return

this.getStatusCode().value();

}

/**

*

回收資源方法

*

用于回收當(dāng)前fallback邏輯開(kāi)啟的資源對(duì)象的。

*

不要關(guān)閉getBody方法返回的那個(gè)輸入流對(duì)象。

*/

@Override

public

void

close()

{

}

};

}

}五、Zuul網(wǎng)關(guān)的限流保護(hù)Zuul網(wǎng)關(guān)組件也提供了限流保護(hù)。當(dāng)請(qǐng)求并發(fā)達(dá)到閥值，自動(dòng)觸發(fā)限流保護(hù)，返回錯(cuò)誤結(jié)果。只要提供error錯(cuò)誤處理機(jī)制即可。搜索公眾號(hào)頂級(jí)架構(gòu)師后臺(tái)回復(fù)“手冊(cè)”，獲取一份驚喜禮包。Zuul的限流保護(hù)需要額外依賴spring-cloud-zuul-ratelimit組件。<dependency>

<groupId>com.marcosbarbero.cloudgroupId>

<artifactId>spring-cloud-zuul-ratelimitartifactId>

<version>1.3.4.RELEASEversion>

dependency>5.1全局限流配置使用全局限流配置，zuul會(huì)對(duì)代理的所有服務(wù)提供限流保護(hù)。#

開(kāi)啟限流保護(hù)

zuul.ratelimit.enabled=true

#

60s內(nèi)請(qǐng)求超過(guò)3次，服務(wù)端就拋出異常，60s后可以恢復(fù)正常請(qǐng)求

zuul.ratelimit.default-policy.limit=3

zuul.ratelimit.default-policy.refresh-interval=60

#

針對(duì)IP進(jìn)行限流，不影響其他IP

zuul.ratelimit.default-policy.type=origin5.2局部限流配置使用局部限流配置，zuul僅針對(duì)配置的服務(wù)提供限流保護(hù)。#

開(kāi)啟限流保護(hù)

zuul.ratelimit.enabled=true

#hystrix-application-client服務(wù)60s內(nèi)請(qǐng)求超過(guò)3次，服務(wù)拋出