返回顶部
首页 > 资讯 > 后端开发 > Python >如何为Spring Cloud Gateway加上全局过滤器
  • 373
分享到

如何为Spring Cloud Gateway加上全局过滤器

2024-04-02 19:04:59 373人浏览 安东尼

Python 官方文档:入门教程 => 点击学习

摘要

既然是一个网关。那么全局过滤器肯定是少不了的一个存在。像是鉴权、认证啥的不可能每个服务都做一次,一般都是在网关处就搞定了。 Zuul他就有很强大的过滤器体系来给人使用。 Gatewa

既然是一个网关。那么全局过滤器肯定是少不了的一个存在。像是鉴权、认证啥的不可能每个服务都做一次,一般都是在网关处就搞定了。
Zuul他就有很强大的过滤器体系来给人使用。
Gateway当然也不会差这么点东西。
对于SpringCloud体系来说,一切的实现都是那么的简单。那么废话不多说,直接开始写起来。
 
Gateway内部有一个接口 名为GlobalFilter,这个就是Gateway的全局过滤器接口,只要在应用中实现此接口后注册为spring的Bean,背后就会帮你将这个实现注册到全局过滤器链条里边去。
我这里就简单的写了个模拟鉴权的过滤器实现:


@Component
public class AuthFilter implements GlobalFilter, Ordered {
  @Override
  public Mono<Void> filter(ServerWEBExchange exchange, GatewayFilterChain chain) {
    String token = exchange.getRequest().getHeaders().getFirst("Authorization");
    //不为空则通过
    if (!StringUtils.isEmpty(token)) return chain.filter(exchange);
    ServerHttpResponse response = exchange.getResponse();
    // 封装错误信息
    Map<String, Object> responseData = Maps.newHashMapWithExpectedSize(3);
    responseData.put("code", httpstatus.UNAUTHORIZED.value());
    responseData.put("message", "Token is empty");
    responseData.put("cause", "Token is empty");
    // 将信息转换为 JSON
    ObjectMapper objectMapper = new ObjectMapper();
    byte[] data = new byte[0];
    try {
      data = objectMapper.writeValueAsBytes(responseData);
    } catch (jsonProcessingException e) {
      e.printStackTrace();
    }
    // 返回错误信息json
    DataBuffer buffer = response.bufferFactory().wrap(data);
    response.setStatusCode(HttpStatus.UNAUTHORIZED);
    response.getHeaders().add("Content-Type", "application/json;charset=UTF-8");
    return response.writeWith(Mono.just(buffer));
  }
  //最后执行
  @Override
  public int getOrder() {
    return Ordered.LOWEST_PRECEDENCE;
  }
}

虽说是鉴权,但实际上我这就是个简单的demo而已。想知道真正的Spring Security鉴权/认证怎么写?
我以前写的这个:https://GitHub.com/skypyb/code_demo/tree/master/spring-security-demo 应该可以帮助你。
 
看我写的这个过滤器内部实现哈,其实就是拿出Request Header中的 Authorization字段(token) 然后判断是否存在。不存在就返回错误,存在就交给链条中的下一个过滤器。
 
过滤器其实也没啥好说的,那么说说限流。
关于限流这个东西,常见的算法就是漏桶和令牌桶了,对于一个应用单机限流来说也复杂不到哪儿去。
靠着Google guava包里的RateLimiter工具都能搞定大多数场景了。
不过既然人家Gateway好心好意给你搞了个限流的实现。那么还是尊重他用一下。
由于Gateway是用的Redislua脚本实现了令牌桶的算法,那么先导入几个需要的依赖:


    <!--Redis begin-->
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis-Reactive</artifactId>
    </dependency>
    <dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
    </dependency>
    <!--Redis end-->

既然是Redis,那还是先配一下Redis序列化先:


@Configuration
public class RedisConfig {
  @Bean
  public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
    StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
    redisTemplate.seTKEySerializer(stringRedisSerializer);
    redisTemplate.setHashKeySerializer(stringRedisSerializer);
    redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<Object>(Object.class));
    redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    redisTemplate.setConnectionFactory(connectionFactory);
    return redisTemplate;
  }
}

万事俱备,开始进行限流的具体实现了。
 
既然是限流,那么也得有个限流策略
是根据用户来限流呢?还是说根据请求路径限流?或者是IP限流?
不过这个都是由需求来决定了,我这就简单的写个根据IP来限流的。
人家也给你封装完毕了,只需要你自己实现KeyResolver这个接口就可以。
由于实现这个一般来说也就一行代码,所以我就不写个单独的类去实现了,而是直接写在配置类里边。


@Configuration
public class GatewayRateLimiterConfig {
  
