Skip to content

Commit 600dd24

Browse files
hengboyhengboy
committed
Adapt "minbox-ratelimiter" component
1 parent 3fcda1f commit 600dd24

File tree

24 files changed

+48
-1124
lines changed

24 files changed

+48
-1124
lines changed

‎api-boot-project/api-boot-autoconfigure/pom.xml‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,16 @@
126126
<artifactId>minbox-mongo-client-settings</artifactId>
127127
<optional>true</optional>
128128
</dependency>
129+
<dependency>
130+
<groupId>org.minbox.framework</groupId>
131+
<artifactId>minbox-ratelimiter</artifactId>
132+
<optional>true</optional>
133+
</dependency>
134+
<dependency>
135+
<groupId>org.minbox.framework</groupId>
136+
<artifactId>minbox-resource-load</artifactId>
137+
<optional>true</optional>
138+
</dependency>
129139

130140
<!--Others-->
131141
<dependency>

‎api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/ratelimiter/ApiBootRateLimiterAutoConfiguration.java‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,13 @@
1717

1818
package org.minbox.framework.api.boot.autoconfigure.ratelimiter;
1919

20-
import org.minbox.framework.api.boot.limiter.ApiBootRateLimiter;
21-
import org.minbox.framework.api.boot.limiter.aop.advisor.ApiBootRateLimiterAdvisor;
22-
import org.minbox.framework.api.boot.limiter.aop.interceptor.ApiBootRateLimiterMethodInterceptor;
23-
import org.minbox.framework.api.boot.limiter.centre.RateLimiterConfigCentre;
24-
import org.minbox.framework.api.boot.limiter.centre.support.DefaultRateLimiterConfigCentre;
25-
import org.minbox.framework.api.boot.limiter.result.RateLimiterOverFlowResponse;
26-
import org.minbox.framework.api.boot.limiter.support.GoogleGuavaRateLimiter;
20+
import org.minbox.framework.limiter.MinBoxRateLimiter;
21+
import org.minbox.framework.limiter.aop.advisor.RateLimiterAdvisor;
22+
import org.minbox.framework.limiter.aop.interceptor.RateLimiterMethodInterceptor;
23+
import org.minbox.framework.limiter.centre.RateLimiterConfigCentre;
24+
import org.minbox.framework.limiter.centre.support.DefaultRateLimiterConfigCentre;
25+
import org.minbox.framework.limiter.result.RateLimiterOverFlowResponse;
26+
import org.minbox.framework.limiter.support.GoogleGuavaRateLimiter;
2727
import org.springframework.beans.factory.ObjectProvider;
2828
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
2929
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
@@ -41,7 +41,7 @@
4141
* @author 恒宇少年
4242
*/
4343
@Configuration
44-
@ConditionalOnClass(ApiBootRateLimiter.class)
44+
@ConditionalOnClass(MinBoxRateLimiter.class)
4545
@EnableConfigurationProperties(ApiBootRateLimiterProperties.class)
4646
@AutoConfigureAfter(WebMvcAutoConfiguration.class)
4747
@Import({ApiBootRateLimiterRedisAutoConfiguration.class, ApiBootRateLimiterNacosConfigConfiguration.class})
@@ -69,7 +69,7 @@ public ApiBootRateLimiterAutoConfiguration(ApiBootRateLimiterProperties apiBootR
6969
@Bean
7070
@ConditionalOnMissingBean
7171
@ConditionalOnMissingClass("org.springframework.data.redis.core.RedisTemplate")
72-
public ApiBootRateLimiter googleGuavaRateLimiter(RateLimiterConfigCentre rateLimiterConfigCentre) {
72+
public MinBoxRateLimiter googleGuavaRateLimiter(RateLimiterConfigCentre rateLimiterConfigCentre) {
7373
return new GoogleGuavaRateLimiter(apiBootRateLimiterProperties.isEnableGlobalQps() ? apiBootRateLimiterProperties.getGlobalQps() : 0L, rateLimiterConfigCentre);
7474
}
7575

@@ -88,13 +88,13 @@ public RateLimiterConfigCentre defaultRateLimiterConfigCentre() {
8888
/**
8989
* ApiBoot RateLimiter Pointcut Advisor
9090
*
91-
* @param apiBootRateLimiterMethodInterceptor ResourceLoad Annotation Method Interceptor
91+
* @param rateLimiterMethodInterceptor ResourceLoad Annotation Method Interceptor
9292
* @return ApiBootRateLimiterAdvisor
9393
*/
9494
@Bean
9595
@ConditionalOnMissingBean
96-
ApiBootRateLimiterAdvisor rateLimiterAdvisor(ApiBootRateLimiterMethodInterceptor apiBootRateLimiterMethodInterceptor) {
97-
return new ApiBootRateLimiterAdvisor(apiBootRateLimiterMethodInterceptor);
96+
RateLimiterAdvisor rateLimiterAdvisor(RateLimiterMethodInterceptor rateLimiterMethodInterceptor) {
97+
return new RateLimiterAdvisor(rateLimiterMethodInterceptor);
9898
}
9999

100100
/**
@@ -106,7 +106,7 @@ ApiBootRateLimiterAdvisor rateLimiterAdvisor(ApiBootRateLimiterMethodInterceptor
106106
*/
107107
@Bean
108108
@ConditionalOnMissingBean
109-
ApiBootRateLimiterMethodInterceptor rateLimiterMethodInterceptor(ApiBootRateLimiter apiBootRateLimiter) {
110-
return new ApiBootRateLimiterMethodInterceptor(apiBootRateLimiter, rateLimiterOverFlowResponse);
109+
RateLimiterMethodInterceptor rateLimiterMethodInterceptor(MinBoxRateLimiter apiBootRateLimiter) {
110+
return new RateLimiterMethodInterceptor(apiBootRateLimiter, rateLimiterOverFlowResponse);
111111
}
112112
}

‎api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/ratelimiter/ApiBootRateLimiterNacosConfigConfiguration.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
import com.alibaba.nacos.api.NacosFactory;
2323
import com.alibaba.nacos.api.config.ConfigService;
2424
import com.alibaba.nacos.api.exception.NacosException;
25-
import org.minbox.framework.api.boot.limiter.centre.RateLimiterConfigCentre;
26-
import org.minbox.framework.api.boot.limiter.centre.support.NacosRateLimiterConfigCentre;
25+
import org.minbox.framework.limiter.centre.RateLimiterConfigCentre;
26+
import org.minbox.framework.limiter.centre.support.NacosRateLimiterConfigCentre;
2727
import org.slf4j.Logger;
2828
import org.slf4j.LoggerFactory;
2929
import org.springframework.beans.factory.annotation.Qualifier;

‎api-boot-project/api-boot-autoconfigure/src/main/java/org/minbox/framework/api/boot/autoconfigure/ratelimiter/ApiBootRateLimiterRedisAutoConfiguration.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,9 @@
1616
*/
1717

1818
package org.minbox.framework.api.boot.autoconfigure.ratelimiter;
19-
import org.minbox.framework.api.boot.limiter.ApiBootRateLimiter;
20-
import org.minbox.framework.api.boot.limiter.centre.RateLimiterConfigCentre;
21-
import org.minbox.framework.api.boot.limiter.support.RedisLuaRateLimiter;
19+
import org.minbox.framework.limiter.MinBoxRateLimiter;
20+
import org.minbox.framework.limiter.centre.RateLimiterConfigCentre;
21+
import org.minbox.framework.limiter.support.RedisLuaRateLimiter;
2222
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
2323
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
2424
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
@@ -56,7 +56,7 @@ public ApiBootRateLimiterRedisAutoConfiguration(ApiBootRateLimiterProperties api
5656
*/
5757
@Bean
5858
@ConditionalOnMissingBean
59-
public ApiBootRateLimiter redisLuaRateLimiter(RedisTemplate redisTemplate, RateLimiterConfigCentre rateLimiterConfigCentre) {
59+
public MinBoxRateLimiter redisLuaRateLimiter(RedisTemplate redisTemplate, RateLimiterConfigCentre rateLimiterConfigCentre) {
6060
return new RedisLuaRateLimiter(apiBootRateLimiterProperties.isEnableGlobalQps() ? apiBootRateLimiterProperties.getGlobalQps() : 0L, rateLimiterConfigCentre, redisTemplate);
6161
}
6262
}

‎api-boot-project/api-boot-dependencies/pom.xml‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
<!--Minbox Projects-->
2626
<minbox.version>1.0.5.RELEASE</minbox.version>
2727
<minbox-logging.version>1.0.5.RELEASE</minbox-logging.version>
28+
<minbox-ratelimiter.version>1.0.0.RELEASE</minbox-ratelimiter.version>
29+
<minbox-resource-load.version>1.0.0.RELEASE</minbox-resource-load.version>
2830
<minbox-mongo-client-settings.version>1.0.0.RELEASE</minbox-mongo-client-settings.version>
2931
<code.builder.core.version>1.0.5.RELEASE</code.builder.core.version>
3032
<mybatis-enhance.version>1.1.3.RELEASE</mybatis-enhance.version>
@@ -164,6 +166,16 @@
164166
<artifactId>mybatis-enhance-dsl</artifactId>
165167
<version>${mybatis-enhance.version}</version>
166168
</dependency>
169+
<dependency>
170+
<groupId>org.minbox.framework</groupId>
171+
<artifactId>minbox-ratelimiter</artifactId>
172+
<version>${minbox-ratelimiter.version}</version>
173+
</dependency>
174+
<dependency>
175+
<groupId>org.minbox.framework</groupId>
176+
<artifactId>minbox-resource-load</artifactId>
177+
<version>${minbox-resource-load.version}</version>
178+
</dependency>
167179

168180

169181
<!--ApiBoot Dependencies-->

‎api-boot-project/api-boot-starters/api-boot-starter-rate-limiter/pom.xml‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,10 @@
4949
<groupId>org.minbox.framework</groupId>
5050
<artifactId>api-boot-starter</artifactId>
5151
</dependency>
52+
<dependency>
53+
<groupId>org.minbox.framework</groupId>
54+
<artifactId>minbox-ratelimiter</artifactId>
55+
</dependency>
5256
<dependency>
5357
<groupId>com.google.guava</groupId>
5458
<artifactId>guava</artifactId>

‎api-boot-project/api-boot/src/main/java/org/minbox/framework/api/boot/limiter/ApiBootRateLimiter.java‎

Lines changed: 0 additions & 45 deletions
This file was deleted.

‎api-boot-project/api-boot/src/main/java/org/minbox/framework/api/boot/limiter/annotation/RateLimiter.java‎

Lines changed: 0 additions & 39 deletions
This file was deleted.

‎api-boot-project/api-boot/src/main/java/org/minbox/framework/api/boot/limiter/aop/advisor/ApiBootRateLimiterAdvisor.java‎

Lines changed: 0 additions & 94 deletions
This file was deleted.

0 commit comments

Comments
 (0)