springcloud之Zuul网关服务

Zuul是Netflix开源的微服务网关，它的核心是一系列的过滤器，这些过滤器可以完成以下功能：

• 身份认证与安全：识别每个资源的验证要求，并拒绝那些与要求不符的请求。
• 审查与监控：在边缘位置追踪有意义的数据和统计结果，从而带来精确的生产视图。
• 动态路由：动态的请求路由到不同的后端集群。
• 压力测试：为每一个负载类型分配对应容量，并启用超出限定值的请求。
• 静态响应处理：在边缘位置直接建立部分响应，从而避免其转发到内部集群。
• 多区域弹性：跨越AWS Region进行请求路由，实现静态负载均衡（ELB）使用的多样化，以及让系统的边缘更贴近系统的使用者。

添加maven依赖：

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

在其入口applicaton类加上注解@EnableZuulProxy，开启zuul的功能：

@SpringBootApplication
@EnableZuulProxy
@EnableEurekaClient
@EnableDiscoveryClient
public class ServiceZuulApplication {

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

修改application.yml如下：

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
server:
  port: 8769
spring:
  application:
    name: service-zuul
zuul:
  routes:
    api-a:
      path: /api-a/**
      serviceId: service-ribbon
    api-b:
      path: /api-b/**
      serviceId: service-feign

首先指定服务注册中心的地址为http://localhost:8761/eureka/，服务的端口为8769，服务名为service-zuul；以/api-a/ 开头的请求都转发给service-ribbon服务；以/api-b/开头的请求都转发给service-feign服务。

过滤器是Zuul的核心组件，它的大部分功能都是通过过滤器来实现的，Zuul定义了4中标准过滤器类型，这些过滤器类型对应于请求的典型生命周期：

• PRE：这种过滤器在请求被路由之前调用。可以利用这种过滤器实现身份验证、在集群中选择请求的微服务、记录调试信息等。
• ROUTING：这种过滤器将请求路由到微服务。用于构建发送到微服务的请求，并使用Apache HttpClient或Netflix Ribbon请求微服务。
• POST：这种过滤器在路由到微服务以后执行。这种过滤器可以用来为响应添加标准的HTTP Header、手机统计信息和指标、将响应从微服务发送给客户端等。
• ERROR：在其他阶段发生错误时执行该过滤器。

编写Zuul过滤器非常简单，只需要继承抽象类ZuulFilter，实现几个抽象方法即可。

@Component
public class MyFilter extends ZuulFilter {

    private static Logger log = LoggerFactory.getLogger(MyFilter.class);
    @Override
    public String filterType() {
        return "pre";
    }

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

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

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        log.info(String.format("%s >>> %s", request.getMethod(), request.getRequestURL().toString()));
        Object accessToken = request.getParameter("token");
        if(accessToken == null) {
            log.warn("token is empty");
            ctx.setSendZuulResponse(false);
            ctx.setResponseStatusCode(401);
            try {
                ctx.getResponse().getWriter().write("token is empty");
            }catch (Exception e){}

            return null;
        }
        log.info("ok");
        return null;
    }
}

根据代码可知，自定义一个Zuul Filter需实现以下几个方法：

• filterType：返回过滤器的类型。有pre、route、post、error等几种取值，分别对应上述的几种过滤器。
• fiterOrder：返回一个int值来指定过滤器的执行顺序，不同的过滤器允许返回相同的数字。
• shoudFilter：返回一个boolean值来判断该过滤器是否要执行，true表示执行。
• run：过滤器的具体逻辑。包括查sql，nosql去判断该请求到底有没有权限访问。