zuul集成Eureka

通過剛才的示例，我們已經(jīng)可以簡單地使用 Zuul 進(jìn)行路由的轉(zhuǎn)發(fā)了，在實(shí)際使用中我們通常是用 Zuul 來代理請(qǐng)求轉(zhuǎn)發(fā)到內(nèi)部的服務(wù)上去，統(tǒng)一為外部提供服務(wù)。內(nèi)部服務(wù)的數(shù)量會(huì)很多，而且可以隨時(shí)擴(kuò)展，我們不可能每增加一個(gè)服務(wù)就改一次路由的配置，所以也得通過結(jié)合 Eureka 來實(shí)現(xiàn)動(dòng)態(tài)的路由轉(zhuǎn)發(fā)功能。首先需要添加 Eureka 的依賴，代碼如下所示。

<dependency>
 <groupId>org.springframework.cloud</groupId > 
 <artifactId>spring-cloud- starter-netflix-eureka-client</artifactId> 
 <version>2.2.9.RELEASE</version> 
 </dependency>

說明：這里的eureka-client版本要使用2.2.9.RELEASE,否則會(huì)報(bào)錯(cuò)！

啟動(dòng)類不需要修改，因?yàn)?@EnableZuulProxy 已經(jīng)自帶了 @EnableDiscoveryClient。只需要在配置文件中增加Eureka 的地址即可：

eureka:
 client:
  service-url:
   defaultZone: http://admin:1357@localhost:8761/eureka

重啟服務(wù)，我們可以通過默認(rèn)的轉(zhuǎn)發(fā)規(guī)則來訪問 Eureka中的服務(wù)。訪問規(guī)則是“網(wǎng)關(guān)服務(wù)地址+訪問的服務(wù)名稱+接口 URI”。

如上面的訪問改為： http://localhost:7000/ws-user-server/user/23

Zuul路由配置

當(dāng) Zuul 集成 Eureka 之后，其實(shí)就可以為 Eureka 中所有的服務(wù)進(jìn)行路由操作了，默認(rèn)的轉(zhuǎn)發(fā)規(guī)則就是“網(wǎng)關(guān) 服務(wù)地址+訪問的服務(wù)名稱+接口 URI”。在給服務(wù)指定名稱的時(shí)候，應(yīng)盡量短一點(diǎn)，這樣的話我們就可以用默認(rèn)的路由規(guī)則進(jìn)行請(qǐng)求，不需要為每個(gè)服務(wù)都定一個(gè)路由規(guī)則，這樣就算新增了服務(wù)，API 網(wǎng)關(guān)也不用修改和重啟了。

1. 指定具體服務(wù)路由

我們可以為每一個(gè)服務(wù)都配置一個(gè)路由轉(zhuǎn)發(fā)規(guī)則：

