lsm/file-online-preview
1
0
Fork 0
mirror of https://gitee.com/kekingcn/file-online-preview.git synced 2025-08-20 09:26:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

支持redis集群配置，升级redisson版本依赖

Browse Source
This commit is contained in:
王跑跑 2025-02-17 09:47:50 +08:00
parent 2230cfa52b
commit f5df6239d0
2 changed files with 45 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -16,7 +16,7 @@
<xdocreport.version>1.0.6</xdocreport.version> <xdocreport.version>1.0.6</xdocreport.version>
<xstream.version>1.4.20</xstream.version> <xstream.version>1.4.20</xstream.version>
<junrar.version>7.5.5</junrar.version> <junrar.version>7.5.5</junrar.version>
<redisson.version>3.2.0</redisson.version> <redisson.version>3.16.6</redisson.version>
<sevenzipjbinding.version>16.02-2.01</sevenzipjbinding.version> <sevenzipjbinding.version>16.02-2.01</sevenzipjbinding.version>
<jchardet.version>1.0</jchardet.version> <jchardet.version>1.0</jchardet.version>
<antlr.version>2.7.7</antlr.version> <antlr.version>2.7.7</antlr.version>

53
server/src/main/java/cn/keking/config/RedissonConfig.java
View File

@ -43,33 +43,68 @@ public class RedissonConfig {
private String codec="org.redisson.codec.JsonJacksonCodec"; private String codec="org.redisson.codec.JsonJacksonCodec";
// @Bean
// Config config() throws Exception {
// Config config = new Config();
// config.useSingleServer().setAddress(address)
// .setConnectionMinimumIdleSize(connectionMinimumIdleSize)
// .setConnectionPoolSize(connectionPoolSize)
// .setDatabase(database)
// .setDnsMonitoringInterval(dnsMonitoringInterval)
// .setSubscriptionConnectionMinimumIdleSize(subscriptionConnectionMinimumIdleSize)
// .setSubscriptionConnectionPoolSize(subscriptionConnectionPoolSize)
// .setSubscriptionsPerConnection(subscriptionsPerConnection)
// .setClientName(clientName)
// .setRetryAttempts(retryAttempts)
// .setRetryInterval(retryInterval)
// .setTimeout(timeout)
// .setConnectTimeout(connectTimeout)
// .setIdleConnectionTimeout(idleConnectionTimeout)
// .setPassword(StringUtils.trimToNull(password));
// Codec codec=(Codec) ClassUtils.forName(getCodec(), ClassUtils.getDefaultClassLoader()).newInstance();
// config.setCodec(codec);
// config.setThreads(thread);
// config.setEventLoopGroup(new NioEventLoopGroup());
// return config;
// }
/**
* redis集群配置 redisson版本需要切换到3.16.6版本及以上
*
* @return Config
* @throws Exception
* @Date 2025年2月13日10:20:51
* @author wangshanzhen2
*/
@Bean @Bean
Config config() throws Exception { Config config() throws Exception {
String[] tokenizeToStringArray = org.springframework.util.StringUtils.tokenizeToStringArray(address, ",");
String[] nodes = new String[tokenizeToStringArray.length];
for (int i = 0; i < tokenizeToStringArray.length; i++) {
nodes[i] = "redis://" + tokenizeToStringArray[i];
}
Config config = new Config(); Config config = new Config();
config.useSingleServer().setAddress(address) config.useClusterServers()
.setConnectionMinimumIdleSize(connectionMinimumIdleSize) .addNodeAddress(nodes)
.setConnectionPoolSize(connectionPoolSize) .setMasterConnectionMinimumIdleSize(connectionMinimumIdleSize)
.setDatabase(database) .setMasterConnectionPoolSize(connectionPoolSize)
.setDnsMonitoring(dnsMonitoring)
.setDnsMonitoringInterval(dnsMonitoringInterval) .setDnsMonitoringInterval(dnsMonitoringInterval)
.setSubscriptionConnectionMinimumIdleSize(subscriptionConnectionMinimumIdleSize) .setSubscriptionConnectionMinimumIdleSize(subscriptionConnectionMinimumIdleSize)
.setSubscriptionConnectionPoolSize(subscriptionConnectionPoolSize) .setSubscriptionConnectionPoolSize(subscriptionConnectionPoolSize)
.setSubscriptionsPerConnection(subscriptionsPerConnection) .setSubscriptionsPerConnection(subscriptionsPerConnection)
.setClientName(clientName) .setClientName(clientName)
.setFailedAttempts(failedAttempts)
.setRetryAttempts(retryAttempts) .setRetryAttempts(retryAttempts)
.setRetryInterval(retryInterval) .setRetryInterval(retryInterval)
.setReconnectionTimeout(reconnectionTimeout)
.setTimeout(timeout) .setTimeout(timeout)
.setConnectTimeout(connectTimeout) .setConnectTimeout(connectTimeout)
.setIdleConnectionTimeout(idleConnectionTimeout) .setIdleConnectionTimeout(idleConnectionTimeout)
.setPingTimeout(pingTimeout)
.setPassword(StringUtils.trimToNull(password)); .setPassword(StringUtils.trimToNull(password));
Codec codec=(Codec) ClassUtils.forName(getCodec(), ClassUtils.getDefaultClassLoader()).newInstance(); Codec codec=(Codec) ClassUtils.forName(getCodec(), ClassUtils.getDefaultClassLoader()).newInstance();
config.setCodec(codec); config.setCodec(codec);
config.setThreads(thread); config.setThreads(thread);
config.setEventLoopGroup(new NioEventLoopGroup()); config.setEventLoopGroup(new NioEventLoopGroup());
config.setUseLinuxNativeEpoll(false);
return config; return config;
} }