服务限流/API限流(Zuul+RateLimiter)

2023-12-02 08:58

本文主要是介绍服务限流/API限流(Zuul+RateLimiter),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

 

 

一、前言

1、什么是RateLimiter、Spring Cloud Zuul RateLimiter?

2、本篇主要内容

3、本篇环境信息

4、准备工作

二、服务限流(Zuul+RateLimiter)

1、默认服务限流策略

2、为指定服务单独配置限流策略

3、基于URL的限流策略

三、Zuul集群服务限流(Zuul+RateLimiter+Redis)

1、部署Reids Server

2、引入 Spring Data Redis

3、配置Redis连接

4、配置RateLimiter数据存储方式

四、备注

Zuul-RateLimiter参数说明

附录


 

一、前言

1、什么是RateLimiter、Spring Cloud Zuul RateLimiter?

RateLimiter是Google开源的实现了令牌桶算法的限流工具(速率限制器)。http://ifeve.com/guava-ratelimiter/

Spring Cloud Zuul RateLimiter结合Zuul对RateLimiter进行了封装,通过实现ZuulFilter提供了服务限流功能

限流粒度/类型说明
Authenticated User针对请求的用户进行限流
Request Origin针对请求的Origin进行限流
URL针对URL/接口进行限流
Service针对服务进行限流,如果没有配置限流类型,则此类型生效

https://github.com/marcosbarbero/spring-cloud-zuul-ratelimit

2、本篇主要内容

  • 服务限流配置示例与说明
  • URL限流配置示例与说明
  • Zull集群服务限流说明(+Redis)
  • Spring Cloud Zuul RateLimiter参数介绍

3、本篇环境信息

框架版本
Spring Boot2.0.0.RELEASE
Spring CloudFinchley.RELEASE
Zuul1.3.1
JDK1.8.x

4、准备工作

参考上一篇:https://ken.io/note/spring-cloud-zuul-quickstart
基于源码:https://github.com/ken-io/springcloud-course/tree/master/chapter-08

  • 准备Eureka Server、服务提供者

启动Eureka Server: http://localhost:8800
启动Test Service:http://localhost:8602

二、服务限流(Zuul+RateLimiter)

基于上一篇中zuul项目的源码进行修改即可:https://github.com/ken-io/springcloud-course/tree/master/chapter-08/zuul

  • 引入spring-cloud-zuul-ratelimit
<dependency><groupId>com.marcosbarbero.cloud</groupId><artifactId>spring-cloud-zuul-ratelimit</artifactId><version>2.0.4.RELEASE</version>
</dependency>

1、默认服务限流策略

  • 修改 application.yml 配置限流策略
zuul:ratelimit:enabled: truedefault-policy:limit: 1quota: 2refresh-interval: 3

以上配置表示启用限流策略,并且所有服务在3秒内只能有1次请求且所有请求时间总和不得超过2秒

  • 限流测试

启动zuul项目,然后访问 http://localhost:8888/testservice?token=ken
3秒内访问两次,就会看到错误页面

image

错误信息:type=Too Many Requests, status=429
这说明3秒内的>1次的访问已经被限流策略挡掉

2、为指定服务单独配置限流策略

  • 修改 application.yml 配置限流策略
zuul:ratelimit:enabled: truedefault-policy:limit: 1quota: 1refresh-interval: 3policies:testservice:limit: 10quota: 50refresh-interval: 60

以上配置单独为testservice配置了限流策略。60秒内访问次数不得查过10次且访问时间这不得超过50秒。

虽然我们也同时配置了默认限流策略,而且默认限流策略比testservice的限流策略还要更严格,但是这个限流并不会冲突。因为一旦我们为某个服务单独配置了限流策略,那么只有这个单独配置的限流策略会对该服务生效。

3、基于URL的限流策略

  • 修改 application.yml 配置限流策略
zuul:ratelimit:enabled: truedefault-policy:limit: 1quota: 1refresh-interval: 3policies:testservice:limit: 10quota: 50refresh-interval: 60type: url

以上配置只是在testservice的策略上增加了type参数的设置。(当然也可以在默认策略加这个参数)。

那么这个策略就变成了:每个Url60秒内访问次数不得超过10次且总计访问时间这不得超过50秒。

  • 访问测试

启动zuul项目,然后访问: http://localhost:8888/testservice?token=ken
达到限流阈值后,访问:
http://localhost:8888/testservice/plus?token=ken&numA=1&numB=2

依然可以正常访问。
另外,需要值得注意的是,?后面的参数是不会作为限流的key的。
http://localhost:8888/testservice?token=ken , http://localhost:8888/testservice?token=ken.io 会被作为同一个url进行限流

如果zuul-ratelimiter的限流粒度/方式不能满足你的需求,你可以选择自定义ZuulFilter集成RateLimiter去做限流。

三、Zuul集群服务限流(Zuul+RateLimiter+Redis)

RateLimiter的限流数据是默认以ConcurrentHashMap方式存储在内存中的,
当我们部署了Zuul集群的时候,就会影响我们的限流策略了。我们可以将限流数据存储在Redis中,这样就可以集中记录各个Zuul节点的限流数据,来保证限流的准确性。

1、部署Reids Server

参考:https://ken.io/note/centos7-redis4-setup

2、引入 Spring Data Redis

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>2.0.4.RELEASE</version>
</dependency>

3、配置Redis连接

修改application.yml

spring:redis:host: 192.168.88.11port: 6379

4、配置RateLimiter数据存储方式

