spring cloud如何使用Zuul實現(xiàn)API網(wǎng)關(guān)服務(wù)問題

這篇文章將為大家詳細(xì)講解有關(guān)spring cloud如何使用Zuul實現(xiàn)API網(wǎng)關(guān)服務(wù)問題，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

通過前面幾次的分享，我們了解了微服務(wù)架構(gòu)的幾個核心設(shè)施，通過這些組件我們可以搭建簡單的微服務(wù)架構(gòu)系統(tǒng)。比如通過Spring Cloud Eureka搭建高可用的服務(wù)注冊中心并實現(xiàn)服務(wù)的注冊和發(fā)現(xiàn)；

通過Spring Cloud Ribbon或Feign進(jìn)行負(fù)載均衡；通過Spring Cloud Hystrix進(jìn)行服務(wù)容錯保護(hù)以避免故障蔓延。微服務(wù)搭建好了之后我們肯定會提供給外部系統(tǒng)一些統(tǒng)一的RESTFul API服務(wù)接口進(jìn)行調(diào)用，

但是當(dāng)外部系統(tǒng)調(diào)用我們的RESTful API的時候，怎么確定它需要的功能具體是哪個服務(wù)提供的呢？這個就涉及到一個路由規(guī)則和服務(wù)實例列表的維護(hù)問題。

這就引入了我們今天的主角--Spring Cloud Zuul，它是基于Netflix Zuul實現(xiàn)的API網(wǎng)關(guān)組件。它可以解決兩個大問題：

• 就是我們上面提到的路由規(guī)則和服務(wù)實例的維護(hù)問題
  

• 對于一些校驗（比如登錄校驗等）冗余問題。 按照我們的習(xí)慣的做法，是在每個服務(wù)中都需要加入這些校驗，但是這樣會導(dǎo)致代碼冗余并且維護(hù)也比較麻煩，有了Spring Cloud Zuul這個網(wǎng)關(guān)服務(wù)之后，我們可以將這些共通的校驗放到網(wǎng)關(guān)里面統(tǒng)一維護(hù)。
  

好，接下來我們就來看下怎么實現(xiàn)這個網(wǎng)關(guān)服務(wù)。

一、構(gòu)建網(wǎng)關(guān)，配置路由

 這里我們還是需要使用到前面的hello-service和feign-consumer服務(wù)。我們之前把feign-consumer作為服務(wù)消費者，但是別忘了在eureka體系里面，每個服務(wù)既是服務(wù)提供者又是服務(wù)消費者，所以feign-consumer也是一個服務(wù)提供者，并且http://localhost:9001/feign-consumer等接口就是它提供的服務(wù)。

接下來我們構(gòu)建一個網(wǎng)關(guān)服務(wù)，代碼結(jié)構(gòu)如下：

代碼實現(xiàn)步驟：

新建maven工程api-gateway

修改POM文件

<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>
 <groupId>com.sam</groupId>
 <artifactId>api-gateway</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 <parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>1.5.1.RELEASE</version>
 </parent>
 <properties>
  <javaVersion>1.8</javaVersion>
 </properties>
 <!-- 使用dependencyManagement進(jìn)行版本管理 -->
 <dependencyManagement>
  <dependencies>
   <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-dependencies</artifactId>
    <version>Camden.SR6</version>
    <type>pom</type>
    <scope>import</scope>
   </dependency>
  </dependencies>
 </dependencyManagement>
 <dependencies>
  <!-- 引入zuul依賴 , 它依賴了spring-boot-starter-actuator/spring-boot-starter-hystrix/spring-boot-starter-ribbon-->
  <dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-zuul</artifactId>
  </dependency>
 </dependencies>
</project>

新建啟動類

/**
 * @EnableZuulProxy 開啟Zuul 的API網(wǎng)關(guān)服務(wù)功能
 *
 */
@EnableZuulProxy
@SpringCloudApplication
public class GateWayApp {

 public static void main(String[] args) {
  SpringApplication.run(GateWayApp.class, args);
 }
}

新建application.properties

