springboot zuul實(shí)現(xiàn)網(wǎng)關(guān)的代碼
網(wǎng)關(guān)在微服務(wù)里的角色
在微服務(wù)架構(gòu)體系里,網(wǎng)關(guān)是非常重要的一個(gè)環(huán)節(jié),它主要實(shí)現(xiàn)了一些功能的統(tǒng)一處理,包括了:
- 統(tǒng)一授權(quán)
- 統(tǒng)一異常處理
- 路由導(dǎo)向
- 跨域處理
- 限流
實(shí)踐一下
1 添加依賴
dependencies { implementation('org.springframework.cloud:spring-cloud-starter-netflix-eureka-client') implementation('org.springframework.cloud:spring-cloud-starter-netflix-zuul') testImplementation('org.springframework.boot:spring-boot-starter-test') implementation('com.marcosbarbero.cloud:spring-cloud-zuul-ratelimit:1.3.2.RELEASE') }
2 添加yml
server: port: 8300 spring: application: name: microservice-gateway-zuul eureka: client: register-with-eureka: true fetch-registry: true service-url: defaultZone: http://localhost:6761/eureka instance: ip-address: true zuul: routes: users: path: /lind/** #以lind開(kāi)頭的路徑被重定向到lind服務(wù) serviceId: lind add-host-header: true #顯示真實(shí)的http頭 retryable: false #關(guān)閉Hystrix的重試功能 ratelimit: enabled: true # repository: REDIS behind-proxy: true policies: users: limit: 5 #限流,每分鐘請(qǐng)求5次 refresh-interval: 60 type: - user - origin - url # url類型的限流就是通過(guò)請(qǐng)求路徑區(qū)分 # origin是通過(guò)客戶端IP地址區(qū)分 # user是通過(guò)授權(quán)用戶進(jìn)行區(qū)分,也包括匿名用戶
3 添加實(shí)現(xiàn)代碼
http攔截器,獲取用戶ID,為子服務(wù)進(jìn)行傳遞
public class PreRequestLogFilter extends ZuulFilter { private static final Logger logger = LoggerFactory.getLogger(PreRequestLogFilter.class); private final RateLimiter rateLimiter = RateLimiter.create(1000.0); @Override public Object run() { try { RequestContext currentContext = RequestContext.getCurrentContext(); HttpServletResponse response = currentContext.getResponse(); HttpServletRequest reqeust = currentContext.getRequest(); currentContext.addZuulRequestHeader("userId","123");//向子系統(tǒng)http頭寫(xiě)數(shù)據(jù) currentContext.addZuulRequestHeader("userName","test"); PreRequestLogFilter.logger.info( String.format("send %s request to %s", reqeust.getMethod(), reqeust.getRequestURL().toString())); if (!rateLimiter.tryAcquire()) { HttpStatus httpStatus = HttpStatus.TOO_MANY_REQUESTS; response.setContentType(MediaType.TEXT_PLAIN_VALUE); response.setStatus(httpStatus.value()); response.getWriter().append(httpStatus.getReasonPhrase()); currentContext.setSendZuulResponse(false); throw new ZuulException( httpStatus.getReasonPhrase(), httpStatus.value(), httpStatus.getReasonPhrase() ); } } catch (java.lang.Exception e) { ReflectionUtils.rethrowRuntimeException(e); } return null; } @Override public boolean shouldFilter() { // 判斷是否需要過(guò)濾 return true; } @Override public String filterType() { return FilterConstants.PRE_TYPE; } @Override public int filterOrder() { return Ordered.HIGHEST_PRECEDENCE; } }
在主程中注入這個(gè)過(guò)濾器
@Bean public PreRequestLogFilter preRequestLogFilter() { return new PreRequestLogFilter(); }
4 使用它
在URL上通過(guò)localhost:8300/users/home
將進(jìn)行l(wèi)ind服務(wù)里的home控制器下,并在http頭上寫(xiě)入了userid和username這個(gè)鍵值對(duì)!
總結(jié)
以上所述是小編給大家介紹的springboot zuul實(shí)現(xiàn)網(wǎng)關(guān),希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
相關(guān)文章
java JSON解析庫(kù)Alibaba Fastjson用法詳解
這篇文章主要介紹了java JSON解析庫(kù)Alibaba Fastjson用法,結(jié)合實(shí)例形式詳細(xì)分析了java JSON解析庫(kù)Alibaba Fastjson的基本功能、原理、用法及操作注意事項(xiàng),需要的朋友可以參考下2020-04-04解決IDEA JSP沒(méi)有代碼提示問(wèn)題的幾種方法
這篇文章主要介紹了解決IDEA JSP沒(méi)有代碼提示問(wèn)題的幾種方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-10-10SpringBoot2.x配置HTTPS訪問(wèn)的過(guò)程
這篇文章主要介紹了SpringBoot2.x配置HTTPS訪問(wèn)的過(guò)程,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-07-07Java基于解釋器模式實(shí)現(xiàn)定義一種簡(jiǎn)單的語(yǔ)言功能示例
這篇文章主要介紹了Java基于解釋器模式實(shí)現(xiàn)定義一種簡(jiǎn)單的語(yǔ)言功能,簡(jiǎn)單描述了解釋器模式的概念、功能及Java使用解釋器模式定義一種簡(jiǎn)單語(yǔ)言的相關(guān)實(shí)現(xiàn)與使用技巧,需要的朋友可以參考下2018-05-05mybatis初始化SqlSessionFactory失敗的幾個(gè)原因分析
這篇文章主要介紹了mybatis初始化SqlSessionFactory失敗的幾個(gè)原因分析,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12MybatisPlus調(diào)用原生SQL的實(shí)現(xiàn)方法
本文主要介紹了MybatisPlus調(diào)用原生SQL的實(shí)現(xiàn)方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02Springboot基于assembly的服務(wù)化打包方案及spring boot部署方式
這篇文章主要介紹了Springboot基于assembly的服務(wù)化打包方案及springboot項(xiàng)目的幾種常見(jiàn)的部署方式,本文主要針對(duì)第二種部署方式提供一種更加友好的打包方案,需要的朋友可以參考下2017-12-12在SpringBoot項(xiàng)目中整合攔截器的詳細(xì)步驟
在系統(tǒng)中經(jīng)常需要在處理用戶請(qǐng)求之前和之后執(zhí)行一些行為,例如檢測(cè)用戶的權(quán)限,或者將請(qǐng)求的信息記錄到日志中,即平時(shí)所說(shuō)的"權(quán)限檢測(cè)"及"日志記錄",下面這篇文章主要給大家介紹了關(guān)于在SpringBoot項(xiàng)目中整合攔截器的相關(guān)資料,需要的朋友可以參考下2022-09-09java反射拼接方法名動(dòng)態(tài)執(zhí)行方法實(shí)例
下面小編就為大家?guī)?lái)一篇java反射拼接方法名動(dòng)態(tài)執(zhí)行方法實(shí)例。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-08-08