快捷導(dǎo)航

SpringCloud Zuul實現(xiàn)動態(tài)路由

更新時間：2019年01月11日 09:32:21 作者：huanzi-qch

這篇文章主要介紹了SpringCloud Zuul實現(xiàn)動態(tài)路由，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值，需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧

前言

Zuul 是在Spring Cloud Netflix平臺上提供動態(tài)路由,監(jiān)控,彈性,安全等邊緣服務(wù)的框架，是Netflix基于jvm的路由器和服務(wù)器端負載均衡器，相當于是設(shè)備和 Netflix 流應(yīng)用的 Web 網(wǎng)站后端所有請求的前門。本文基于上篇（SpringCloud系列——Ribbon 負載均衡）實現(xiàn)Zuul動態(tài)路由

GitHub地址：https://github.com/Netflix/zuul

官方文檔：https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.1.0.RC2/single/spring-cloud-netflix.html

代碼編寫

首先我們在springCloud下面新建一個springboot項目：zuul-server，pom繼承parent，并且在Eureka上面注冊（還不會服務(wù)注冊與發(fā)現(xiàn)的，請戳：SpringCloud系列——Eureka 服務(wù)注冊與發(fā)現(xiàn)）

maven引入Zuul

 <!-- Zuul -->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
    </dependency>

配置文件

server.port=10010
spring.application.name=zuul-server
eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
#健康檢查（需要spring-boot-starter-actuator依賴）
eureka.client.healthcheck.enabled=true
# 續(xù)約更新時間間隔（默認30秒）
eureka.instance.lease-renewal-interval-in-seconds=10
# 續(xù)約到期時間（默認90秒）
eureka.instance.lease-expiration-duration-in-seconds=10

#zuul代理配置 zuul.routes.服務(wù)名.path,服務(wù)名要與注冊的一致
#應(yīng)用名映射
zuul.routes.myspringboot.path=/myspringboot/**
zuul.routes.myspringboot.service-id=myspringboot

#URL映射
#zuul.routes.myspringboot.path=/myspringboot/**
#zuul.routes.myspringboot-url.url=http://localhost:10087/

自定義Zuul過濾器

更多的檢查規(guī)則后續(xù)慢慢健全

/**
 * Zuul過濾器，實現(xiàn)了路由檢查
 */
public class AccessFilter extends ZuulFilter {

  /**
   * 通過int值來定義過濾器的執(zhí)行順序
   */
  @Override
  public int filterOrder() {
    // PreDecoration之前運行
    return PRE_DECORATION_FILTER_ORDER - 1;
  }

  /**
   * 過濾器的類型，在zuul中定義了四種不同生命周期的過濾器類型：
   *   public static final String ERROR_TYPE = "error";
   *   public static final String POST_TYPE = "post";
   *   public static final String PRE_TYPE = "pre";
   *   public static final String ROUTE_TYPE = "route";
   */
  @Override
  public String filterType() {
    return PRE_TYPE;
  }

  /**
   * 過濾器的具體邏輯
   */
  @Override
  public Object run() {
    RequestContext ctx = RequestContext.getCurrentContext();
    HttpServletRequest request = ctx.getRequest();
    System.out.println(String.format("%s AccessFilter request to %s", request.getMethod(),request.getRequestURL().toString()));
    String accessToken = request.getParameter("accessToken");
    //有權(quán)限令牌
    if (!StringUtils.isEmpty(accessToken)) {
      ctx.setSendZuulResponse(true);
      ctx.setResponseStatusCode(200);
      //可以設(shè)置一些值
      ctx.set("isSuccess", true);
      return null;
    } else {
      ctx.setSendZuulResponse(false);
      ctx.setResponseStatusCode(401);
      ctx.setResponseBody("{\"result\":\"accessToken is not correct!\"}");
      //可以設(shè)置一些值
      ctx.set("isSuccess", false);
      return null;
    }
  }

  /**
   * 返回一個boolean類型來判斷該過濾器是否要執(zhí)行
   */
  @Override
  public boolean shouldFilter() {
    return true;
  }
}

啟動類

添加@EnableZuulProxy注解并使用自定義過濾器

@EnableZuulProxy
@SpringBootApplication
public class ZuulServerApplication {

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

  @Bean
  public AccessFilter accessFilter() {
    return new AccessFilter();
  }
}

效果演示

啟動所有項目，我們在Eureka上注冊了四個服務(wù)，相比上篇（SpringCloud系列——Ribbon 負載均衡）多了一個Zuul