server.port=5555
spring.application.name=api-gateway
#增加路由規(guī)則的配置
#通過zuul.routes.<route>.path和zuul.routes.<route>.url進(jìn)行配置，<route>為路由的名字，可以任意指定，但是一組path和url的路由名要相同
#如下面的例子：所有滿足/api-a/** 規(guī)則的訪問都會被路由轉(zhuǎn)發(fā)到//localhost:9001的地址
#也就是說，我們訪問http://localhost:5555/api-a/hello的時候，API網(wǎng)關(guān)服務(wù)就會將該請#求路由到 http://localhost:9001/hello提供的微服務(wù)接口上
zuul.routes.api-a.path=/api-a/**
zuul.routes.api-a.url=http://localhost:9001
zuul.routes.api-b.path=/api-b/**
zuul.routes.api-b.url=http://localhost:9090

測試，啟動eureka、hello-service、feign-consumer以及本次新加的api-gateway服務(wù)，然后訪問http://localhost:5555/api-a/feign-consumer

成功訪問到了feign-consumer的服務(wù)接口--feign-consonsumer。

以上步驟實現(xiàn)了傳統(tǒng)路由的配置，這種配置有個大的缺點，就是需要手工在application.properties文件中進(jìn)行路由規(guī)則的配置，當(dāng)服務(wù)很多的時候，維護(hù)工作量就會很大。為了減小維護(hù)成本，還有另外一種路由--面向服務(wù)的路由。

二、面向服務(wù)的路由

Spring Cloud Zuul和Eureka進(jìn)行整合，我們可以讓路由的path不是映射具體的url，而是具體的某個服務(wù)，而服務(wù)的url則交給Eureka服務(wù)發(fā)現(xiàn)機制自動維護(hù),這類路由就是面向服務(wù)的路由。具體代碼配置如下：

修改POM文件，引入Eureka依賴

<!-- 引入eureka依賴 -->
  <dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-eureka</artifactId>
  </dependency>

修改application.properties配置文件

server.port=5555
spring.application.name=api-gateway
zuul.routes.api-a.path=/api-a/**
#這里用serviceId代替url，用服務(wù)名代替ip+端口號
zuul.routes.api-a.serviceId=hello-service
eureka.client.service-url.defaultZone=http://localhost:1111/eureka

注意：zuul.routes.api-a.url=hello-service也能實現(xiàn)功能，但是它不能進(jìn)行正常的負(fù)載均衡和容錯保護(hù)。

測試,訪問http://localhost:5555/api-a/hello

訪問成功。

 三、服務(wù)路由的默認(rèn)規(guī)則

在面向服務(wù)的路由中，由于<route>名字是隨意起的，那么是不是可以這樣：

zuul.routes.hello-service.path=/hello-service/**
zuul.routes.hello-service.serviceId=hello-service

<route>名字就是服務(wù)名，其實在實際的應(yīng)用中，我們往往就是這樣命名的。如果有這樣的規(guī)則的話，那Zuul就可以幫我們默認(rèn)實現(xiàn)這樣的功能，進(jìn)一步省去了配置的麻煩。

我們來做個實驗，將配置文件改為：

server.port=5555
spring.application.name=api-gateway
eureka.client.service-url.defaultZone=http://localhost:1111/eureka

然后頁面訪問驗證

訪問成功。

但是由于默認(rèn)情況下，Eureka上的服務(wù)都會被Zuul創(chuàng)建默認(rèn)的映射關(guān)系來進(jìn)行路由，使得我們不想對外開放的服務(wù)也被外部訪問到，這個時候可以通過配置zuul.ignored-services來進(jìn)行配置不需要自動創(chuàng)建路由的規(guī)則。當(dāng)zuul.ignored-services=*的時候，所有的服務(wù)都不會自動創(chuàng)建路由規(guī)則，這個時候需要通過前面的配置進(jìn)行相關(guān)路由配置了。

================華麗的分割線===================

前面說了那么多都是圍繞一個問題展開的：路由規(guī)則和服務(wù)實例的維護(hù)問題，那么怎么解決第二個問題（校驗冗余問題）呢？

 四、請求過濾

為了在API網(wǎng)關(guān)中實現(xiàn)對客戶端請求的校驗，我們可以通過過濾器來實現(xiàn)對請求的攔截和過濾，實現(xiàn)方法比較簡單，只需要繼承ZuulFilter抽象類并實現(xiàn)其四個方法就行了。

修改api-gateway：

新增過濾器類

/**
 * 繼承ZuulFilter，并且實現(xiàn)其4個接口
 *
 * 用來進(jìn)行請求過濾
 *
 */
