Springboot 整合 Current-Limiting 实现接口限流

简介: Springboot 整合 Current-Limiting 实现接口限流

该篇文章内容:



1.实现标题中提到的接口限流


2.使用压测工具jmeter给大家展现验证效果

 

第一部分,代码的实现


首先是导入依赖包:


        <dependency>
            <groupId>cn.yueshutong</groupId>
            <artifactId>spring-boot-starter-current-limiting</artifactId>
            <version>0.0.1.RELEASE</version>
        </dependency>


然后是application.yml :


current:
  limiting:
    #开启全局限流
    enabled: false
    #开启注解限流,可使注解失效
    part-enabled: true
      #每秒并发量 这里的qps是全局限流开启的时候的值,如果使用注解在注解里设置QPS值
    qps: 100
      #开启快速失败,可切换为阻塞
    fail-fast: true
      #系统启动保护时间为0
    initial-delay: 0


然后是写测试接口,使用限流注解标记接口的并发量 QPS :


    @RequestMapping("/testLimit")
    @CurrentLimiter(QPS = 5)
    public String testLimit1() throws InterruptedException {
        //业务处理......
        return "success";
    }


@CurrentLimiter(QPS = 5)  这个注解里的QPS =5 就是当前接口的每秒的并发量 。


最后再针对限流的访问做一个返回处理,新建MyCurrentLimitHandler.class :


import cn.yueshutong.springbootstartercurrentlimiting.annotation.CurrentLimiter;
import cn.yueshutong.springbootstartercurrentlimiting.handler.CurrentAspectHandler;
import com.alibaba.fastjson.JSONObject;
import org.aspectj.lang.ProceedingJoinPoint;
import org.springframework.stereotype.Component;
/**
 * @Author : JCccc
 * @CreateTime : 2020/4/20
 * @Description :
 **/
@Component
public class MyCurrentLimitHandler  implements CurrentAspectHandler {
    @Override
    public Object around(ProceedingJoinPoint pjp, CurrentLimiter rateLimiter)  {
        //限流的返回数据可以自己根据需求场景设计
        JSONObject jsonObject=new JSONObject();
        jsonObject.put("resultCode",10011);
        jsonObject.put("msg","接口访问繁忙,休息一下");
        return jsonObject.toString();
    }
}


ps: 有兴趣的可以点进源码里面看,其实是我们非常熟悉的注解方式使用AOP的环绕。


第二部分,接口限流测试


我这边使用的是 Apache JMeter 压测工具给大家做个测试(大家不想额外用这种测试工具的话,设置并发QPS=1,然后手速快一点,再配合在接口里面sleep一下,也是能测试的,不过作为东道主,我就用这些专业点的给你们展示),


设置每秒10个并发


image.png


调用看下结果:


接口调用成功的返回是 success:


image.png


因为限流返回的失败处理是:


image.png



整体的结果是:


image.png


ps:提前跟小杠们说的 不是代码里设置的每秒5个并发么,为什么成功的才4个?


这个问题不做回应。


好了,这次springboot整合Current-Limiting 实现接口限流 就到此吧,其实看到yml的配置项,是可以设置系统级别的限流,但是该篇不做介绍,这些可以自己调试下就好,都是开箱即用。


ps:


这个限流jar不同版本差异还是存在的,如果是简单的单机使用,就用0.0.1版本即可:


0.0.1.RELEASE:单点限流,注解+全局配置。


0.0.2.RELEASE:结合Redis实现集群限流,使用选举算法选出Master节点。


0.0.3.RELEASE:可自定义规则限流、增加令牌桶算法与漏桶算法的切换,纳秒级并发控制。


0.0.4.RELEASE:解决大规模限流器注册而长时间不使用导致的内存泄漏问题,定时删除过期的限流器对象,秒级。统一线程池管理,并可定义核心线程数。


0.0.5.RELEASE:去掉集群限流器的锁操作,改进令牌桶算法,实现真正的无锁限流。使用享元模式减少大量对象的创建。


0.0.6.RELEASE:使用Lua脚本减少Redis网络请求次数。


0.0.7.RELEASE:从SpringBoot2切换到SpringBoot1.5开发。


0.0.8.RELEASE:修复了0.0.7版本的集群限流失效bug。



image.png

相关文章
|
4天前
|
Java API 微服务
【Spring Boot系列】通过OpenAPI规范构建微服务服务接口
【4月更文挑战第5天】通过OpenAPI接口构建Spring Boot服务RestAPI接口
24 0
|
22天前
|
NoSQL Java Redis
SpringBoot集成Redis解决表单重复提交接口幂等(亲测可用)
SpringBoot集成Redis解决表单重复提交接口幂等(亲测可用)
73 0
|
22天前
|
Java API Spring
SpringBoot项目调用HTTP接口5种方式你了解多少?
SpringBoot项目调用HTTP接口5种方式你了解多少?
71 2
|
2月前
|
JSON 前端开发 Java
SpringBoot 的优雅的接口参数验证
1. 为什么需要参数验证 在应用程序的开发中,我们经常会遇到需要保证传入参数的正确性的情况。例如,当我们在注册用户时,需要验证用户填写的表单数据是否符合规范,是否缺少必填字段,或者格式是否正确,等等。如果不对参数进行验证,我们的应用程序可能会因此受到攻击或者运行出错。 为了保证参数的正确性,我们需要使用参数验证机制,来检测并处理传入的参数格式是否符合规范。 2. 如何进行参数验证 Spring Boot内置了一个很强大的参数验证框架——JSR 303 Bean Validation 标准,它可以对我们的实体类参数进行校验,并且可以给我们提供详细的错误提示信息。
48 1
|
22天前
|
Java Spring
SpringBoot+async异步调用接口以及几个任务同时完成和异步接口实现和调用
SpringBoot+async异步调用接口以及几个任务同时完成和异步接口实现和调用
22 0
|
1月前
|
Java API Maven
SpringBoot 调用外部接口的三种方式--学习总结
SpringBoot 调用外部接口的三种方式--学习总结
38 1
|
1月前
|
NoSQL Java API
SpringBoot项目中防止表单重复提交的两种方法(自定义注解解决API接口幂等设计和重定向)
SpringBoot项目中防止表单重复提交的两种方法(自定义注解解决API接口幂等设计和重定向)
37 0
|
1月前
|
前端开发 Java Maven
java集成opencv(不踩坑),实现人脸检测小demo(含上传人像图片识别接口),windows,IDEA,Springboot
java集成opencv(不踩坑),实现人脸检测小demo(含上传人像图片识别接口),windows,IDEA,Springboot
176 0
|
1月前
|
算法 Java 开发工具
使用阿里云KMS产品针对 Springboot 接口参数加密解密功能
针对Springboot里面使用开源工具使用加解密,替换成阿里云KMS产品进行加解密;
141 1