lxy/zhub-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增：redis 插件密码解密处理逻辑

Browse Source
This commit is contained in:
梁显优 2023-05-08 16:29:05 +08:00
parent bca3ac6590
commit 54369c08dc
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/org/redkalex/cache/redis/RedisCacheSource.java vendored
View File

@ -28,6 +28,7 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantLock;
import java.util.function.Function;
import java.util.logging.Level; import java.util.logging.Level;
import java.util.logging.Logger; import java.util.logging.Logger;
@ -147,6 +148,10 @@ public class RedisCacheSource extends AbstractRedisSource {
int maxconns = conf.getIntValue(CACHE_SOURCE_MAXCONNS, urlmaxconns); int maxconns = conf.getIntValue(CACHE_SOURCE_MAXCONNS, urlmaxconns);
int pipelines = conf.getIntValue(CACHE_SOURCE_PIPELINES, urlpipelines); int pipelines = conf.getIntValue(CACHE_SOURCE_PIPELINES, urlpipelines);
RedisCacheClient old = this.client; RedisCacheClient old = this.client;
if (passwordDecoder != null) {
password = passwordDecoder.apply(password);
}
this.client = new RedisCacheClient(resourceName(), ioGroup, resourceName() + "." + db, new ClientAddress(address), maxconns, pipelines, this.client = new RedisCacheClient(resourceName(), ioGroup, resourceName() + "." + db, new ClientAddress(address), maxconns, pipelines,
password == null || password.isEmpty() ? null : new RedisCacheReqAuth(password), db > 0 ? new RedisCacheReqDB(db) : null); password == null || password.isEmpty() ? null : new RedisCacheReqAuth(password), db > 0 ? new RedisCacheReqDB(db) : null);
if (old != null) { if (old != null) {
@ -1787,4 +1792,10 @@ public class RedisCacheSource extends AbstractRedisSource {
public <T> Map<String, Collection<T>> getCollectionMap(final boolean set, final Type componentType, String... keys) { public <T> Map<String, Collection<T>> getCollectionMap(final boolean set, final Type componentType, String... keys) {
return (Map) getCollectionMapAsync(set, componentType, keys).join(); return (Map) getCollectionMapAsync(set, componentType, keys).join();
} }
private static Function<String, String> passwordDecoder = null;
public static void setPasswordDecoder(Function decoder) {
passwordDecoder = decoder;
}
} }