public class AccessFilter extends ZuulFilter {
 Logger logger = LoggerFactory.getLogger(AccessFilter.class);
 /* 
  * shouldFilter 判斷該過濾器是否需要被執(zhí)行
  * 
  * 這里直接返回true，表示該過濾器對所有請求都會生效。
  * 實際運用中我們可以利用該函數(shù)指定過濾器的有效范圍
  */
 @Override
 public boolean shouldFilter() {
  return true;
 }
 /*
  * 過濾器的具體邏輯
  * 
  * 這里我們通過ctx.setSendZuulResponse(false)讓zuul過來請求，不對其進(jìn)行路由
  * 然后通過ctx.setResponseStatusCode(401)設(shè)置了返回的錯誤碼
  * 
  */
 @Override
 public Object run() {
  RequestContext context = RequestContext.getCurrentContext();
  HttpServletRequest request = context.getRequest();
  Object accessToken = request.getParameter("accessToken");
  logger.info("send {} request to {}", request.getMethod(),request.getRequestURL().toString());
  if(accessToken == null) {
   context.setSendZuulResponse(false);
   context.setResponseStatusCode(401);
  }
  return null;
 }
 /* filterType 返回過濾器類型
  * 他決定了過濾器在請求的哪個生命周期中執(zhí)行。這里定義為pre，代表會在請求被路由前執(zhí)行。
  * 
  * pre:請求執(zhí)行之前filter 
  * route: 處理請求，進(jìn)行路由 
  * post: 請求處理完成后執(zhí)行的filter 
  * error:出現(xiàn)錯誤時執(zhí)行的filter
  */
 @Override
 public String filterType() {
  return "pre";
 }
 /* 
  * filterOrder 返回過濾器的執(zhí)行順序
  * 
  * 當(dāng)請求在一個階段有多個過濾器是，需要根據(jù)該方法的返回值來一次執(zhí)行
  * 
  */
 @Override
 public int filterOrder() {
  return 0;
 }
}

修改啟動類

/**
 * @EnableZuulProxy 開啟Zuul 的API網(wǎng)關(guān)服務(wù)功能
 *
 */
@EnableZuulProxy
@SpringCloudApplication
public class GateWayApp {
 //追加bean的是實現(xiàn)
 @Bean
 public AccessFilter accessFilter() {
  return new AccessFilter();
 }
 
 public static void main(String[] args) {
  SpringApplication.run(GateWayApp.class, args);
 }
}

測試

)訪問http://localhost:5555/hello-service/hello，訪問失敗

)訪問http://localhost:5555/hello-service/hello?accessToken=token，正常訪問

修改后的代碼結(jié)構(gòu)：

 五、拓展延伸

其實路由功能在真正運行時，他的路由映射和請求轉(zhuǎn)發(fā)都是由幾個不同的過濾器完成的。

路由映射主要通過pre類型的過濾器完成，他將請求路徑與配置的路由規(guī)則進(jìn)行匹配，找到需要轉(zhuǎn)發(fā)的目標(biāo)地址。

而請求轉(zhuǎn)發(fā)的部分則是由route類型的過濾器完成的，對pre類型過濾器獲取的路由地址進(jìn)行轉(zhuǎn)發(fā)。

所以，過濾器可以說是Zuul實現(xiàn)API網(wǎng)關(guān)功能最為核心的部件，每一個進(jìn)入Zuul的HTTP請求都會經(jīng)過一系列的過濾器處理鏈得到請求響應(yīng)并返回給客戶端。

關(guān)于“spring cloud如何使用Zuul實現(xiàn)API網(wǎng)關(guān)服務(wù)問題”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學(xué)到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。