SpringCloud之Zuul網(wǎng)關(guān)原理及其配置講解
Zuul是spring cloud中的微服務(wù)網(wǎng)關(guān)。網(wǎng)關(guān): 是一個(gè)網(wǎng)絡(luò)整體系統(tǒng)中的前置門(mén)戶(hù)入口。請(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)求路由到不同的后端集群中。
- 減少客戶(hù)端與服務(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ù)名稱(chēng)/服務(wù)中的URL
服務(wù)名稱(chēng):properties配置文件中的spring.application.name。
服務(wù)的URL:就是對(duì)應(yīng)的服務(wù)對(duì)外提供的URL路徑監(jiān)聽(tīng)。
2、網(wǎng)關(guān)依賴(lài)注入
<!-- spring cloud Eureka Client 啟動(dòng)器 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-eureka</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-zuul</artifactId> </dependency> <!-- zuul網(wǎng)關(guān)的重試機(jī)制,不是使用ribbon內(nèi)置的重試機(jī)制 是借助spring-retry組件實(shí)現(xiàn)的重試 開(kāi)啟zuul網(wǎng)關(guān)重試機(jī)制需要增加下述依賴(lài) --> <dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> </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需要的必要依賴(lài)是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.1 URL路徑匹配
# URL pattern # 使用路徑方式匹配路由規(guī)則。 # 參數(shù)key結(jié)構(gòu): zuul.routes.customName.path=xxx # 用于配置路徑匹配規(guī)則。 # 其中customName自定義。通常使用要調(diào)用的服務(wù)名稱(chēng),方便后期管理 # 可使用的通配符有: * ** ? # ? 單個(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=http://127.0.0.1:8080/
4.2 服務(wù)名稱(chēng)匹配
# service id pattern 通過(guò)服務(wù)名稱(chēng)路由 # 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ù)名稱(chēng)。 zuul.routes.eureka-application-service.serviceId=eureka-application-service
服務(wù)名稱(chēng)匹配也可以使用簡(jiǎn)化的配置:
# simple service id pattern 簡(jiǎn)化配置方案 # 如果只配置path,不配置serviceId。則customName相當(dāng)于服務(wù)名稱(chēng)。 # 符合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ù)名稱(chēng)使用逗號(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ù)名稱(chēng)匹配規(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ù)名稱(chēng)匹配方式配置請(qǐng)求路徑規(guī)則。 # 這里的配置將為:http://ip:port/api/appservice/**的請(qǐng)求提供zuul網(wǎng)關(guān)代理,可以將要訪問(wèn)服務(wù)進(jìn)行前綴分類(lèi)。 # 并將請(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ù)名稱(chēng)、排除|忽略、前綴。
網(wǎng)關(guān)配置沒(méi)有優(yōu)劣好壞,應(yīng)該在不同的情況下選擇合適的配置方案。
zuul網(wǎng)關(guān)其底層使用ribbon來(lái)實(shí)現(xiàn)請(qǐng)求的路由,并內(nèi)置Hystrix,可選擇性提供網(wǎng)關(guān)fallback邏輯。使用zuul的時(shí)候,并不推薦使用Feign作為application client端的開(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è)父類(lèi)。父類(lèi)是ZuulFilter。通過(guò)父類(lèi)中定義的抽象方法filterType,來(lái)決定當(dāng)前的Filter種類(lèi)是什么。有前置過(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ā)生異?;蜻h(yuǎn)程服務(wù)調(diào)用無(wú)結(jié)果反饋的時(shí)候執(zhí)行的過(guò)濾邏輯。無(wú)結(jié)果反饋,就是遠(yuǎn)程服務(wù)調(diào)用超時(shí)。
3.1過(guò)濾器實(shí)現(xiàn)方式
繼承父類(lèi)ZuulFilter。在父類(lèi)中提供了4個(gè)抽象方法,分別是:filterType, filterOrder, shouldFilter, run。其功能分別是:
filterType
:方法返回字符串?dāng)?shù)據(jù),代表當(dāng)前過(guò)濾器的類(lèi)型??蛇x值有-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類(lèi)型的過(guò)濾器,可以通過(guò)對(duì)請(qǐng)求的驗(yàn)證來(lái)決定是否將請(qǐng)求路由到服務(wù)上;如post類(lèi)型的過(guò)濾器,可以對(duì)服務(wù)響應(yīng)結(jié)果做加工處理(如為每個(gè)響應(yīng)增加footer數(shù)據(jù))。
3.2 過(guò)濾器的生命周期
3.3 代碼示例
/** * Zuul過(guò)濾器,必須繼承ZuulFilter父類(lèi)。 * 當(dāng)前類(lèi)型的對(duì)象必須交由Spring容器管理。使用@Component注解描述。 * 繼承父類(lèi)后,必須實(shí)現(xiàn)父類(lèi)中定義的4個(gè)抽象方法。 * shouldFilter、 run、 filterType、 filterOrder */ @Component public class LoggerFilter extends ZuulFilter { private static final Logger logger = LoggerFactory.getLogger(LoggerFilter.class); /** * 返回boolean類(lèi)型。代表當(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官方解釋?zhuān)? * 直接返回null即可。 */ @Override public Object run() throws ZuulException { // 通過(guò)zuul,獲取請(qǐng)求上下文 RequestContext rc = RequestContext.getCurrentContext(); HttpServletRequest request = rc.getRequest(); logger.info("LogFilter1.....method={},url={}", request.getMethod(),request.getRequestURL().toString()); // 可以記錄日志、鑒權(quán),給維護(hù)人員記錄提供定位協(xié)助、統(tǒng)計(jì)性能 return null; } /** * 過(guò)濾器的類(lèi)型。可選值有: * pre - 前置過(guò)濾 * route - 路由后過(guò)濾 * error - 異常過(guò)濾 * post - 遠(yuǎn)程服務(wù)調(diào)用后過(guò)濾 */ @Override public String filterType() { return "pre"; } /** * 同種類(lèi)的過(guò)濾器的執(zhí)行順序。 * 按照返回值的自然升序執(zhí)行。 */ @Override public int filterOrder() { return 0; } }
四、Zuul網(wǎng)關(guān)的容錯(cuò)(與Hystrix的無(wú)縫結(jié)合)
在spring cloud中,Zuul啟動(dòng)器中包含了Hystrix相關(guān)依賴(lài),在Zuul網(wǎng)關(guān)工程中,默認(rèn)是提供了Hystrix Dashboard服務(wù)監(jiān)控?cái)?shù)據(jù)的(hystrix.stream),但是不會(huì)提供監(jiān)控面板的界面展示??梢哉f(shuō),在spring cloud中,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í)想要反饋給客戶(hù)端的。
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ù)的spring.application.name值。 * - 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)型來(lái)運(yùn)行不同的容錯(cuò)邏輯。 */ @Component public class TestFallBbackProvider implements FallbackProvider { /** * return - 返回fallback處理哪一個(gè)服務(wù)。返回的是服務(wù)的名稱(chēng) * 推薦 - 為指定的服務(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 * 子接口中提供了方法ClientHttpResponse fallbackResponse(Throwable cause)。 * 優(yōu)先調(diào)用子接口新定義的fallback處理邏輯。 */ @Override public ClientHttpResponse fallbackResponse() { System.out.println("ClientHttpResponse fallbackResponse()"); List<Map<String, Object>> result = new ArrayList<>(); Map<String, Object> 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ù)異常類(lèi)型動(dòng)態(tài)決定處理方式。 */ @Override public ClientHttpResponse fallbackResponse(Throwable cause) { System.out.println("ClientHttpResponse fallbackResponse(Throwable cause)"); if(cause instanceof NullPointerException){ List<Map<String, Object>> result = new ArrayList<>(); Map<String, Object> 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提供的枚舉類(lèi)型對(duì)象實(shí)現(xiàn)。HttpStatus * @param contentMsg 自定義的響應(yīng)內(nèi)容。就是反饋給客戶(hù)端的數(shù)據(jù)。 * @param mediaType 響應(yīng)類(lèi)型,是響應(yīng)的主類(lèi)型, 如: application、text、media。 * @param subMediaType 響應(yīng)類(lèi)型,是響應(yīng)的子類(lèi)型, 如: json、stream、html、plain、jpeg、png等。 * @param charsetName 響應(yīng)結(jié)果的字符集。這里只傳遞字符集名稱(chēng),如: 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的輸出流輸出到客戶(hù)端。 */ @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ī)制即可。
Zuul的限流保護(hù)需要額外依賴(lài)spring-cloud-zuul-ratelimit組件。
<dependency> <groupId>com.marcosbarbero.cloud</groupId> <artifactId>spring-cloud-zuul-ratelimit</artifactId> <version>1.3.4.RELEASE</version> </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=origin
5.2 局部限流配置
使用局部限流配置,zuul僅針對(duì)配置的服務(wù)提供限流保護(hù)。
# 開(kāi)啟限流保護(hù) zuul.ratelimit.enabled=true # hystrix-application-client服務(wù)60s內(nèi)請(qǐng)求超過(guò)3次,服務(wù)拋出異常。 zuul.ratelimit.policies.hystrix-application-client.limit=3 zuul.ratelimit.policies.hystrix-application-client.refresh-interval=60 # 針對(duì)IP限流。 zuul.ratelimit.policies.hystrix-application-client.type=origin
5.3 限流參數(shù)簡(jiǎn)介
六、Zuul網(wǎng)關(guān)性能調(diào)優(yōu):網(wǎng)關(guān)的兩層超時(shí)調(diào)優(yōu)
使用Zuul的spring cloud微服務(wù)結(jié)構(gòu)圖:
從上圖中可以看出。整體請(qǐng)求邏輯還是比較復(fù)雜的,在沒(méi)有zuul網(wǎng)關(guān)的情況下,app client請(qǐng)求app service的時(shí)候,也有請(qǐng)求超時(shí)的可能。那么當(dāng)增加了zuul網(wǎng)關(guān)的時(shí)候,請(qǐng)求超時(shí)的可能就更明顯了。
當(dāng)請(qǐng)求通過(guò)zuul網(wǎng)關(guān)路由到服務(wù),并等待服務(wù)返回響應(yīng),這個(gè)過(guò)程中zuul也有超時(shí)控制。zuul的底層使用的是Hystrix+ribbon來(lái)實(shí)現(xiàn)請(qǐng)求路由。結(jié)構(gòu)如下:
zuul中的Hystrix內(nèi)部使用線程池隔離機(jī)制提供請(qǐng)求路由實(shí)現(xiàn),其默認(rèn)的超時(shí)時(shí)長(zhǎng)為1000毫秒。ribbon底層默認(rèn)超時(shí)時(shí)長(zhǎng)為5000毫秒。如果Hystrix超時(shí),直接返回超時(shí)異常。如果ribbon超時(shí),同時(shí)Hystrix未超時(shí),ribbon會(huì)自動(dòng)進(jìn)行服務(wù)集群輪詢(xún)重試,直到Hystrix超時(shí)為止。如果Hystrix超時(shí)時(shí)長(zhǎng)小于ribbon超時(shí)時(shí)長(zhǎng),ribbon不會(huì)進(jìn)行服務(wù)集群輪詢(xún)重試。
那么在zuul中可配置的超時(shí)時(shí)長(zhǎng)就有兩個(gè)位置:Hystrix和ribbon。具體配置如下:
# 開(kāi)啟zuul網(wǎng)關(guān)重試 zuul.retryable=true # hystrix超時(shí)時(shí)間設(shè)置 # 線程池隔離,默認(rèn)超時(shí)時(shí)間1000ms hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=8000 # ribbon超時(shí)時(shí)間設(shè)置:建議設(shè)置比Hystrix小 # 請(qǐng)求連接的超時(shí)時(shí)間: 默認(rèn)5000ms ribbon.ConnectTimeout=5000 # 請(qǐng)求處理的超時(shí)時(shí)間: 默認(rèn)5000ms ribbon.ReadTimeout=5000 # 重試次數(shù):MaxAutoRetries表示訪問(wèn)服務(wù)集群下原節(jié)點(diǎn)(同路徑訪問(wèn));MaxAutoRetriesNextServer表示訪問(wèn)服務(wù)集群下其余節(jié)點(diǎn)(換臺(tái)服務(wù)器) ribbon.MaxAutoRetries=1 ribbon.MaxAutoRetriesNextServer=1 # 開(kāi)啟重試 ribbon.OkToRetryOnAllOperations=true
Spring-cloud中的zuul網(wǎng)關(guān)重試機(jī)制是使用spring-retry實(shí)現(xiàn)的。
工程必須依賴(lài)下述資源:
<dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> </dependency>
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
java+jsp+struts2實(shí)現(xiàn)發(fā)送郵件功能
這篇文章主要為大家詳細(xì)介紹了java+jsp+struts2實(shí)現(xiàn)發(fā)送郵件功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-03-03Java 凍結(jié)或解除凍結(jié)Excel中的行和列的方法
這篇文章主要介紹了Java 凍結(jié)或解除凍結(jié)Excel中的行和列的方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-03-03Java異常javax.net.ssl.SSLHandshakeException: SSL的解決方法
在Java開(kāi)發(fā)過(guò)程中,SSL(Secure Sockets Layer)握手異常是一個(gè)常見(jiàn)的網(wǎng)絡(luò)通信錯(cuò)誤,特別是在使用HTTPS協(xié)議進(jìn)行安全通信時(shí),本文將詳細(xì)分析javax.net.ssl.SSLHandshakeException: SSL這一異常的背景、可能的原因,并通過(guò)代碼示例幫助您理解和解決這一問(wèn)題2024-12-12Java實(shí)現(xiàn)的圖片高質(zhì)量縮放類(lèi)定義與用法示例
這篇文章主要介紹了Java實(shí)現(xiàn)的圖片高質(zhì)量縮放類(lèi)定義與用法,涉及java針對(duì)圖片的運(yùn)算與轉(zhuǎn)換等相關(guān)操作技巧,需要的朋友可以參考下2017-11-11SpringBoot+devtools實(shí)現(xiàn)熱部署的示例代碼
在軟件項(xiàng)目的開(kāi)發(fā)過(guò)程中,不可避免的會(huì)經(jīng)常修改代碼,每次修改代碼,都需要手動(dòng)停止然后再啟動(dòng)服務(wù),最后驗(yàn)證代碼的正確性,今天通過(guò)這篇文章,我們一起來(lái)學(xué)習(xí)一下如何使用Spring?Boot?+?devtools?輕松搞定熱部署,需要的朋友可以參考下2024-08-08詳解Spring Cloud Eureka多網(wǎng)卡配置總結(jié)
本篇文章主要介紹了詳解Spring Cloud Eureka多網(wǎng)卡配置總結(jié),小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-04-04