| | |
|---|
| | | Config config = new Config(); |
|---|
| | | config.setThreads(redissonProperties.getThreads()) |
|---|
| | | .setNettyThreads(redissonProperties.getNettyThreads()) |
|---|
| | | .setCodec(JsonJacksonCodec.INSTANCE) |
|---|
| | | .setTransportMode(redissonProperties.getTransportMode()); |
|---|
| | | .setCodec(JsonJacksonCodec.INSTANCE); |
|---|
| | | |
|---|
| | | RedissonProperties.SingleServerConfig singleServerConfig = redissonProperties.getSingleServerConfig(); |
|---|
| | | if (ObjectUtil.isNotNull(singleServerConfig)) { |
|---|
| | |
|---|
| | | .setDatabase(redisProperties.getDatabase()) |
|---|
| | | .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null) |
|---|
| | | .setTimeout(singleServerConfig.getTimeout()) |
|---|
| | | .setRetryAttempts(singleServerConfig.getRetryAttempts()) |
|---|
| | | .setRetryInterval(singleServerConfig.getRetryInterval()) |
|---|
| | | .setClientName(singleServerConfig.getClientName()) |
|---|
| | | .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout()) |
|---|
| | | .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize()) |
|---|
| | |
|---|
| | | .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue()) |
|---|
| | | .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null) |
|---|
| | | .setTimeout(clusterServersConfig.getTimeout()) |
|---|
| | | .setRetryAttempts(clusterServersConfig.getRetryAttempts()) |
|---|
| | | .setRetryInterval(clusterServersConfig.getRetryInterval()) |
|---|
| | | .setClientName(clusterServersConfig.getClientName()) |
|---|
| | | .setIdleConnectionTimeout(clusterServersConfig.getIdleConnectionTimeout()) |
|---|
| | | .setPingConnectionInterval(clusterServersConfig.getPingConnectionInterval()) |
|---|
| | | .setSubscriptionConnectionPoolSize(clusterServersConfig.getSubscriptionConnectionPoolSize()) |
|---|
| | | .setMasterConnectionMinimumIdleSize(clusterServersConfig.getMasterConnectionMinimumIdleSize()) |
|---|
| | | .setMasterConnectionPoolSize(clusterServersConfig.getMasterConnectionPoolSize()) |
|---|
| | |
|---|
| | | * threads: 16 |
|---|
| | | * # Netty线程池数量 |
|---|
| | | * nettyThreads: 32 |
|---|
| | | * # 传输模式 |
|---|
| | | * transportMode: "NIO" |
|---|
| | | * # 集群配置 |
|---|
| | | * clusterServersConfig: |
|---|
| | | * # 客户端名称 |
|---|
| | |
|---|
| | | * slaveConnectionPoolSize: 64 |
|---|
| | | * # 连接空闲超时，单位：毫秒 |
|---|
| | | * idleConnectionTimeout: 10000 |
|---|
| | | * # ping连接间隔 |
|---|
| | | * pingConnectionInterval: 1000 |
|---|
| | | * # 命令等待超时，单位：毫秒 |
|---|
| | | * timeout: 3000 |
|---|
| | | * # 如果尝试在此限制之内发送成功，则开始启用 timeout 计时。 |
|---|
| | | * retryAttempts: 3 |
|---|
| | | * # 命令重试发送时间间隔，单位：毫秒 |
|---|
| | | * retryInterval: 1500 |
|---|
| | | * # 发布和订阅连接池大小 |
|---|
| | | * subscriptionConnectionPoolSize: 50 |
|---|
| | | * # 读取模式 |
|---|