zuul:ratelimit:enabled: truerepository: redisdefault-policy:limit: 1quota: 1refresh-interval: 3policies:testservice:limit: 10quota: 50refresh-interval: 60type: url

四、备注

Zuul-RateLimiter参数说明

  • Zuul-RateLimiter基本配置项
配置项可选值说明
enabledtrue/false是否启用限流
behind-proxytrue/false翻了源码,没发现有使用。。。作者也没说明。。。
key-prefixString限流key前缀
repositoryCONSUL, REDIS, JPA, BUCKET4J_JCACHE, BUCKET4J_HAZELCAST, BUCKET4J_INFINISPAN, BUCKET4J_IGNITE, IN_MEMORY限流数据的存储方式,默认是:IN_MEMORY
default-policy默认策略
policies自定义策略
postFilterOrderpostFilter过滤顺序
preFilterOrderpreFilter过滤顺序
  • Policy限流策略配置项说明
说明
limit单位时间内请求次数限制
quota单位时间内累计请求时间限制(秒),非必要参数
refresh-interval单位时间(秒),默认60秒
type限流方式:ORIGIN, USER, URL

附录

  • 本篇代码示例

https://github.com/ken-io/springcloud-course/tree/master/chapter-09

  • 本篇参考

https://github.com/marcosbarbero/spring-cloud-zuul-ratelimit

http://ifeve.com/guava-ratelimiter/

这篇关于服务限流/API限流(Zuul+RateLimiter)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/444705

相关文章

基于Flask框架添加多个AI模型的API并进行交互

《基于Flask框架添加多个AI模型的API并进行交互》:本文主要介绍如何基于Flask框架开发AI模型API管理系统,允许用户添加、删除不同AI模型的API密钥,感兴趣的可以了解下... 目录1. 概述2. 后端代码说明2.1 依赖库导入2.2 应用初始化2.3 API 存储字典2.4 路由函数2.5 应

Linux上设置Ollama服务配置(常用环境变量)

《Linux上设置Ollama服务配置(常用环境变量)》本文主要介绍了Linux上设置Ollama服务配置(常用环境变量),Ollama提供了多种环境变量供配置,如调试模式、模型目录等,下面就来介绍一... 目录在 linux 上设置环境变量配置 OllamPOgxSRJfa手动安装安装特定版本查看日志在

SpringCloud之LoadBalancer负载均衡服务调用过程

《SpringCloud之LoadBalancer负载均衡服务调用过程》:本文主要介绍SpringCloud之LoadBalancer负载均衡服务调用过程,具有很好的参考价值,希望对大家有所帮助,... 目录前言一、LoadBalancer是什么?二、使用步骤1、启动consul2、客户端加入依赖3、以服务

redis+lua实现分布式限流的示例

《redis+lua实现分布式限流的示例》本文主要介绍了redis+lua实现分布式限流的示例,可以实现复杂的限流逻辑,如滑动窗口限流,并且避免了多步操作导致的并发问题,具有一定的参考价值,感兴趣的可... 目录为什么使用Redis+Lua实现分布式限流使用ZSET也可以实现限流,为什么选择lua的方式实现

Nginx配置系统服务&设置环境变量方式

《Nginx配置系统服务&设置环境变量方式》本文介绍了如何将Nginx配置为系统服务并设置环境变量,以便更方便地对Nginx进行操作,通过配置系统服务,可以使用系统命令来启动、停止或重新加载Nginx... 目录1.Nginx操作问题2.配置系统服android务3.设置环境变量总结1.Nginx操作问题

C#集成DeepSeek模型实现AI私有化的流程步骤(本地部署与API调用教程)

《C#集成DeepSeek模型实现AI私有化的流程步骤(本地部署与API调用教程)》本文主要介绍了C#集成DeepSeek模型实现AI私有化的方法,包括搭建基础环境,如安装Ollama和下载DeepS... 目录前言搭建基础环境1、安装 Ollama2、下载 DeepSeek R1 模型客户端 ChatBo

springboot的调度服务与异步服务使用详解

《springboot的调度服务与异步服务使用详解》本文主要介绍了Java的ScheduledExecutorService接口和SpringBoot中如何使用调度线程池,包括核心参数、创建方式、自定... 目录1.调度服务1.1.JDK之ScheduledExecutorService1.2.spring

通俗易懂的Java常见限流算法具体实现

《通俗易懂的Java常见限流算法具体实现》:本文主要介绍Java常见限流算法具体实现的相关资料,包括漏桶算法、令牌桶算法、Nginx限流和Redis+Lua限流的实现原理和具体步骤,并比较了它们的... 目录一、漏桶算法1.漏桶算法的思想和原理2.具体实现二、令牌桶算法1.令牌桶算法流程:2.具体实现2.1

Java调用DeepSeek API的最佳实践及详细代码示例

《Java调用DeepSeekAPI的最佳实践及详细代码示例》:本文主要介绍如何使用Java调用DeepSeekAPI,包括获取API密钥、添加HTTP客户端依赖、创建HTTP请求、处理响应、... 目录1. 获取API密钥2. 添加HTTP客户端依赖3. 创建HTTP请求4. 处理响应5. 错误处理6.

Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

《Android悬浮窗开发示例((动态权限请求|前台服务和通知|悬浮窗创建)》本文介绍了Android悬浮窗的实现效果,包括动态权限请求、前台服务和通知的使用,悬浮窗权限需要动态申请并引导... 目录一、悬浮窗 动态权限请求1、动态请求权限2、悬浮窗权限说明3、检查动态权限4、申请动态权限5、权限设置完毕后