Zuul、Fegin、Rebbion、Eureka一條龍

很多人都自然而然把zuul當成nginx那樣來在配置寫死節點配置來。實際上zuul和eureka的是可以完美配合，完全可以基於服務名的註冊和發現,來動態的實現服務的動態負載和動態註冊，從而達到不需要重啟zuul即可達到動態擴容的。下文將介紹靜態配置路由表和從Eureka發現服務的兩種方式來加強Zuul的使用。

專案地址：

GateWay搭建

Maven依賴

<dpendency>
    <groupId>org.springframework.cloud</groupId>
 

    <artifactId>spring-cloud-starter-zuul</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId
 
>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session</artifactId>
    <version>1.2.2.RELEASE</version>
</dependency>
<dependency
 
>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
</dependency>

基於Eureka的application.yml（關鍵）

spring:
    application:
        name: ace-gate
    thymeleaf:
        mode: LEGACYHTML5
        cache: false
    redis:
        database: 1
        host: 127.0.0.1
        pool:
            max-active: 20
server:
    port: 8765 #啟動埠

#開啟動態閘道器服務發現
ribbon:
  eureka:
    enabled: true 

#配置zuul路由表，靜態路由
#zuul:
#  #prefix: /techouse #為zuul設定一個公共的字首
#  #ignoredServices: '*'
#  routes:
#    ace-admin: #隨便定義，當不存在serviceId時，預設該值為serviceId（就是註冊服務的名稱，屬性spring.application.name）
#      path: /test/** #匹配/test/** 均路由到cloud-client

#基於靜態路由節點的ribbon負載均衡配置
#ace-admin:
#  ribbon:
#    listOfServers: 127.0.0.1:8767 

eureka:
    instance:
        statusPageUrlPath: ${management.context-path}/info
        healthCheckUrlPath: ${management.context-path}/health
    client:
        serviceUrl:
            defaultZone: http://localhost:8761/eureka/
security:
    user:
        name: admin
        password: admin
        role: USER
#避免第一次呼叫失敗
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 5000

#請求和響應GZIP壓縮支援
feign:
  compression:
    request:
      enabled: true
      mime-types: text/xml,application/xml,application/json
      min-request-size: 2048
    response:
      enabled: true

啟用Zuul、Fegin、Eureka註解

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@EnableFeignClients
@EnableZuulProxy
@EnableRedisHttpSession(redisFlushMode = RedisFlushMode.IMMEDIATE)
public class GateBootstrap {
    public static void main(String[] args) {
        SpringApplication.run(GateBootstrap.class, args);
    }
}

Zuul filter攔截示例程式碼

@Component
public class SessionAccessFilter extends ZuulFilter {
  private final Logger log = LoggerFactory.getLogger(SessionAccessFilter.class);

  @Autowired
  private SessionRepository<?> repository;
  @Autowired
  private IUserService userService;

  @Override
  public String filterType() {
    return "pre";
  }

  @Override
  public int filterOrder() {
    return 1;
  }

  @Override
  public boolean shouldFilter() {
    return true;
  }

  @Override
  public Object run() {
    RequestContext ctx = RequestContext.getCurrentContext();
    HttpSession httpSession = ctx.getRequest().getSession();
    if (不符合許可權){
      setFailedRequest("<h1>Forbidden!</h1>",403);
    }
    return null;
  }

  /**
   * 路由重定向
   *
   * @param body
   * @param code
   */
  private void setFailedRequest(String body, int code) {
    log.debug("Reporting error ({}): {}", code, body);
    RequestContext ctx = RequestContext.getCurrentContext();
    ctx.setResponseStatusCode(code);
    if (ctx.getResponseBody() == null) {
      ctx.setResponseBody(body);
      ctx.setSendZuulResponse(false);
      throw new RuntimeException("Code: " + code + ", " + body); //optional
    }
  }
}

訪問閘道器地址示例

[ip]:[zuul port]/[Eureak 註冊服務]/[資源路徑]

Zuul相容動態註冊和靜態路由表

核心思路

基於Eureka上註冊另一個zuul，通過主的zuul gate way來分流到另外一個zuul，從而相容靜態路由的情況。