Zuul微服务网关、容错与监控、Zuul路由端点、路由配置、Zuul上传文件、Zuul过滤器、Zuul异常处理、Zuul回退、Zuul聚合微服务
一、為什么要使用微服務(wù)網(wǎng)關(guān)
二、Zuul
1、編寫Zuul微服務(wù)網(wǎng)關(guān)
2、Zuul的Hystrix容錯(cuò)與監(jiān)控
3、Zuul的路由端點(diǎn)
4、路由配置
1.自定義指定微服務(wù)的訪問路徑
2.忽略指定微服務(wù)
3.忽略所有微服務(wù)，只路由指定微服務(wù)
4.同時(shí)指定微服務(wù)的serviceId和對應(yīng)路徑
5.同時(shí)指定path和URL
6.使用正則表達(dá)式指定Zuul的路由匹配規(guī)則
7.路由前綴
8.忽略某些路徑
5、Zuul的安全與Header
1.指定敏感Header
2.忽略Header
6、Zuul上傳文件
7、Zuul過濾器
1.編寫Zuul過濾器
2.Zuul異常處理過濾器
3.Zuul默認(rèn)過濾器
8、Zuul回退
9、Zuul聚合微服務(wù)
一、為什么要使用微服務(wù)網(wǎng)關(guān)
不同的微服務(wù)一般會經(jīng)過不同的網(wǎng)絡(luò)地址，而外部客戶端可能需要調(diào)用多個(gè)服務(wù)的接口才能完成一個(gè)業(yè)務(wù)需求。
如果讓客戶端直接與各個(gè)微服務(wù)通信，會有以下的問題：
- 客戶端會多次請求不同的微服務(wù)，增加了客戶端的復(fù)雜性。
- 存在跨域請求，在一定場景下處理相對復(fù)雜。
- 認(rèn)證復(fù)雜，每個(gè)服務(wù)都需要獨(dú)立認(rèn)證。
- 難以重構(gòu)，隨著項(xiàng)目的迭代，可能需要重新劃分微服務(wù)。例如，可能將多個(gè)服務(wù)整個(gè)成一個(gè)或者將一個(gè)服務(wù)拆分成多個(gè)。如果客戶端直接與微服務(wù)通信，那么重構(gòu)將會很難實(shí)施。
- 某些微服務(wù)可能使用了防火墻/瀏覽器不友好協(xié)議，直接訪問會有一定的困難。
以上問題可借助微服務(wù)網(wǎng)管解決。微服務(wù)網(wǎng)關(guān)是介于客戶端和服務(wù)器之間的中間層，所有外部請求都會先經(jīng)過微服務(wù)網(wǎng)關(guān)。使用微服務(wù)網(wǎng)關(guān)后架構(gòu)演變?yōu)橄聢D。
如圖，微服務(wù)網(wǎng)關(guān)封裝了應(yīng)用程序的內(nèi)部結(jié)構(gòu)，客戶端只需跟網(wǎng)關(guān)交互，而無需直接調(diào)用特定微服務(wù)的接口。這樣，開發(fā)就可以簡化。不僅如此，使用微服務(wù)網(wǎng)關(guān)還有以下優(yōu)點(diǎn)：
- 易于監(jiān)控。可在微服務(wù)網(wǎng)關(guān)收集監(jiān)控?cái)?shù)據(jù)并將其推送到外部系統(tǒng)進(jìn)行分析。
- 易于認(rèn)證。可在微服務(wù)網(wǎng)關(guān)上進(jìn)行認(rèn)證，然后再將請求轉(zhuǎn)發(fā)到后端的微服務(wù)，而無需再每個(gè)微服務(wù)中進(jìn)行認(rèn)證。
- 減少了客戶端與各個(gè)微服務(wù)之間的交互次數(shù)。
二、Zuul
Zuul是Netflix開源的微服務(wù)網(wǎng)關(guān)，核心是一系列的過濾器，這些過濾器可以完成以下功能。
- 身份認(rèn)證與安全：識別每個(gè)資源的驗(yàn)證需求，并拒絕那些與要求不符的請求。
- 審查與監(jiān)控：在邊緣位置追蹤有意義的數(shù)據(jù)和統(tǒng)計(jì)結(jié)果，從而帶來精確的生產(chǎn)視圖。
- 動態(tài)路由：動態(tài)地請求路由到不同的后端集群。
- 壓力測試：逐漸增加執(zhí)行集群的流量，以了解性能。
- 負(fù)載分配：為每一種負(fù)載類型分配對應(yīng)容量，并棄用超出限定值的請求。
- 靜態(tài)響應(yīng)處理：在邊緣位置直接建立部分響應(yīng)，從而避免其轉(zhuǎn)發(fā)到內(nèi)部集群。
- 多區(qū)域彈性：跨越AWS Region進(jìn)行請求路由，旨在實(shí)現(xiàn)ELB（Elastic Load Balancing）使用多樣化，以及讓系統(tǒng)的邊緣更貼近系統(tǒng)的使用者。
1、編寫Zuul微服務(wù)網(wǎng)關(guān)
1.創(chuàng)建項(xiàng)目gateway-zuul
以下是pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.6.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><groupId>com.springclouddemo</groupId><artifactId>gateway-zuul</artifactId><version>0.0.1-SNAPSHOT</version><name>gateway-zuul</name><description>微服務(wù)網(wǎng)關(guān)</description><properties><java.version>1.8</java.version><spring-cloud.version>Greenwich.SR1</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-zuul</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>2.編寫application配置文件
spring.application.name=gateway-zuul server.port=7400 eureka.client.service-url.defaultZone=http://localhost:7000/eureka/ eureka.instance.prefer-ip-address=true3.在main類添加@EnableZuulProxy注解
package com.springclouddemo.gatewayzuul;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.zuul.EnableZuulProxy;/*** @author 何昌杰*/ @SpringBootApplication @EnableZuulProxy public class GatewayZuulApplication {public static void main(String[] args) {SpringApplication.run(GatewayZuulApplication.class, args);}}這樣一個(gè)簡單的微服務(wù)網(wǎng)關(guān)就搭建成功了，并且將這個(gè)微服務(wù)注冊到Eureka Server上。
測試：
默認(rèn)情況下Zuul會代理所有注冊到Eureka Server的微服務(wù)，并且Zuul的路由規(guī)則是：http://ZUUL_HOST:ZUUL_PORT/微服務(wù)名稱/**會轉(zhuǎn)發(fā)到對應(yīng)的微服務(wù)上。
2、Zuul的Hystrix容錯(cuò)與監(jiān)控
Zuul是默認(rèn)繼承了負(fù)載均衡和熔斷的，負(fù)載均衡無需任何操作，Greenwich版本的Hystrix需要添加@Bean配置路徑才可以訪問/hystrix.stream
將項(xiàng)目gateway-zuul的main類修改如下：
package com.springclouddemo.gatewayzuul;import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.cloud.netflix.zuul.EnableZuulProxy; import org.springframework.context.annotation.Bean;/*** @author 何昌杰*/ @SpringBootApplication @EnableZuulProxy public class GatewayZuulApplication {public static void main(String[] args) {SpringApplication.run(GatewayZuulApplication.class, args);}@Beanpublic ServletRegistrationBean getServlet() {HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);registrationBean.setLoadOnStartup(1);registrationBean.addUrlMappings("/hystrix.stream");registrationBean.setName("HystrixMetricsStreamServlet");return registrationBean;} }測試：
說明Zuul已經(jīng)整合了Hystrix（默認(rèn)整合）。
3、Zuul的路由端點(diǎn)
當(dāng)@EnableZuulProxy與Spring Boot Actuator配合使用時(shí)，Zuul會暴露一個(gè)路由管理端點(diǎn)/actuator/routes（低版本為/routes端點(diǎn)）。借助這個(gè)端點(diǎn)，可以方便、直觀地查看以及管理Zuul的路由。
/actuator/routes端點(diǎn)的使用非常簡單，使用GET方法訪問端點(diǎn)，即可以返回Zuul當(dāng)時(shí)映射的路由列表；使用POST方式訪問該端點(diǎn)就會強(qiáng)制刷新Zuul當(dāng)時(shí)映射的路由列表（盡管路由會自動刷新，Spring Cloud依然提供了強(qiáng)制立即刷新的方式）。
由于spring-cloud-starter-netflix-zuul已經(jīng)包含了spring-boot-starter-actuator，因此之前編寫的gateway-zuul項(xiàng)目已經(jīng)具備路由管理的能力，不過需要在application配置文件中添加以下配置。
management.endpoints.web.exposure.include=routes訪問http://localhost:7400/actuator/routes，可以看到以下內(nèi)容：
4、路由配置
某些場景寫我們只想讓Zuul代理部分微服務(wù)，或者需要對URL進(jìn)行更加精確的控制。
1.自定義指定微服務(wù)的訪問路徑
配置zuul.routes，指定微服務(wù)的serviceId=指定路徑 即可：
zuul.routes.eureka-client-consumer-feign=/feign/**這樣配置，eureka-client-consumer-feign微服務(wù)就會被映射到/feign/**路徑。
2.忽略指定微服務(wù)
zuul.ignored-services=eureka-client-provider,eureka-client-consumer-feign這樣配置，Zuul就會忽略eureka-client-provider,eureka-client-consumer-feign微服務(wù)，只代理其他微服務(wù)。
3.忽略所有微服務(wù)，只路由指定微服務(wù)
某些場景下我們只想讓Zuul代理指定微服務(wù)：
zuul.ignored-services='*' zuul.routes.eureka-client-consumer-feign=/feign/**這樣配置，Zuul就會只路由eureka-client-consumer-feign這個(gè)微服務(wù)。
4.同時(shí)指定微服務(wù)的serviceId和對應(yīng)路徑
zuul.routes.feign.service-id=eureka-client-consumer-feign zuul.routes.feign.path=/feign/**- zuul.routes.feign.***的feign只是一個(gè)路由名稱，可以任意修改名稱
5.同時(shí)指定path和URL
zuul.routes.feign.service-id=http://localhost:7204/ zuul.routes.feign.path=/feign/**-
zuul.routes.feign.***的feign只是一個(gè)路由名稱，可以任意修改名稱
6.使用正則表達(dá)式指定Zuul的路由匹配規(guī)則
借助PatternServiceRouteMapper，實(shí)現(xiàn)微服務(wù)的映射路由的正則配置：
package com.springclouddemo.gatewayzuul;import com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.cloud.netflix.zuul.EnableZuulProxy; import org.springframework.cloud.netflix.zuul.filters.discovery.PatternServiceRouteMapper; import org.springframework.context.annotation.Bean;/*** @author 何昌杰*/ @SpringBootApplication @EnableZuulProxy public class GatewayZuulApplication {public static void main(String[] args) {SpringApplication.run(GatewayZuulApplication.class, args);}@Beanpublic ServletRegistrationBean getServlet() {HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);registrationBean.setLoadOnStartup(1);registrationBean.addUrlMappings("/hystrix.stream");registrationBean.setName("HystrixMetricsStreamServlet");return registrationBean;}@Beanpublic PatternServiceRouteMapper serviceRouteMapper(){return new PatternServiceRouteMapper("(?<name>^.+)-(?<version>.+$)","${version}/${name}");} }通過上述配置可以實(shí)現(xiàn)eureka-client-consumer-feign這個(gè)微服務(wù)，映射到/feign/eureka-client-consumer/**這個(gè)路徑。
7.路由前綴
zuul.routes.eureka-client-consumer-feign.path=/feign/** zuul.routes.eureka-client-consumer-feign.strip-prefix=false這樣訪問Zuul的/hello/**路徑，請求就會被轉(zhuǎn)發(fā)到eureka-client-consumer-feign的/hello/**上。
8.忽略某些路徑
某些場景下我們想讓Zuul代理某些微服務(wù)，同時(shí)又想保護(hù)該微服務(wù)的某些敏感路徑，我們可以使用
zuul.ignored-patterns=/**/user/**這樣配置就是可以忽略微服務(wù)中所有包含/admin/的路徑
5、Zuul的安全與Header
1.指定敏感Header
一般情況下同一個(gè)系統(tǒng)的服務(wù)之間共享Header，不過應(yīng)盡量防止讓一些敏感的Header外泄。因此，在很多場景下，需要通過為路由指定一系列敏感Header列表。
zuul.routes.eureka-client-consumer-feign.path=/feign/** zuul.routes.eureka-client-consumer-feign.sensitive-headers=Cookie,Set-Cookie,Authorization這樣配置就可以為eureka-client-consumer-feign指定微服務(wù)訪問路徑和指定敏感Header
也可以全局指定敏感Header：
zuul.sensitive-headers=Cookie,Set-Cookie,Authorization2.忽略Header
可以通過zuul.ignored-headers屬性指定需要忽略的Header。
zuul.ignored-headers=Authorization這樣配置后Authorization將不會傳播到其他的微服務(wù)中。
zuul.ignored-headers的默認(rèn)值為空值，但如果Spring Security在項(xiàng)目的classpath中，那么zuul.ignored-headers的默認(rèn)值就是Pragma,Cache-Control,X-Frame-Options,X-Content-Type-Options,X-XSS-Protection,Expires。所以當(dāng)Spring Security在項(xiàng)目的classpath中，同時(shí)又需要使用下游微服務(wù)的Spriing Security的Header時(shí)，可以將zuul.ignore-security-headers設(shè)置為false。
6、Zuul上傳文件
對于大文件（10M以上）上傳，需要為上傳路徑添加/zuul前綴。也可以使用zuul.servlet-path自定義前綴。
例如假如zuul.routes.eureka-client-consumer-feign-upload=/upload/**,http://localhost/{HOST}:{PORT}/upload是微服務(wù)eureka-client-consumer-feign-upload的上傳路徑，則需要用Zuul的/zuul/upload路徑進(jìn)行上傳（添加/zuul前綴）。
如果Zuul使用了Ribbon負(fù)載均衡，name對于超大文件，需要擴(kuò)大超時(shí)設(shè)置：
（Hystrix與Ribbon的默認(rèn)請求超時(shí)時(shí)間都是1秒）
hystrix.command.connect.execution.isolation.thread.timeoutInMilliseconds=60000 ribbon.connectTimeout=3000 ribbon.readTimeout=60000還需要為提供上傳文件的微服務(wù)添加以下配置：
（max-file-size默認(rèn)1MB，max-request-size默認(rèn)10MB）
spring.servlet.multipart.max-file-size=2000MB spring.servlet.multipart.max-request-size=2500MB7、Zuul過濾器
Zuul大部分功能都是通過過濾器來實(shí)現(xiàn)的，Zuul定義了4種標(biāo)準(zhǔn)的過濾器類型，這些過濾器類型對應(yīng)于請求的典型生命周期。
- pre:?這種過濾器在請求被路由之前調(diào)用。可利用這種過濾器實(shí)現(xiàn)身份驗(yàn)證、在集群中選擇請求的微服務(wù)，記錄調(diào)試信息等。
- routing:?這種過濾器將請求路由到微服務(wù)。這種過濾器用于構(gòu)建發(fā)送給微服務(wù)的請求，并使用apache?httpclient或netflix?ribbon請求微服務(wù)。
- post:?這種過濾器在路由到微服務(wù)以后執(zhí)行。這種過濾器可用來為響應(yīng)添加標(biāo)準(zhǔn)的http header、收集統(tǒng)計(jì)信息和指標(biāo)、將響應(yīng)從微服務(wù)發(fā)送給客戶端等。
- error:?在其他階段發(fā)送錯(cuò)誤時(shí)執(zhí)行該過濾器。
除了默認(rèn)的過濾器類型，zuul還允許創(chuàng)建自定義的過濾器類型。例如，可以定制一種static類型的過濾器，直接在zuul中生成響應(yīng)，而不將請求轉(zhuǎn)發(fā)到后端的微服務(wù)。
Zuul請求的生命周期如下圖，該圖詳細(xì)描述了各種類型的過濾器的執(zhí)行順序。
也可通過查看源碼中com.netflix.zuul.http.ZuulServlet類的service了解執(zhí)行順序。
1.編寫Zuul過濾器
1.復(fù)制項(xiàng)目gateway-zuul為gateway-zuul-filter
2.端口修改為7401，微服務(wù)名修改為gateway-zuul-filter
3.編寫自定義Zuul過濾器filters/PreRequestLogFilter.java
package com.springclouddemo.gatewayzuulfilter.filters;import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component;import javax.servlet.http.HttpServletRequest;/*** @author 何昌杰*/ @Component public class PreRequestLogFilter extends ZuulFilter {private static final Logger log= LoggerFactory.getLogger(PreRequestLogFilter.class);@Overridepublic String filterType() {return "pre";}@Overridepublic int filterOrder() {return 1;}@Overridepublic boolean shouldFilter() {return true;}@Overridepublic Object run() throws ZuulException {RequestContext ctx = RequestContext.getCurrentContext();HttpServletRequest request = ctx.getRequest();log.info("send {} request to {}",request.getMethod(),request.getRequestURL());return null;} }- filterType 指定過濾器類型，對應(yīng)上文幾種過濾器
- filterOrder 指定過濾器執(zhí)行順序（默認(rèn)越小越先執(zhí)行）
- shouldFilter 是否啟用該過濾器（true為啟用，false為禁用）
- run 過濾器的具體業(yè)務(wù)邏輯
測試：
說明我們的自定義Zuul過濾器正常運(yùn)行。
2.Zuul異常處理過濾器
當(dāng)zuul通過eureka調(diào)用一個(gè)不可用、不存在、宕機(jī)了的服務(wù)時(shí)，可能就會直接返回類似于這樣的不友好的畫面：
我們可以通過編寫一個(gè)異常過濾器來處理這種情況：
package com.springclouddemo.gatewayzuulfilter.filters;import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import org.apache.http.HttpStatus; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter;/*** @author 何昌杰*/ @Component public class ErrorFilter extends ZuulFilter {private static final Logger log = LoggerFactory.getLogger(ErrorFilter.class);@Overridepublic String filterType() {return "error";}@Overridepublic int filterOrder() {return -1;}@Overridepublic boolean shouldFilter() {return true;}@Overridepublic Object run() throws ZuulException {RequestContext ctx = RequestContext.getCurrentContext();HttpServletResponse response = ctx.getResponse();response.setStatus(HttpStatus.SC_NOT_FOUND);response.setContentType("application/json;charset=UTF-8");Throwable throwable = ctx.getThrowable();try (PrintWriter writer = response.getWriter()) {writer.print("{\"resultCode\":404,\"data\":null,\"cause\":\"" + throwable.getCause() + "\",\"message\":\"路由轉(zhuǎn)發(fā)錯(cuò)誤\"}");} catch (IOException e) {log.error("系統(tǒng)異常{}", e.getMessage());}return null;} }?
測試：
說明我們的異常處理過濾器正常運(yùn)行。
3.Zuul默認(rèn)過濾器
| pre | -3 | ServletDetectionFilter | 標(biāo)記處理Servlet的類型 |
| pre | -2 | Servlet30WrapperFilter | 包裝HttpServletRequest請求 |
| pre | -1 | FormBodyWrapperFilter | 包裝請求體 |
| route | 1 | DebugFilter | 標(biāo)記調(diào)試標(biāo)志 |
| route | 5 | PreDecorationFilter | 處理請求上下文供后續(xù)使用 |
| route | 10 | RibbonRoutingFilter | serviceId請求轉(zhuǎn)發(fā) |
| route | 100 | SimpleHostRoutingFilter | url請求轉(zhuǎn)發(fā) |
| route | 500 | SendForwardFilter | forward請求轉(zhuǎn)發(fā) |
| post | 0 | SendErrorFilter | 處理有錯(cuò)誤的請求響應(yīng) |
| post | 1000 | SendResponseFilter | 處理正常的請求響應(yīng) |
8、Zuul回退
想為Zuul添加回退需要實(shí)現(xiàn)FallbakcProvider接口，指定為哪些微服務(wù)提供回退并且提供一個(gè)ClientHTTPResponse作為回退響應(yīng)。
1.復(fù)制項(xiàng)目gateway-zuul為gateway-zuul-fallback
2.端口修改為7402，微服務(wù)名修改為gateway-zuul-fallback
3.編寫Zuul的回退類
package com.springclouddemo.gatewayzuulfallback.fallbacks;import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.client.ClientHttpResponse; import org.springframework.stereotype.Component; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import java.nio.charset.Charset;/*** @author 何昌杰*/ @Component public class ProviderFallback implements FallbackProvider {@Overridepublic String getRoute() {return "*";}@Overridepublic ClientHttpResponse fallbackResponse(String route, Throwable cause) {return new ClientHttpResponse() {@Overridepublic HttpStatus getStatusCode() throws IOException {//fallback時(shí)的狀態(tài)碼return HttpStatus.OK;}@Overridepublic int getRawStatusCode() throws IOException{//數(shù)字類型的狀態(tài)碼return 200;}@Overridepublic String getStatusText() throws IOException{//狀態(tài)文本return this.getStatusCode().getReasonPhrase();}@Overridepublic void close() {}@Overridepublic InputStream getBody() throws IOException{//響應(yīng)體return new ByteArrayInputStream("此微服務(wù)不可用，請稍后重試！".getBytes());}@Overridepublic HttpHeaders getHeaders() {//響應(yīng)頭部HttpHeaders httpHeaders = new HttpHeaders();MediaType mediaType = new MediaType("application", "json", Charset.forName("UTF-8"));httpHeaders.setContentType(mediaType);return httpHeaders;}};} }- getRoute() 返回值指定微服務(wù)的serviceId,也可以是*代表所有微服務(wù)。
測試：
說明我們?yōu)閆uul添加回退成功。
9、Zuul聚合微服務(wù)
在很多次場景下，外部請求需要查詢Zuul后端的多個(gè)微服務(wù)。舉個(gè)例子，一個(gè)電影售票手機(jī)APP，在購票訂單頁上，既需要查詢“電影微服務(wù)”獲得電影相關(guān)信息，又需要查詢“用戶微服務(wù)”獲得當(dāng)前用戶的信息。如果讓手機(jī)端直接請求各個(gè)微服務(wù)（即使使用Zuul進(jìn)行轉(zhuǎn)發(fā)），那么網(wǎng)絡(luò)開銷、流量耗費(fèi)、耗費(fèi)時(shí)長可能都無法令人滿意。那么對于這種場景，可使用Zuul聚合微服務(wù)請求——手機(jī)APP只需發(fā)送一個(gè)請求給Zuul，由于Zuul請求用戶微服務(wù)以及電影微服務(wù)，并組織好數(shù)據(jù)給手機(jī)APP。
使用這種方式，手機(jī)端只須發(fā)送一次請求即可，簡化了客戶端側(cè)的開發(fā)；不僅如此，由于Zuul、用戶微服務(wù)、電影微服務(wù)一般都在同一局域網(wǎng)，因此速度非常快，效率會非常高。
下面圍繞以上這個(gè)場景，來編寫代碼。
1.復(fù)制項(xiàng)目gateway-zuul為gateway-zuul-aggregation
2.將端口修改為7403，微服務(wù)名修改為gateway-zuul-aggregation
3.修改啟動類
package com.springclouddemo.gatewayzuulaggregation;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.cloud.netflix.zuul.EnableZuulProxy; import org.springframework.context.annotation.Bean; import org.springframework.web.client.RestTemplate;/*** @author 何昌杰*/ @SpringBootApplication @EnableZuulProxy public class GatewayZuulAggregationApplication {public static void main(String[] args) {SpringApplication.run(GatewayZuulAggregationApplication.class, args);}@Bean@LoadBalancedpublic RestTemplate restTemplate(){return new RestTemplate();}}4.創(chuàng)建業(yè)務(wù)類services/AggregationService.java
package com.springclouddemo.gatewayzuulaggregation.services;import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.client.RestTemplate; import rx.Observable;/*** @author 何昌杰*/ @Service public class AggregationService {@Autowiredprivate RestTemplate restTemplate;@HystrixCommand(fallbackMethod = "fallback")public Observable<String> helloDemo1(String name) {// 創(chuàng)建一個(gè)被觀察者return Observable.create(observer -> {// 請求微服務(wù)1的/hello/{name}端點(diǎn)String res = restTemplate.getForObject("http://eureka-client-consumer-feign/hello/{name}", String.class, name);observer.onNext(res);observer.onCompleted();});}@HystrixCommand(fallbackMethod = "fallback")public Observable<String> helloDemo2(String name) {return Observable.create(syncOnSubscribe -> {// 請求微服務(wù)2的/hello/{name}端點(diǎn)String res = restTemplate.getForObject("http://eureka-client-consumer-hystrix/hello/{name}", String.class, name);syncOnSubscribe.onNext(res);syncOnSubscribe.onCompleted();});}public String fallback(String name) {return "默認(rèn)值："+name;}}5.創(chuàng)建controllers/AggregationController.java
在Controller中聚合多個(gè)請求
package com.springclouddemo.gatewayzuulaggregation.controllers;import com.google.common.collect.Maps; import com.springclouddemo.gatewayzuulaggregation.services.AggregationService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.context.request.async.DeferredResult; import rx.Observable; import rx.Observer;import java.util.HashMap;/*** @author 何昌杰*/@RestController public class AggregationController {public static final Logger LOGGER = LoggerFactory.getLogger(AggregationController.class);@Autowiredprivate AggregationService aggregationService;@GetMapping("/aggregate/{name}")public DeferredResult<HashMap<String, String>> aggregate(@PathVariable String name) {Observable<HashMap<String, String>> result = this.aggregateObservable(name);return this.toDeferredResult(result);}public Observable<HashMap<String, String>> aggregateObservable(String name) {// 合并兩個(gè)或者多個(gè)Observables發(fā)射出的數(shù)據(jù)項(xiàng)，根據(jù)指定的函數(shù)變換它們r(jià)eturn Observable.zip(this.aggregationService.helloDemo1(name),this.aggregationService.helloDemo1(name),(res1, res2) -> {HashMap<String, String> map = Maps.newHashMap();map.put("microservice1", res1);map.put("microservice2", res2);return map;});}public DeferredResult<HashMap<String, String>> toDeferredResult(Observable<HashMap<String, String>> details) {DeferredResult<HashMap<String, String>> result = new DeferredResult<>();// 訂閱details.subscribe(new Observer<HashMap<String, String>>() {@Overridepublic void onCompleted() {LOGGER.info("完成...");}@Overridepublic void onError(Throwable throwable) {LOGGER.error("發(fā)生錯(cuò)誤...", throwable);}@Overridepublic void onNext(HashMap<String, String> movieDetails) {result.setResult(movieDetails);}});return result;} }?
測試：
控制臺輸出：
2019-07-11 22:56:53.639 INFO 5448 --- [nio-7403-exec-1] c.s.g.controllers.AggregationController : 完成...?
控制臺輸出：
2019-07-11 23:03:58.003 INFO 5448 --- [io-7403-exec-10] c.s.g.controllers.AggregationController : 完成...說明我們已經(jīng)成功用Zuul聚合了兩個(gè)微服務(wù)的接口。
總結(jié)
以上是生活随笔為你收集整理的Zuul微服务网关、容错与监控、Zuul路由端点、路由配置、Zuul上传文件、Zuul过滤器、Zuul异常处理、Zuul回退、Zuul聚合微服务的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： git rebase 的几种用法
- 下一篇： 问卷星简单自动填写调查问卷