壹

上篇学习了zuul路由,这边继续学习,粗糙的记录zuul过滤器的用法

贰

现在对请求url做个约定,在请求url上没有带参数key=123的url全部过滤掉

①localhost:7000/product/list?key=1234 ---不过滤

②localhost:7000/product/list ---过滤,不执行

完成以上功能,在gateway服务中,代码如下 :

1package com.cloud.gateway.filters;
2
3import com.netflix.zuul.ZuulFilter;
4import com.netflix.zuul.context.RequestContext;
5import com.netflix.zuul.exception.ZuulException;
6import org.springframework.http.HttpStatus;
7import org.springframework.stereotype.Component;
8import org.springframework.util.StringUtils;
9
10import javax.servlet.http.HttpServletRequest;
11
12import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_DECORATION_FILTER_ORDER;
13import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;
14
15/**
16 * 常量类
17 * 过滤器状态 FilterConstants
18 * 请求状态 HttpStatus
19 * 引用其中的属性值即可，无需自己写
20 */
21@Component
22public class PreFilter extends ZuulFilter {
23    /**
24     * filter类型
25     * @return
26     */
27    @Override
28    public String filterType() {
29        return PRE_TYPE;
30    }
31
32    /**
33     * filter执行顺序，值越小优先级越高
34     * 官方推荐使用x-1方式优先排序
35     * @return
36     */
37    @Override
38    public int filterOrder() {
39        return PRE_DECORATION_FILTER_ORDER - 1;
40    }
41
42    /**
43     * filter 开启关闭
44     * @return
45     */
46    @Override
47    public boolean shouldFilter() {
48        return true;
49    }
50
51    /**
52     * 实现filter逻辑
53     * @return
54     * @throws ZuulException
55     */
56    @Override
57    public Object run() throws ZuulException {
58        RequestContext requestContext = RequestContext.getCurrentContext();
59        HttpServletRequest request =requestContext.getRequest();
60        String key=request.getParameter("key");
61
62        //如果不存在，则设置没有权限不通过，状态为401
63        if (StringUtils.isEmpty(key)){
64            requestContext.setSendZuulResponse(false);
65            requestContext.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
66        }
67        return null;
68    }
69}

浏览器访问成功则返回list列表,失败则返回错误页面,错误码:401

再来实现一个post过滤器,在得到结果之后,实现在post filter阶段,返回response的,给header头部加点信息,代码如下:

1package com.cloud.gateway.filters;
2
3import com.netflix.zuul.ZuulFilter;
4import com.netflix.zuul.context.RequestContext;
5import com.netflix.zuul.exception.ZuulException;
6import org.springframework.stereotype.Component;
7
8import javax.servlet.http.HttpServletResponse;
9import java.util.UUID;
10
11import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.POST_TYPE;
12import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SEND_RESPONSE_FILTER_ORDER;
13
14/**
15 * 常量类
16 * 过滤器状态 FilterConstants
17 * 请求状态 HttpStatus
18 * 引用其中的属性值即可，无需自己写
19 */
20@Component
21public class PostFilter extends ZuulFilter {
22    /**
23     * filter类型
24     *
25     * @return
26     */
27    @Override
28    public String filterType() {
29        return POST_TYPE;
30    }
31
32    /**
33     * filter执行顺序，值越小优先级越高
34     * 官方推荐使用x-1方式优先排序
35     *
36     * @return
37     */
38    @Override
39    public int filterOrder() {
40        return SEND_RESPONSE_FILTER_ORDER - 1;
41    }
42
43    /**
44     * filter 开启关闭
45     *
46     * @return
47     */
48    @Override
49    public boolean shouldFilter() {
50        return true;
51    }
52
53    /**
54     * 实现filter逻辑
55     *
56     * @return
57     * @throws ZuulException
58     */
59    @Override
60    public Object run() throws ZuulException {
61        RequestContext requestContext = RequestContext.getCurrentContext();
62        HttpServletResponse response = requestContext.getResponse();
63        response.setHeader("POST-UUID", UUID.randomUUID().toString());
64        return null;
65    }
66}

浏览器控制台请求信息 :

写了两次, 套路也都摸清了,能写的地方也就这么几个点,后面再做限流操作,结合上面学的,限流做在请求filter最靠前的地方,比鉴权pre前执行,不然流量都进去了,这里需要一个算法---令牌桶算法,这个算法很多地方已经实现了,拿来用即可,意思是以一定速率将令牌放入桶中,桶中的令牌满了,就不会再放进去了,外部的请求进入,请求将获得桶中的令牌,得令牌者可通行,没有令牌请求将被拒绝

下面代码实现 :

1package com.cloud.gateway.filters;
2
3import com.cloud.gateway.exceptions.RateLimiterException;
4import com.google.common.util.concurrent.RateLimiter;
5import com.netflix.zuul.ZuulFilter;
6import com.netflix.zuul.exception.ZuulException;
7import org.springframework.stereotype.Component;
8
9import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;
10import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SERVLET_DETECTION_FILTER_ORDER;
11
12/**
13 * 限流
14 */
15@Component
16public class RateLimiterFilter extends ZuulFilter {
17
18    //create 每秒放入100个令牌
19    private static final RateLimiter RATE_LIMITER = RateLimiter.create(100);
20
21    /**
22     * filter类型
23     *
24     * @return
25     */
26    @Override
27    public String filterType() {
28        return PRE_TYPE;
29    }
30
31    /**
32     * filter执行顺序，值越小优先级越高
33     * 官方推荐使用x-1方式优先排序
34     * 选择最高优先级SERVLET_DETECTION_FILTER_ORDER，并-1
35     *
36     * @return
37     */
38    @Override
39    public int filterOrder() {
40        return SERVLET_DETECTION_FILTER_ORDER - 1;
41    }
42
43    /**
44     * filter 开启关闭
45     *
46     * @return
47     */
48    @Override
49    public boolean shouldFilter() {
50        return true;
51    }
52
53    /**
54     * 实现filter逻辑
55     *
56     * @return
57     * @throws ZuulException
58     */
59    @Override
60    public Object run() throws ZuulException {
61        //判断--获取通行令牌-->如果没有令牌不等于之前的没有权限401，可以抛出自定义异常或者其他处理
62        if (!RATE_LIMITER.tryAcquire()) {
63            throw new RateLimiterException();
64        }
65
66        return null;
67    }
68}

自定义异常:

1package com.cloud.gateway.exceptions;
2
3public class RateLimiterException extends RuntimeException {
4}

叁

以上是过滤器的简单示例

还有一个Zuul关于鉴权的使用,涉及新建user服务,也会用到docker、redis,刚刚入手mac,上面什么都没有,装好了再继续下面的学习实践

---------------------------------------------------------

SpringCloud 微服务 (十四) 服务网关 Zuul 过滤器(Pre&Post)

壹

贰

叁

评论区

相关推荐