springcloud之微服务zuul组件实现

迈不过友情╰ 2023-06-25 02:13 26阅读 0赞

**springcloud常用组件  
1、服务注册与发现：Eureka  
2、服务网关: Zuul  
3、服务负载均衡：Ribbon  
4、服务之间调用：Feign  
5、服务熔断：Hystrix   ---因官网不继续维护，可以使用阿里提供的Alibaba Sentinel 轻量级的流量控制、熔断降级 Java 库  
6、配置中心：config     ---如果不想自己维护，可以使用阿里云nacos作为配置中心**  
  
**2、zuul路由网管**  
**主要权限验证和限流，**  
**（1）、权限验证：这里具体用ZuulFilter实现**

**方法说明  
filterType : filter类型,分为pre、error、post、 route  
filterOrder: filter执行顺序，通过数字指定，数字越小，执行顺序越先  
shouldFilter: filter是否需要执行 true执行 false 不执行  
run : filter具体逻辑（上面为true那么这里就是具体执行逻辑）**

**filter类型说明  
pre: 请求执行之前filter  
route: 处理请求，进行路由  
post: 请求处理完成后执行的filter  
error: 出现错误时执行的filter**

/\*\*  
 \* 登录过滤器  
 \*记得类上加Component注解  
 \*/  
@Component  
public class LoginFilter extends ZuulFilter \{

/\*\*  
     \* 过滤器类型，前置过滤器  
     \*/  
    @Override  
    public String filterType() \{  
        return PRE\_TYPE;  
    \}

/\*\*  
     \* 过滤器顺序，越小越先执行  
     \*/  
    @Override  
    public int filterOrder() \{  
        return 4;  
    \}

/\*\*  
     \* 过滤器是否生效  
     \* 返回true代表需要权限校验，false代表不需要用户校验即可访问  
     \*/  
    @Override  
    public boolean shouldFilter() \{

//共享RequestContext，上下文对象  
        RequestContext requestContext = RequestContext.getCurrentContext();  
        HttpServletRequest request = requestContext.getRequest();

System.out.println(request.getRequestURI());  
        //需要权限校验URL  
        if ("/apigateway/order/api/v1/order/save".equalsIgnoreCase(request.getRequestURI())) \{  
            return true;  
        \} else if ("/apigateway/order/api/v1/order/list".equalsIgnoreCase(request.getRequestURI())) \{  
            return true;  
        \} else if ("/apigateway/order/api/v1/order/find".equalsIgnoreCase(request.getRequestURI())) \{  
            return true;  
        \}  
        return false;  
    \}

/\*\*  
     \* 业务逻辑  
     \* 只有上面返回true的时候，才会进入到该方法  
     \*/  
    @Override  
    public Object run() throws ZuulException \{

//JWT  
        RequestContext requestContext = RequestContext.getCurrentContext();  
        HttpServletRequest request = requestContext.getRequest();

//token对象,有可能在请求头传递过来，也有可能是通过参数传过来，实际开发一般都是请求头方式  
        String token = request.getHeader("token");

if (StringUtils.isBlank((token))) \{  
            token = request.getParameter("token");  
        \}  
        System.out.println("页面传来的token值为：" + token);  
        //登录校验逻辑  如果token为null，则直接返回客户端，而不进行下一步接口调用  
        if (StringUtils.isBlank(token)) \{  
            // 过滤该请求，不对其进行路由  
            requestContext.setSendZuulResponse(false);  
            //返回错误代码  
            requestContext.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());  
        \}  
        return null;  
    \}  
\}

具体操作用如下代码  
原文章地址：[https://www.cnblogs.com/qdhxhz/p/9601170.html][https_www.cnblogs.com_qdhxhz_p_9601170.html]  
  
**（2）、限流：这里采用ZuulFilter + RateLimiter（基于guava框架来做网关限流）,RateLimiter是令牌桶算法**

/\*\*  
 \* 订单限流  
 \*其它和上面都一样，只是run()中逻辑不一样  
 \*/  
@Component  
public class OrderRateLimiterFilter extends ZuulFilter \{

//每秒产生1000个令牌  
    private static final RateLimiter RATE\_LIMITER = RateLimiter.create(1000);

@Override  
    public String filterType() \{  
        return PRE\_TYPE;  
    \}

@Override  
    public int filterOrder() \{  
        return -4;  
    \}

@Override  
    public boolean shouldFilter() \{  
        RequestContext requestContext = RequestContext.getCurrentContext();  
        HttpServletRequest request = requestContext.getRequest();

//只对订单接口限流  
        if ("/apigateway/order/api/v1/order/save".equalsIgnoreCase(request.getRequestURI())) \{  
            return true;  
        \}  
        return false;  
    \}

@Override  
    public Object run() throws ZuulException \{  
        RequestContext requestContext = RequestContext.getCurrentContext();

//就相当于每调用一次tryAcquire()方法，令牌数量减1，当1000个用完后，那么后面进来的用户无法访问上面接口  
        //当然这里只写类上面一个接口，可以这么写，实际可以在这里要加一层接口判断。  
        if (!RATE\_LIMITER.tryAcquire()) \{  
            requestContext.setSendZuulResponse(false);  
            //HttpStatus.TOO\_MANY\_REQUESTS.value()里面有静态代码常量  
            requestContext.setResponseStatusCode(HttpStatus.TOO\_MANY\_REQUESTS.value());  
        \}  
        return null;  
    \}  
\}  
  
文章来源：[https://www.cnblogs.com/qdhxhz/p/9601170.html][https_www.cnblogs.com_qdhxhz_p_9601170.html]  
  
**下一篇文章介绍漏桶算法和令牌桶算法区别**

[https_www.cnblogs.com_qdhxhz_p_9601170.html]: https://www.cnblogs.com/qdhxhz/p/9601170.html