zuul:
 routes: #路由轉(zhuǎn)發(fā)
  ws-user-server:
   path: /api-user/**

上述代碼將ws-user-server 服務(wù)的路由地址配置成了api-user，也就是當(dāng)需要訪問 ws-user-server中的接口時(shí)，我們可以通過 api-user/user/20 來進(jìn)行。這其實(shí)就是將服務(wù)名稱變成了我們自定義的名稱。注意： /api-user/** 后面一定要配置兩個(gè)星號(hào)，兩個(gè)星號(hào)表示可以轉(zhuǎn)發(fā)任意層級(jí)的 URL，比如“/apiuser/user/1”。如果只配置一個(gè)星號(hào)，那么就只能轉(zhuǎn)發(fā)一級(jí)，比如“/api-user/user”。默認(rèn)的路由規(guī)則還適用?。。?！

2. 路由前綴

有的時(shí)候我們會(huì)想在 API 前面配置一個(gè)統(tǒng)一的前綴,就可

以通過 Zuul 中的配置來實(shí)現(xiàn)：

zuul:
 prefix: /v1

上述訪問地址變?yōu)椋?http://localhost:7000/v1/api-user/user/20

Zuul過濾器

過濾器類型

Zuul 中的過濾器跟我們之前使用的 javax.servlet.Filter不一樣，javax.servlet.Filter 只有一種類型，可以通過配置 urlPatterns 來攔截對(duì)應(yīng)的請(qǐng)求。

而 Zuul 中的過濾器總共有 4 種類型，且每種類型都有對(duì)應(yīng)的使用場景。

1）pre

可以在請(qǐng)求被路由之前調(diào)用。適用于身份認(rèn)證的場景，認(rèn)證通過后再繼續(xù)執(zhí)行下面的流程。

2）route

在路由請(qǐng)求時(shí)被調(diào)用。適用于灰度發(fā)布場景，在將要路由的時(shí)候可以做一些自定義的邏輯。

3）post

在 route 和 error 過濾器之后被調(diào)用。這種過濾器將請(qǐng)求路由到達(dá)具體的服務(wù)之后執(zhí)行。適用于需要添加響應(yīng)頭，記錄響應(yīng)日志等應(yīng)用場景。

4）error

處理請(qǐng)求時(shí)發(fā)生錯(cuò)誤時(shí)被調(diào)用。在執(zhí)行過程中發(fā)送錯(cuò)誤時(shí)會(huì)進(jìn)入 error 過濾器，可以用來統(tǒng)一記錄錯(cuò)誤信息。

請(qǐng)求生命周期

過濾器執(zhí)行的順序，請(qǐng)求發(fā)過來首先到 pre 過濾器，再到 routing 過濾器，最后到 post 過濾器，任何一個(gè)過濾器有異常都會(huì)進(jìn)入 error 過濾器。通過 com.netflix.zuul.http.ZuulServlet 也可以看出完整執(zhí)行順序，ZuulServlet 類似 Spring-MVC 的DispatcherServlet，所有的 Request 都要經(jīng)過ZuulServlet 的處理。

ZuulServlet 的service實(shí)現(xiàn)：

public void service(ServletRequest servletRequest, ServletResponse servletResponse) throws ServletException, IOException { try { 
this.init((HttpServletRequest)servletReque st(HttpServletResponse)servletResponse); RequestContext context = RequestContext.getCurrentContext(); context.setZuulEngineRan(); try {this.preRoute(); } catch (ZuulException var13) { this.error(var13); this.postRoute(); return; }try {this.route(); } catch (ZuulException var12) { this.error(var12); this.postRoute(); return; }try {this.postRoute();} catch (ZuulException var11) { this.error(var11); } } catch (Throwable var14) { this.error(new ZuulException(var14, 500, "UNHANDLED_EXCEPTION_" + var14.getClass().getName())); } finally { RequestContext.getCurrentContext().unset() ; } }

使用過濾器

創(chuàng)建一個(gè)token驗(yàn)證的過濾器，繼承抽象類ZuulFilter，

如下：

import com.netflix.zuul.ZuulFilter; 
import com.netflix.zuul.context.RequestContext; 
import com.netflix.zuul.exception.ZuulException; 
public class TokenFilter extends ZuulFilter {
/*** 過濾器類型，可選值有 pre、route、post、 error。* @return */ @Override 
public String filterType() { 
return "pre"; }
/*** 過濾器的執(zhí)行順序，數(shù)值越小，優(yōu)先級(jí)越高。 * @return */ @Override 
public int filterOrder() {
 return 0; }
 /*** 是否執(zhí)行該過濾器，true 為執(zhí)行，false 為不 執(zhí)行，這個(gè)也可以利用配置中心來實(shí)現(xiàn)，達(dá)到動(dòng)態(tài)的開啟和 關(guān)閉過濾器。 * @return */ @Override 
 public boolean shouldFilter() { 
 return true; }/*** 執(zhí)行自己的業(yè)務(wù)邏輯，判斷是否 * @return * @throws ZuulException */ @Override 
 public Object run() throws ZuulException {
  RequestContext requestContext=RequestContext.getCurrentCo ntext();String token= requestContext.getRequest().getHeader("tok en"); 
  //如果token沒傳或 失效 if(null==token){ requestContext.setSendZuulResponse(false); //告訴 Zuul 不需要將當(dāng)前請(qǐng)求轉(zhuǎn)發(fā)到后端的服務(wù)了 requestContext.setResponseBody(" {code:0,msg:'返回給客戶端的數(shù)據(jù)'}"); requestContext.getResponse().setContentTyp e("application/json; charset=utf-8"); }return null; } }

使過濾器生效：

@Configuration 
public class FilterConfig { 
@Bean
 public TokenFilter tokenFilter(){
  return new TokenFilter(); 
  }
   }

到此這篇關(guān)于Spring Cloud詳細(xì)講解zuul集成Eureka流程的文章就介紹到這了,更多相關(guān)Spring Cloud Eureka內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論