  @Bean(value = "ipKeyResolver")
  public KeyResolver ipKeyResolver() {
    return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getAddress().getHostAddress());
  }
}

看,我其实只需要返回我需要限制的东西就可以了。我这里提取到用户的IP将其返回,即可实现通过ip来进行限流的策略。
不过限流相关的配置写了,那也得用起来。
这个怎么用起来? 其实直接在配置文件里配置就OK了


spring:
 application:
  # 应用名称
  name: sc-demo-alibaba-gateway
 cloud:
  Nacos:
   discovery:
    server-addr: 192.168.3.105:8848 #注册进nacos
  # 使用 Sentinel 作为熔断器
  sentinel:
   transport:
    port: 18102
    dashboard: 192.168.3.105:8858
  # 路由网关配置
  gateway:
   # 这里是设置与服务注册发现组件结合,这样可以采用服务名的路由策略
   discovery:
    locator:
     enabled: true
   # 配置路由规则
   routes:
    - id: ROUTER#sc-demo-alibaba-consumer #这个是路由ID,需要保证在所有路由定义中唯一,值随便写就是了
     # 采用 LoadBalanceClient 方式请求,以 lb:// 开头,后面的是注册在 Nacos 上的服务名
     uri: lb://sc-demo-alibaba-consumer
     predicates:
      # Method ,这里是匹配 GET 和 POST 请求
      - Method=GET,POST
     filters:
      - name: RequestRateLimiter
       args:
        redis-rate-limiter.burstCapacity: 20
        redis-rate-limiter.replenishRate: 5
        key-resolver: '#{@ipKeyResolver}'
    - id: ROUTER#sc-demo-alibaba-provider
     uri: lb://sc-demo-alibaba-provider
     predicates:
      - Method=GET,POST
 #Redis配置
 redis:
  host: 192.168.3.105
  port: 6379
  #Redis连接池配置
  jedis:
   pool:
    min-idle: 0
    max-idle: 8
    max-active: 8
    max-wait: -1ms
server:
 port: 8888
feign:
 sentinel:
  enabled: true
management:
 endpoints:
  web:
   exposure:
    include: "*"
# 配置日志级别,方别调试
logging:
 level:
  org.springframework.cloud.gateway: debug

这里可以看到,除了Redis配置 ( spring.redis.** )以外。
主要就是对于Getway的配置。
在Gateway路由配置中,设置了一个filters参数。
这个是为了指定路由的各种过滤器的。这个参数也有很多种,可以参考官方讲解: https://cloud.spring.io/spring-cloud-gateway/2.0.x/single/spring-cloud-gateway.html#gateway-route-filters

我这就是指定了一个RequestRateLimiter,请求限流。

  • redis-rate-limiter.burstCapacity: 20     

这个参数表示突发容量,即每秒可以最大通过多少次请求

  • redis-rate-limiter.replenishRate: 5      

 这个是令牌桶的补充速度,每秒往桶里边放几个令牌

  • key-resolver: ‘#{@ipKeyResolver}'             

这个就是用上KeyResolver的具体实现了,这里用spel表达式指定我写的那个ip限制类

准备好之后将应用启动就完事了,想测的话可以用jmeter测测看,或者将请求限制写的更小一点,在网页上狂按f5也行。

以上就是如何为spring cloud Gateway加上全局过滤器的详细内容,更多关于Spring Cloud Gateway添加全局过滤器的资料请关注编程网其它相关文章!

--结束END--

本文标题: 如何为Spring Cloud Gateway加上全局过滤器

