1.前言
自定义注解实现Redis分布式锁、手动控制事务和根据异常名字或内容限流的三合一的功能https://mp.weixin.qq.com/s/aW4PU_wlNVfzPc6uGFnndA
https://blog.csdn.net/qq_34905631/article/details/133325782?spm=1001.2014.3001.5501
自定义redission装配和集成分布式开源限流业务组件ratelimiter-spring-boot-starter的正确姿势https://mp.weixin.qq.com/s/TFbKOLMZfu5nuVRzhd9oVg
https://blog.csdn.net/qq_34905631/article/details/133845032?spm=1001.2014.3001.5501
在项目中使用下来就觉得能不能把这两个结合起来使用？做成一个启动器starter,不然这个项目要用，要去拷贝一次重复的代码，重复的代码只要写一次就行，抽成可复用的工具、SDK或者starter,这样就复用性就非常的好，重复的事情不用去重复的搞，集成效率大大提高，使用也更方便，下面揭晓这个starter是如何实现的.
2.原理
使用了两层动态代理，内层是aop的注解切面代理，外层是jdk的动态代理，就这么简单，具体可以去看源码。
3.使用
3.1项目地址
https://gitee.com/BigBigFeiFei/biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-start
https://github.com/BigBigFeiFei/biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-start
3.2依赖
<dependency> <groupId>io.gitee.bigbigfeifeigroupId> <artifactId>biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-startartifactId> <version>1.0version>dependency>
<dependency> <groupId>io.github.bigbigfeifeigroupId> <artifactId>biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-startartifactId> <version>1.0version>dependency>
3.3使用说明
## biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-start启动器1. 项目中引入依赖如下：下面是一个新项目demo的完整pom需要引入的依赖，根据自己项目依赖删减如果项目中引入如下依赖有缺少依赖需要自行补全所需依赖或者是有依赖冲突需要解决依赖冲突，项目才可以正常启动运行起来```<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0modelVersion>
<groupId>org.examplegroupId> <artifactId>TestLimiterartifactId> <version>1.0-SNAPSHOTversion>
<properties> <java.version>1.8java.version> <spring-cloud.version>Hoxton.SR9spring-cloud.version> <spring-cloud-alibaba.version>2.2.2.RELEASEspring-cloud-alibaba.version> <commons-collections4.vsersion>4.1commons-collections4.vsersion> <spring-boot.version>2.3.12.RELEASEspring-boot.version> <spring-cloud.version>Hoxton.SR9spring-cloud.version> properties>
<dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-dependenciesartifactId> <version>${spring-boot.version}version> <type>pomtype> <scope>importscope> dependency> <dependency> <groupId>org.springframework.cloudgroupId> <artifactId>spring-cloud-dependenciesartifactId> <version>${spring-cloud.version}version> <type>pomtype> <scope>importscope> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-alibaba-dependenciesartifactId> <version>${spring-cloud-alibaba.version}version> <type>pomtype> <scope>importscope> dependency> dependencies> dependencyManagement>
<dependencies> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-webartifactId> <version>${spring-boot.version}version> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starterartifactId> <version>${spring-boot.version}version> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-configartifactId> dependency> <dependency> <groupId>com.alibaba.cloudgroupId> <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-testartifactId> <scope>testscope> dependency> <dependency> <groupId>com.alibabagroupId> <artifactId>fastjsonartifactId> <version>1.2.75version> <scope>compilescope> dependency> <dependency> <groupId>mysqlgroupId> <artifactId>mysql-connector-javaartifactId> <scope>runtimescope> dependency> <dependency> <groupId>com.github.taptapgroupId> <artifactId>ratelimiter-spring-boot-starterartifactId> <version>1.3version> dependency> <dependency> <groupId>io.gitee.bigbigfeifeigroupId> <artifactId>biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-startartifactId> <version>1.0version> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-autoconfigureartifactId> <version>2.3.12.RELEASEversion> dependency> <dependency> <groupId>org.projectlombokgroupId> <artifactId>lombokartifactId> <scope>providedscope> dependency> <dependency> <groupId>org.springframeworkgroupId> <artifactId>spring-txartifactId> <version>5.2.15.RELEASEversion> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-data-redisartifactId> <version>2.3.9.RELEASEversion> dependency> <dependency> <groupId>org.springframework.bootgroupId> <artifactId>spring-boot-starter-jdbcartifactId> <version>2.3.12.RELEASEversion> dependency> <dependency> <groupId>com.zaxxergroupId> <artifactId>HikariCPartifactId> <version>3.4.0version> dependency> <dependency> <groupId>com.alibaba.nacosgroupId> <artifactId>nacos-clientartifactId> <version>2.1.2version> dependency> <dependency> <groupId>org.apache.commonsgroupId> <artifactId>commons-pool2artifactId> <version>2.6.0version> dependency> <dependency> <groupId>org.apache.commonsgroupId> <artifactId>commons-lang3artifactId> <version>3.10version> dependency> dependencies>
<build> <plugins> <plugin> <groupId>org.apache.maven.pluginsgroupId> <artifactId>maven-surefire-pluginartifactId> <version>2.22.1version> <configuration> <skipTests>trueskipTests> configuration> plugin> plugins> build>
project>``` 2. nacos配置如下:```# 限流ratelimiter配置spring: application: name: xxxxx-server ratelimiter: enabled: true redis-address: redis://ip:port redis-password: xxxxxx response-body: "您请求的太快了,请慢点,不然会有点受不了哦!" status-code: 500 # 数据源需要配置,如果是多数据源将这里改成多数据源配置 datasource: url: jdbc:mysql://xxxx:3306/xxxxxx?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai username: root password: xxxxx driver-class-name: com.mysql.cj.jdbc.Driver #redis配置,redis连接池使用默认的lettuce连接池 redis: host: ip port: port password: 12345678 database: 6 lettuce: pool: # 最大空闲连接数 max-idle: 20 # 可以分配的最大连接数 max-active: 50 # 阻塞的最大时间 max-wait: 10000 # 最小空闲连接数 min-idle: 10# redison配置 redisson: lock: enabled: true config: address: redis://ip:port password: xxxxxx# 限流业务接口配置# interfaceName名称可以配置一个相同的，methodName配置不同的方法名称# 如果interfaceName接口有多个方法需要限流操作就可以配置下面下标0,1的配置# 也可以配置不同的interfaceName对应不同的methodName的配置# 相同的methodName对应不同的methodName的配置# 不要多次配置相同的interfaceName对应相同的methodName的配置limit: lps: - interfaceName: xxxxrService1 # 接口类名称首字母小写 methodName: testLimit1 # 实现类接口名称 tokenBucketRate: 5 # 可以不配有默认值 bucketCapacity: 1000 # 可以不配有默认值 requestedTokens: 1 # 可以不配有默认值 enabled: true # 可以不配有默认值(默认开启) - interfaceName: xxxxrService1 methodName: testLimit2 tokenBucketRate: 5 bucketCapacity: 1000 requestedTokens: 1 enabled: true - interfaceName: xxxxrService2 methodName: testLimit3 tokenBucketRate: 5 bucketCapacity: 1000 requestedTokens: 1 enabled: true ```3. 启动类上加入如下注解： @@EnableZlfBizRateLimiter4. 功能说明 4.1 可以单独使用redissonLock分布式锁(@BizIdempotentManualCtrlTransLimiterAnno注解) 4.2 可以单独使用手动控制事务提交，异常事务回滚(@BizIdempotentManualCtrlTransLimiterAnno注解) 4.3 可以组合使用4.1和4.2 4.4 可以单独使用ratelimiter功能(注解方式-ratelimiter开源组件自带的注解) ratelimiter开源限流组件github项目地址：https://github.com/TapTap/ratelimiter-spring-boot-starter 4.5 可以单独使用ratelimiter的令牌桶限流 + 滑动窗口限流 4.6 可以组合使用4.1、4.2、4.4 4.7 可以组合使用4.1、4.2、4.55. 项目中使用```# service层定义一个接口public interface xxxRateLimiterService {
RestResponse testLimit(String key, String params);
}# service层定义一个接口实现类@Slf4j@Servicepublic class xxxBizRateLimiterServiceImpl implements xxxBizRateLimiterService {
#分布式锁和手动控制事务注解(aop + 自定义注解实现),根据需要加该注解 #方法格式必须为public修饰,方法第一参数必须为String类型,该参数约定是作为分布式锁的key(传入啥格式就是啥格式) #方法中不用使用try/catch否则事务不会回滚,如果使用了try/catch-->在catch中需要把异常抛出(在catch里面throw new RuntimeException(e.getMessage());将异常抛出)到外层给aop代理try/catch才能回滚事务 @BizIdempotentManualCtrlTransLimiterAnno(isOpenManualCtrlTrans = true, isOpenRedissonLock = true) @Override public RestResponse testLimit(String key, String params) { log.info("=========BizRateLimiterServiceImpl方法开始key:{},params:{}=============", key, params); return RestResponse.success(Boolean.TRUE); } }
# @RestController@RequestMapping("limit")public class xxxRateLimiterController {
#该biz-ratelimiter-redissonlock-manualctrltrans-spring-boot-start组件提供了一套service接口,直接调用即可 @Autowired private BizRateLimiterService bizRateLimiterService;
#上面xxxRateLimiterService接口的bean @Autowired private xxxBizRateLimiterService xxxBizRateLimiterService;
@GetMapping("/testLimit") public RestResponse testLimit() { #先判断一个配置对应的接口是否开启4.5的功能 #接口调用的使用index下标需要对应好(配置和接口的调用的时候是通过index来找到是哪个接口的哪个方法) if (bizRateLimiterService.enabled(0)) { # 滑动窗口限流key,滑动窗口时间是3s内,该key可以传一个唯一的标识,比如用户的id,订单号orderNo,也就是3s内可以限制根据用户唯一标识只能点一次 String timeWindowKey = "123456"; # 这里获取接口的代理对象,采用jdk动态代理将原有的接口进行了增强 XxxBizRateLimiterService xxxBizRateLimiterService = (XxxBizRateLimiterService ) bizRateLimiterService.getBizRateLimiterProxy(0, xxxBizRateLimiterService , XxxBizRateLimiterService .class, timeWindowKey); # 调用目标方法相当于做了两层代理,外层是jdk代理增强实现令牌桶限流 + 滑动窗口限流 # 内层是aop的动态代理,自定义了一个注解,增强实现了分布式锁和手动控制事务还有其它功能增强 return xxxBizRateLimiterService .testLimit("testLimit", "6666"); } # 这里是没有开启令牌桶限流 + 滑动窗口限流限流走的是aop注解切面或者是没有aop注解切面的原对象的方法 return xxxBizRateLimiterService .testLimit("testLimit", "6666"); }}```6.总结本来可以将限流的逻辑融合到注解中，但是注解中的逻辑嵌套又比较多，所以不去改原有注解的逻辑，很容易改出bug的，所以采用jdk动态代理来做了拓展，让ratelimiter的令牌桶限流 + 滑动窗口限流 和 @BizIdempotentManualCtrlTransLimiterAnno注解完美结合使用,本质上是做了两层代理（外层jdk动态代理 + 内层的aop自定义注解切面拦截代理），可以根据配置灵活设置参数简化重复代码，不用每个项目都去拷贝重复的代码，只需要引入一个依赖，根据约定的配置在利用springBoot的自动装配能力就可以消除重复代码，让代码化繁为简，业务代码写的更加帅更健壮，更加优雅更加干净更加整洁更加美观，可拓展性、可复用性和可维护性得到非常大的提升。7.功能简介限流ratelimiter与注解实现分布式锁、手动控制事务相结合的starter启动器，可以实现接口总体限流、滑动窗口限流 + 分布式锁(防止多次点击)，手动控制事务多表操作异常可以自动回滚事务，保证多表数据一致性
4.总结
通过实现了这个启动器就可以将之前搞的东西完美结合起来使用，希望我的分享对你有所启发和帮助，请一键三连，么么么哒！