码迷,mamicode.com
首页 > 其他好文 > 详细

Zuul的常用注解及配置

时间:2019-10-16 19:59:56      阅读:257      评论:0      收藏:0      [点我收藏+]

标签:end   负载均衡   也会   exce   条目   routing   sum   ntc   优先   

Zuul 微服务网关

作用:

Zuul的核心其实就是一系列过滤器

-身份认证与安全

-审查与监控

-动态路由

-压力测试

-负载分配

-静态响应处理

-多区域弹性

 

加入Zuul后的软件架构:

技术图片

 

Zuul的spring依赖自带了springweb依赖,因此建项目时只要导入Zuul依赖即可

引入eureka客户端依赖,以拉取客户端列表

 

在主类上加入注解:

@EnableZuulProxy //开启Zuul的网关功能

配置文件:

 

server:
port: 10010
spring:
application:
name: zuul
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
zuul:
  routes:
  user-uservice: /user-service/**  #这是默认的路由条目,只要zuul连上eureka就会获取eureka上的服务列表,并且根据这个服务列表提供所有服务的自动配置,而且此默认的路由一直都存在,即:不管你写不写,都有这条
    user-service: /user/**  #访问地址为127.0.0.1:10010/user/user/16
  ignored-services:  #这里是不路由的服务,书写方式是集合的方式
    - consumer-service

去除路由前缀:

 

server:
port: 10010
spring:
application:
name: zuul
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
zuul:
  routes:
  user-service:
    path: /user/**
    serviceId: user-service
    strip-prefix: false //去除路由前缀,默认为true,改为false即使user-serivce这条路由的/user路径不做去除,发送给真实路径,则访问地址为127.0.0.1:10010/user/16,因为匹配路径的/user/会发送给真实路径,但使用此功能无法简化路由条目配置
  ignored-services:  #这里是不路由的服务,书写方式是集合的方式
    - consumer-service

 

过滤器:

ZuulFilter是过滤器的顶级父类。在这里我们看一下其中定义的4个最重要的方法:

public abstract ZuulFilter implements IZuulFilter{
?
    abstract public String filterType();
?
    abstract public int filterOrder();
    
    boolean shouldFilter();// 来自IZuulFilter
?
    Object run() throws ZuulException;// IZuulFilter
}
  • shouldFilter:返回一个Boolean值,判断该过滤器是否需要执行。返回true执行,返回false不执行。

  • run:过滤器的具体业务逻辑。

  • filterType:返回字符串,代表过滤器的类型。包含以下4种:

    • pre:请求在被路由之前执行

    • routing:在路由请求时调用

    • post:在routing和errror过滤器之后调用

    • error:处理请求时发生错误调用

  • filterOrder:通过返回的int值来定义过滤器的执行顺序,数字越小优先级越高。

 

过滤器执行的生命周期:

技术图片

  • 正常流程:

    • 请求到达首先会经过pre类型过滤器,而后到达routing类型,进行路由,请求就到达真正的服务提供者,执行请求,返回结果后,会到达post过滤器。而后返回响应。

  • 异常流程:

    • 整个过程中,pre或者routing过滤器出现异常,都会直接进入error过滤器,再error处理完毕后,会将请求交给POST过滤器,最后返回给用户。

    • 如果是error过滤器自己出现异常,最终也会进入POST过滤器,而后返回。

    • 如果是POST过滤器出现异常,会跳转到error过滤器,但是与pre和routing不同的时,请求不会再到达POST过滤器了。

 

Zuul所有内置过滤器列表:

技术图片

 

使用场景:

  • 请求鉴权:一般放在pre类型,如果发现没有访问权限,直接就拦截了

  • 异常处理:一般会在error类型和post类型过滤器中结合来处理。

  • 服务调用时长统计:pre和post结合使用。

 

自定义过滤器:

模拟一个登录的校验。

基本逻辑:如果请求中有access-token参数,则认为请求有效,放行。

@Component
public class LoginFilter extends ZuulFilter{
    @Override
    public String filterType() {
        // 登录校验,肯定是在前置拦截
        return FilterConstants.PRE_TYPE;
    }

    @Override
    public int filterOrder() {
        // 该常量值为5 ,减1后为4
        return FilterConstants.PRE_DECORATION_FILTER_ORDER - 1;
    }

    @Override
    public boolean shouldFilter() {
        // 返回true,代表过滤器生效。
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        // 登录校验逻辑。
        // 1)获取Zuul提供的请求上下文对象
        RequestContext ctx = RequestContext.getCurrentContext();//RequestContext是一个Request域,此域的作用范围是从请求到达zuul一直到路由结束返回到客户端,整个完整流程都会存在
        // 2) 从上下文中获取request对象
        HttpServletRequest req = ctx.getRequest();
        // 3) 从请求中获取token
        String token = req.getParameter("access-token");
        // 4) 判断
        if(StringUtils.isBlank(token)){ //StringUtils,需引apache的commons-lang3包的依赖 使用此方式可以避免内存溢出
            // 没有token,登录校验失败,拦截
            ctx.setSendZuulResponse(false);//true则放行,false则拦截
            // 返回403状态码。也可以考虑重定向到登录页。
            ctx.setResponseStatusCode(HttpStatus.Forbidden.value());
        }
        // 校验通过,可以考虑把用户信息放入上下文,继续向后执行
        return null;//默认为空即为放行
    }
}

 此时使用http://127.0.0.1:10010/user/16 网页会跳转403

使用http://127.0.0.1:10010/user/16?access-token=1212121 即可正常访问,此案例只是验证access-token是否存在,不验证access-token的正确性

 

Zuul的负载均衡ribbon和熔断hystrix

 在zuul的配置文件中配置

server:
port: 10010
spring:
application:
name: zuul
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
zuul:
  routes:
  user-service:
    path: /user/**
    serviceId: user-service
    strip-prefix: false
  ignored-services:
    - consumer-service

zuul: retryable: true ribbon: ConnectTimeout: 250 # 连接超时时间(ms) ReadTimeout: 2000 # 通信超时时间(ms) OkToRetryOnAllOperations: true # 是否对所有操作重试 MaxAutoRetriesNextServer: 2 # 同一服务不同实例的重试次数 MaxAutoRetries: 1 # 同一实例的重试次数 hystrix: command: default: execution: isolation: thread: timeoutInMillisecond: 6000 # 熔断超时时长:6000ms

由于ribbon一次访问失败后会自动重试一次,因此 ( ConnectTimeout + ReadTimeout ) × 2 < timeoutInMillisecond

即:

timeoutInMillisecond的真实值是: ( ConnectTimeout + ReadTimeout ) × 2

公式:

timeoutInMillisecond = ( ribbon ConnectTimeout + ribbon ReadTimeout ) * (maxAutoRetries + 1) * ( maxAutoRetriesNextServer + 1 );

 

Zuul的常用注解及配置

标签:end   负载均衡   也会   exce   条目   routing   sum   ntc   优先   

原文地址:https://www.cnblogs.com/WaterGe/p/11687413.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!