本篇內(nèi)容介紹了“如何理解Spring Cloud網(wǎng)關(guān)服務(wù)zuul ”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！
十余年的望江網(wǎng)站建設(shè)經(jīng)驗(yàn)，針對(duì)設(shè)計(jì)、前端、開(kāi)發(fā)、售后、文案、推廣等六對(duì)一服務(wù)，響應(yīng)快，48小時(shí)及時(shí)工作處理。成都營(yíng)銷網(wǎng)站建設(shè)的優(yōu)勢(shì)是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同，自動(dòng)調(diào)整望江建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無(wú)論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì)，從而大程度地提升瀏覽體驗(yàn)。創(chuàng)新互聯(lián)從事“望江網(wǎng)站設(shè)計(jì)”,“望江網(wǎng)站推廣”以來(lái)，每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。
可以看到服務(wù)端口和注冊(cè)中心都在配置文件中配置化
上一篇我們講了如何搭建網(wǎng)關(guān)zuul 服務(wù)。實(shí)現(xiàn)了基本的轉(zhuǎn)發(fā)功能。這篇文章我們要講述zuul過(guò)濾器的使用。和三個(gè)參數(shù)的使用
ribbon-isolation-strategy
信號(hào)量模式 在該模式下，接收請(qǐng)求和執(zhí)行下游依賴在同一個(gè)線程內(nèi)完成，不存在線程上下文切換所帶來(lái)的性能開(kāi)銷。默認(rèn)信號(hào)量模式
線程池 在該模式下，用戶請(qǐng)求會(huì)被提交到各自的線程池中執(zhí)行，把執(zhí)行每個(gè)下游服務(wù)的線程分離，從而達(dá)到資源隔離的作用。當(dāng)線程池來(lái)不及處理并且請(qǐng)求隊(duì)列塞滿時(shí)，新進(jìn)來(lái)的請(qǐng)求將快速失敗，可以避免依賴問(wèn)題擴(kuò)散。
隔離機(jī)制 Spring Cloud 默認(rèn)的隔離機(jī)制hystrix 去做限流、熔斷、隔離。一個(gè)是基于信號(hào)量。一個(gè)是基于線程池去完成
ignored-services
忽略指定的服務(wù)
ignored—patterns
忽略指定的url 路徑
ignored-headers
忽略指定的header 頭部信息
sensitiveHeaders
字段比較敏感，不希望傳遞給下游微服務(wù)。 設(shè)置空沒(méi)有要忽略的敏感字段。全部傳給下游服務(wù)
在上面ignored-headers 和 sensitiveHeaders 職責(zé)是有重疊的部分。其實(shí)他們是有著關(guān)系存在的。sensitiveHeaders的內(nèi)容會(huì)最終合并到ignored-headers內(nèi)。
驗(yàn)證一下 sensitiveHeaders 字段設(shè)置全區(qū)忽略 X-ABC
消費(fèi)者服務(wù) sensitiveHeaders 指定忽略 X-ABC,Authorization
服務(wù)提供者轉(zhuǎn)發(fā)不做任何調(diào)整 在服務(wù)提供者 和 服務(wù)消費(fèi)者 服務(wù)上。都創(chuàng)建一個(gè) UrlFilter 攔截器 先設(shè)置一下 zuul的yml文件
zuul: host: # 目標(biāo)主機(jī)的最大連接數(shù)，默認(rèn)值為200 max-total-connections: 500 # 每個(gè)主機(jī)的初始連接數(shù)，默認(rèn)值為20 max-per-route-connections: 100 routes: discovery-server: path: /server/** serviceId: cloud-discovery-server client-common: path: /client/** serviceId: cloud-discovery-client sensitiveHeaders: X-ABC,X-Foo # 所有路由的默認(rèn)Hystrix隔離模式（ExecutionIsolationStrategy）為SEMAPHORE。如果此隔離模式是首選，則zuul.ribbonIsolationStrategy可以更改為T(mén)HREAD ribbon-isolation-strategy: thread # 這個(gè)屬性意思，* 忽略未指定的服務(wù)列表 有具體服務(wù)名稱 忽略指定的服務(wù) ignored-services: "*" # 忽略指定的url 路徑 ignored—patterns: # 忽略指定的header 頭部信息 ignored-headers: Authorization # 字段比較敏感，不希望傳遞給下游微服務(wù)。 設(shè)置空沒(méi)有要忽略的敏感字段。全部傳給下游服務(wù) sensitive-headers: X-ABC ribbon: eager-load: # 強(qiáng)制加載，不設(shè)置會(huì)進(jìn)行懶加載。spring 第一次請(qǐng)求會(huì)非常慢 enabled: true
package com.xian.cloud.filter; import lombok.extern.slf4j.Slf4j; import javax.servlet.*; import javax.servlet.annotation.WebFilter; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.util.Enumeration; /** ** * @author xianliru@100tal.com * @version 1.0 * @createDate 2019/10/29 13:57 */ @WebFilter(filterName = "test",urlPatterns = "/*") @Slf4j public class UrlFilter implements Filter { @Override public void init(FilterConfig filterConfig) throws ServletException { log.warn("UrlFilter init......."); } @Override public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException { Enumeration attributeNames = servletRequest.getAttributeNames(); HttpServletRequest req = (HttpServletRequest) servletRequest; String requestURI = req.getRequestURI(); String header = req.getHeader("X-Foo"); String abc = req.getHeader("X-ABC"); String authorization = req.getHeader("Authorization"); String tom = req.getParameter("tom"); String mike = req.getParameter("mike"); log.warn("過(guò)濾器：請(qǐng)求地址"+requestURI); log.warn("uuid:{}",header); log.warn("abc uuid:{}",abc); log.warn("authorization :{}",authorization); log.warn("tom :{}",tom); log.warn("mike :{}",mike); filterChain.doFilter(servletRequest, servletResponse); } @Override public void destroy() { log.warn(" 過(guò)濾器被銷毀"); } }
啟動(dòng)類上添加 @ServletComponentScan 用于掃描 過(guò)濾器 @WebFilter注解
重慶分公司
重慶分公司
package com.xian.cloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
/**
* @Author: xlr
* @Date: Created in 2:44 PM 2019/10/27
*/
@EnableDiscoveryClient
@SpringBootApplication
//新增注解
@ServletComponentScan
public class DiscoveryServerApplication {
public static void main(String[] args) {
SpringApplication.run(DiscoveryServerApplication.class, args);
}
}使用postman 請(qǐng)求服務(wù) 服務(wù)端打印日志
2019-10-30 11:10:35.822 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : 過(guò)濾器：請(qǐng)求地址/server/hello 2019-10-30 11:10:35.826 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : uuid:x-foo 2019-10-30 11:10:35.826 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : abc uuid:null 2019-10-30 11:10:35.827 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : authorization :null 2019-10-30 11:10:35.827 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : tom :null 2019-10-30 11:10:35.828 WARN 48882 --- [nio-9012-exec-8] com.xian.cloud.filter.UrlFilter : mike :null 2019-10-30 11:10:35.852 INFO 48882 --- [nio-9012-exec-8] c.x.cloud.controller.DiscoverCotroller : invoked name = xian age = 20
sensitive-headers、ignored-headers (abc、authorization都在zuul被過(guò)濾掉)全局設(shè)置生效。
我們?cè)俅握?qǐng)求client 服務(wù)接口
在看一下 客戶端打印日志
2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : 過(guò)濾器：請(qǐng)求地址/client/test 2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : uuid:null 2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : abc uuid:null 2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : authorization :null 2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : tom :null 2019-10-30 11:17:05.813 WARN 50223 --- [nio-9011-exec-3] com.xian.cloud.filter.UrlFilter : mike :null
全局設(shè)置，和單個(gè)服務(wù)定制設(shè)置 全部生效。
spring cloud Zuul包含了對(duì)請(qǐng)求的路由和過(guò)濾2個(gè)功能。路由功能負(fù)責(zé)將請(qǐng)求轉(zhuǎn)發(fā)到具體的微服務(wù)上，而過(guò)濾器負(fù)責(zé)對(duì)請(qǐng)求的處理過(guò)程進(jìn)行干預(yù)，是實(shí)現(xiàn)權(quán)限校驗(yàn)、服務(wù)聚合等功能的基礎(chǔ)。
在實(shí)際運(yùn)行時(shí)，路由映射和請(qǐng)求轉(zhuǎn)發(fā)是由幾個(gè)不同的過(guò)濾器完成的。每一個(gè)進(jìn)入zuul的http請(qǐng)求都會(huì)經(jīng)過(guò)一系列的過(guò)濾器處理鏈得到請(qǐng)求響應(yīng)并返回給客戶端。
zuul1.0 對(duì)流量的路由分發(fā)和過(guò)濾倆個(gè)功能。路由讓流量分發(fā)到內(nèi)部的微服務(wù)集群上。過(guò)濾對(duì)請(qǐng)求進(jìn)行修改或者做個(gè)性化處理。實(shí)現(xiàn)鑒權(quán)、安全、監(jiān)控、日志等。
運(yùn)行過(guò)程中，流量請(qǐng)求會(huì)經(jīng)過(guò)一系列的過(guò)濾器最終轉(zhuǎn)發(fā)到對(duì)應(yīng)的服務(wù)上去。
zuul 路由器主要根絕FilterType類型分為四種類型。一個(gè)靜態(tài)響應(yīng)StaticResponseFilter
pre 在請(qǐng)求被路由之前調(diào)用。對(duì)應(yīng)spring boot 工程Filer 中的 doFilter 方法。
route 用于路由到原點(diǎn)，使用http 協(xié)議調(diào)用?？梢岳斫庳?fù)責(zé)轉(zhuǎn)發(fā)請(qǐng)求到微服務(wù)
error 錯(cuò)誤處理，在處理請(qǐng)求發(fā)生錯(cuò)誤時(shí)被調(diào)用
post 用于后路由過(guò)濾，在route和error過(guò)濾器之后被調(diào)用
FilterTypeEnum 枚舉類
package com.xian.cloud.enums; import lombok.Getter; /** ** * @author xianliru@100tal.com * @version 1.0 * @createDate 2019/10/29 13:01 */ @Getter public enum FilterTypeEnum { PRE("pre","前置過(guò)濾"), ROUTE("route","路由請(qǐng)求時(shí)被調(diào)用"), POST("post","后置過(guò)濾器"), ERROR("error","后置錯(cuò)誤處理"); private String type; private String desc; FilterTypeEnum(String type,String desc){ this.type = type; this.desc = desc; } }
過(guò)濾器代碼編寫(xiě)
package com.xian.cloud.filter; import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.exception.ZuulException; import com.xian.cloud.enums.FilterTypeEnum; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Component; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.util.ArrayList; import java.util.List; import java.util.UUID; /** ** * @author xianliru@100tal.com * @version 1.0 * @createDate 2019/10/29 12:57 */ @Component @Slf4j public class BannedAccessFilter extends ZuulFilter { /** * 路由器的類型指定 * @return */ @Override public String filterType() { return FilterTypeEnum.PRE.getType(); } /** * 執(zhí)行順序 數(shù)值越小。執(zhí)行順序越靠前 * @return */ @Override public int filterOrder() { return 0; } /** * 返回一個(gè)boolean值來(lái)判斷該過(guò)濾器是否要執(zhí)行。我們可以通過(guò)此方法來(lái)指定過(guò)濾器的有效范圍。 * @return */ @Override public boolean shouldFilter() { RequestContext context = RequestContext.getCurrentContext(); HttpServletRequest request = context.getRequest(); String requestURI = request.getRequestURI(); if(StringUtils.isNotBlank(requestURI) && (requestURI.contains("client") || requestURI.contains("server"))){ return true; } return false; } /** * 核心業(yè)務(wù)處理 * @return * @throws ZuulException */ @Override public Object run() throws ZuulException { RequestContext context = RequestContext.getCurrentContext(); HttpServletResponse servletResponse = context.getResponse(); String uuid = UUID.randomUUID().toString(); //重寫(xiě) X-Foo X-ABC值 context.addZuulRequestHeader("X-Foo", uuid); context.addZuulRequestHeader("X-ABC",uuid); log.info("X-Foo:{}",uuid); return null; } }
run方法是核心業(yè)務(wù)處理的方法 postman 請(qǐng)求 http://127.0.0.1:9083/server/server/hello?name=1111 攜帶之前設(shè)置的header參數(shù) 
服務(wù)器打印日志
2019-10-30 14:44:44.841 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : 過(guò)濾器：請(qǐng)求地址/server/hello 2019-10-30 14:44:44.842 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : uuid:a65b2244-e9a5-456d-968f-eaaba45b6f49 2019-10-30 14:44:44.842 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : abc uuid:null 2019-10-30 14:44:44.842 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : authorization :null 2019-10-30 14:44:44.842 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : tom :null 2019-10-30 14:44:44.842 WARN 48882 --- [nio-9012-exec-9] com.xian.cloud.filter.UrlFilter : mike :null 2019-10-30 14:44:44.844 INFO 48882 --- [nio-9012-exec-9] c.x.cloud.controller.DiscoverCotroller : invoked name = 1111 age = 20
可以看到 postman設(shè)置的X-Foo 值被 BannedAccessFilter run方法業(yè)務(wù)覆蓋掉了
攔截的請(qǐng)求對(duì)參數(shù)的修改操作都是在這里。這里單獨(dú)介紹一下 RequestContext 這個(gè)類
官方文檔描述
To pass information between filters, Zuul uses a RequestContext. Its data is held in a ThreadLocal specific to each request. Information about where to route requests, errors and the actual HttpServletRequest and HttpServletResponse are stored there. The RequestContext extends ConcurrentHashMap, so anything can be stored in the context. FilterConstants contains the keys that are used by the filters installed by Spring Cloud Netflix (more on these later).
請(qǐng)求要在過(guò)濾器之間傳遞信息，Zuul使用 RequestContext。其數(shù)據(jù)按照每個(gè)請(qǐng)求的ThreadLocal進(jìn)行。關(guān)于路由請(qǐng)求，錯(cuò)誤以及實(shí)際HttpServletRequest和HttpServletResponse的路由信息。RequestContext擴(kuò)展ConcurrentHashMap，所以任何東西都可以存儲(chǔ)在上下文中。
ThreadLocal保證了請(qǐng)求與請(qǐng)求都是獨(dú)立的，相互不影響。擴(kuò)展ConcurrentHashMap 保證內(nèi)部過(guò)濾器并發(fā)操作的安全性。
需要注意點(diǎn) 都在代碼注釋上描述出來(lái)了。請(qǐng)根據(jù)自己的業(yè)務(wù)場(chǎng)景定制自己的過(guò)濾器。