本文链接: https://lsjlt.com/news/121592.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • 如何为Spring Cloud Gateway加上全局过滤器
    既然是一个网关。那么全局过滤器肯定是少不了的一个存在。像是鉴权、认证啥的不可能每个服务都做一次,一般都是在网关处就搞定了。 Zuul他就有很强大的过滤器体系来给人使用。 Gatewa...
    99+
    2024-04-02
  • 怎么为Spring Cloud Gateway加上全局过滤器
    本篇内容介绍了“怎么为Spring Cloud Gateway加上全局过滤器”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!既然是一个网关。那...
    99+
    2023-06-14
  • spring cloud gateway全局过滤器实现向request header中放数据
    gateway全局过滤器向request header放数据 exchange.getRequest().getHeaders().set(); 是不能向 headers中放...
    99+
    2024-04-02
  • spring cloud gateway集成hystrix全局断路器操作
    gateway集成hystrix全局断路器 pom.xml添加依赖 <dependency> <groupId>org.springframework.c...
    99+
    2024-04-02
  • spring cloud gateway集成hystrix全局断路器的操作
    这篇文章主要讲解了“spring cloud gateway集成hystrix全局断路器的操作”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“spring cloud gateway集成hys...
    99+
    2023-06-20
  • springcloud如何整合gateway实现网关全局过滤器功能
    这篇文章主要讲解了“springcloud如何整合gateway实现网关全局过滤器功能”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“springcloud如何整合gateway实现网关全局过...
    99+
    2023-06-29
  • 聊聊Spring Cloud Gateway过滤器精确控制异常返回问题
    欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本篇概览在《Spring Cloud...
    99+
    2024-04-02
  • springcloud整合gateway实现网关全局过滤器功能
    目录1.代码实现:2.实现效果:springcloud整合gateway实现网关全局过滤器功能,在​ ​ springcloud整合gateway实现网关 ​​基础功能上进...
    99+
    2024-04-02
  • Spring Cloud Zuul如何实现自定义过滤器
    小编给大家分享一下Spring Cloud Zuul如何实现自定义过滤器,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!构建Zuul自定义过滤器,限制ip频繁请求自定义zuul过滤器其实很简单1. 首先pom文件得先引入zu...
    99+
    2023-06-14
  • Vue如何引入全局过滤器
    目录Vue引入全局过滤器创建单独的文件加上时间过滤函数在main.js中全局引入在组件中使用formatDate过滤时间戳vue全局过滤器配置总结Vue引入全局过滤器 创建单独的文件...
    99+
    2023-01-28
    Vue引入全局过滤器 Vue全局过滤器 Vue过滤器
  • Spring Cloud Gateway如何替代zuul作为API网关
    这篇文章主要介绍“Spring Cloud Gateway如何替代zuul作为API网关”,在日常操作中,相信很多人在Spring Cloud Gateway如何替代zuul作为API网关问题上存在疑...
    99+
    2023-07-05
  • 网关Gateway过滤器如何使用
    这篇“网关Gateway过滤器如何使用”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“网关Gateway过滤器如何使用”文章吧...
    99+
    2023-07-02
  • vue如何实现全局过滤器注册
    这篇文章主要介绍了vue如何实现全局过滤器注册,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。全局过滤器注册1 一般情况官方注册过滤器的方式:...
    99+
    2024-04-02
  • Spring boot详解fastjson过滤字段为null值如何解决
    目录前言环境解决方法后记前言 最近因项目需要,从零开始重新搭建了一套框架给同事们用。在前后端对接的时候,发现后端提供的字段缺少了很多,即实体类为null值的字段,全部被过滤了。经排查...
    99+
    2024-04-02
  • springSecurity之如何添加自定义过滤器
    目录springSecurity 添加自定义过滤器很简单,配置如下然后再来看看myFilterspringSecurity 自定义认证过滤器出现的问题解决方法springSecuri...
    99+
    2024-04-02
  • 如何为dedecms织梦模板发布文章添加禁用词语过滤功能
    dedecms(本例为V57_UTF8_SP1)中在互动部分有词语过滤功能,但是文章部分没有添加此功能,我们自己手动添加下发布文章禁用词语过滤功能。 在/dede/article_add.php中的代码: if(!...
    99+
    2022-06-12
    dedecms 禁用词语 过滤
  • Vue如何通过浏览器控制台查看全局data值
    目录前言(1)没有或找不到具体的Vue对象(2)Vue在外层定义了实例来包裹整个对象补充:vue在控制台展开有值代码却获取不到总结前言 Vue中借助data实现了数据的存储和中转,方...
    99+
    2023-05-15
    vue控制台如何查看数据 vue控制台 vue查看全局data值
  • 如何使用 Golang 和 supabase 在 Postgres 数据库上链接多个过滤器?
    php小编鱼仔今天为大家介绍一种使用Golang和supabase在Postgres数据库上链接多个过滤器的方法。在开发过程中,我们经常需要对数据库进行查询和筛选,而多个过滤器的组合使...
    99+
    2024-02-09
  • 如何在Linux服务器上加强Web接口安全
    要加强Web接口安全,可以采取以下措施:1. 使用HTTPS:使用HTTPS协议来保护数据传输的安全性。可以使用证书来进行加密和身份...
    99+
    2023-10-10
    Linux
  • 如何通过PHP脚本在Linux服务器上实现数据加密
    引言数据加密是现代计算机系统中非常重要的一项安全措施。通过加密敏感数据,可以保护用户隐私和数据完整性。本文将介绍如何在Linux服务器上使用PHP脚本实现数据加密,并提供具体的代码示例。使用OpenSSL库OpenSSL是一个开源的密码学工...
    99+
    2023-10-21
    Linux PHP 加密
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作