lsm/sa-token
1
0
Fork 0
mirror of https://gitee.com/dromara/sa-token.git synced 2025-04-05 17:37:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

alone-redis 插件兼容低版本

Browse Source
This commit is contained in:
click33 2023-06-23 03:15:51 +08:00
parent 4584388c25
commit dda14fb936
2 changed files with 31 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
sa-token-demo/sa-token-demo-alone-redis/pom.xml
View File

@ -11,6 +11,7 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.14</version>
<!--<version>2.3.3.RELEASE</version>-->
<relativePath/>
</parent>

35
sa-token-plugin/sa-token-alone-redis/src/main/java/cn/dev33/satoken/dao/alone/SaAloneRedisInject.java
View File

@ -95,13 +95,23 @@ public class SaAloneRedisInject implements EnvironmentAware{
redisConfig.setDatabase(cfg.getDatabase());
redisConfig.setPassword(RedisPassword.of(cfg.getPassword()));
redisConfig.setDatabase(cfg.getDatabase());
redisConfig.setUsername(cfg.getUsername());
// 低版本没有 username 属性，捕获异常给个提示即可，无需退出程序
try {
redisConfig.setUsername(cfg.getUsername());
} catch (NoSuchMethodError e){
System.err.println(e.getMessage());
}
redisAloneConfig = redisConfig;
} else if (pattern.equals("cluster")){
// 普通集群模式
RedisClusterConfiguration redisClusterConfig = new RedisClusterConfiguration();
redisClusterConfig.setUsername(cfg.getUsername());
// 低版本没有 username 属性，捕获异常给个提示即可，无需退出程序
try {
redisClusterConfig.setUsername(cfg.getUsername());
} catch (NoSuchMethodError e){
System.err.println(e.getMessage());
}
redisClusterConfig.setPassword(RedisPassword.of(cfg.getPassword()));
RedisProperties.Cluster cluster = cfg.getCluster();
@ -117,7 +127,12 @@ public class SaAloneRedisInject implements EnvironmentAware{
// 哨兵集群模式
RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration();
redisSentinelConfiguration.setDatabase(cfg.getDatabase());
redisSentinelConfiguration.setUsername(cfg.getUsername());
// 低版本没有 username 属性，捕获异常给个提示即可，无需退出程序
try {
redisSentinelConfiguration.setUsername(cfg.getUsername());
} catch (NoSuchMethodError e){
System.err.println(e.getMessage());
}
redisSentinelConfiguration.setPassword(RedisPassword.of(cfg.getPassword()));
RedisProperties.Sentinel sentinel = cfg.getSentinel();
@ -134,7 +149,12 @@ public class SaAloneRedisInject implements EnvironmentAware{
// socket 连接单体 Redis
RedisSocketConfiguration redisSocketConfiguration = new RedisSocketConfiguration();
redisSocketConfiguration.setDatabase(cfg.getDatabase());
redisSocketConfiguration.setUsername(cfg.getUsername());
// 低版本没有 username 属性，捕获异常给个提示即可，无需退出程序
try {
redisSocketConfiguration.setUsername(cfg.getUsername());
} catch (NoSuchMethodError e){
System.err.println(e.getMessage());
}
redisSocketConfiguration.setPassword(RedisPassword.of(cfg.getPassword()));
String socket = environment.getProperty(ALONE_PREFIX + ".socket", "");
redisSocketConfiguration.setSocket(socket);
@ -147,7 +167,12 @@ public class SaAloneRedisInject implements EnvironmentAware{
int port = cfg.getPort();
RedisStaticMasterReplicaConfiguration redisStaticMasterReplicaConfiguration = new RedisStaticMasterReplicaConfiguration(hostName, port);
redisStaticMasterReplicaConfiguration.setDatabase(cfg.getDatabase());
redisStaticMasterReplicaConfiguration.setUsername(cfg.getUsername());
// 低版本没有 username 属性，捕获异常给个提示即可，无需退出程序
try {
redisStaticMasterReplicaConfiguration.setUsername(cfg.getUsername());
} catch (NoSuchMethodError e){
System.err.println(e.getMessage());
}
redisStaticMasterReplicaConfiguration.setPassword(RedisPassword.of(cfg.getPassword()));
redisAloneConfig = redisStaticMasterReplicaConfiguration;