This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 963c0e28ff [ISSUE #9741] Optimize authorization whitelist lookup
efficiency (#9760)
963c0e28ff is described below
commit 963c0e28ff0708520ef3c741b6092ed4aedec0c2
Author: majialong <[email protected]>
AuthorDate: Thu Nov 20 10:31:46 2025 +0800
[ISSUE #9741] Optimize authorization whitelist lookup efficiency (#9760)
* [ISSUE #9741] Optimize authorization whitelist lookup efficiency
* Remove unused import
* Fix get authorization metadata provider.
---
.../authorization/strategy/AbstractAuthorizationStrategy.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AbstractAuthorizationStrategy.java
b/auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AbstractAuthorizationStrategy.java
index 849c3082d3..fef7969ade 100644
---
a/auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AbstractAuthorizationStrategy.java
+++
b/auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AbstractAuthorizationStrategy.java
@@ -16,8 +16,8 @@
*/
package org.apache.rocketmq.auth.authorization.strategy;
-import java.util.ArrayList;
-import java.util.List;
+import java.util.HashSet;
+import java.util.Set;
import java.util.function.Supplier;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.auth.authorization.context.AuthorizationContext;
@@ -30,7 +30,7 @@ import org.apache.rocketmq.common.utils.ExceptionUtils;
public abstract class AbstractAuthorizationStrategy implements
AuthorizationStrategy {
protected final AuthConfig authConfig;
- protected final List<String> authorizationWhitelist = new ArrayList<>();
+ protected final Set<String> authorizationWhiteSet = new HashSet<>();
protected final AuthorizationProvider<AuthorizationContext>
authorizationProvider;
public AbstractAuthorizationStrategy(AuthConfig authConfig, Supplier<?>
metadataService) {
@@ -42,7 +42,7 @@ public abstract class AbstractAuthorizationStrategy
implements AuthorizationStra
if (StringUtils.isNotBlank(authConfig.getAuthorizationWhitelist())) {
String[] whitelist =
StringUtils.split(authConfig.getAuthorizationWhitelist(), ",");
for (String rpcCode : whitelist) {
- this.authorizationWhitelist.add(StringUtils.trim(rpcCode));
+ this.authorizationWhiteSet.add(StringUtils.trim(rpcCode));
}
}
}
@@ -57,7 +57,7 @@ public abstract class AbstractAuthorizationStrategy
implements AuthorizationStra
if (this.authorizationProvider == null) {
return;
}
- if (this.authorizationWhitelist.contains(context.getRpcCode())) {
+ if (this.authorizationWhiteSet.contains(context.getRpcCode())) {
return;
}
try {