浏览代码

添加bloom配置

tianboguang 2 年之前
父节点
当前提交
920eda51dc

+ 0 - 25
4dkankan-utils-redis/src/main/java/com/fdkankan/redis/config/RedisConfig.java

@@ -19,31 +19,6 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
 @AutoConfigureAfter(RedisAutoConfiguration.class)
 public class RedisConfig {
 
-    @Value("${spring.redis.host}")
-    private String host;
-
-    @Value("${spring.redis.port}")
-    private String port;
-
-    @Value("${spring.redis.database:0}")
-    private int database;
-
-    @Value("${spring.redis.password:#{null}}")
-    private String password;
-
-    @Bean
-    public RedissonClient redissonClient() {
-        Config config = new Config();
-        SingleServerConfig singleServerConfig = config.useSingleServer();
-        singleServerConfig.setAddress("redis://".concat(host).concat(":").concat(port));
-        if (StringUtils.isNotEmpty(password)) {
-            singleServerConfig.setPassword(password);
-        }
-        singleServerConfig.setDatabase(database);
-        return Redisson.create(config);
-
-    }
-
     @Bean
     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
         RedisTemplate template = new RedisTemplate();

+ 45 - 0
4dkankan-utils-redis/src/main/java/com/fdkankan/redis/config/RedissonConfig.java

@@ -0,0 +1,45 @@
+package com.fdkankan.redis.config;
+
+
+import org.apache.commons.lang3.StringUtils;
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.redisson.config.SingleServerConfig;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@AutoConfigureAfter(RedisAutoConfiguration.class)
+@ConditionalOnProperty(name = "spring.redis.bloom", havingValue = "true")
+public class RedissonConfig {
+
+    @Value("${spring.redis.host}")
+    private String host;
+
+    @Value("${spring.redis.port}")
+    private String port;
+
+    @Value("${spring.redis.database:0}")
+    private int database;
+
+    @Value("${spring.redis.password:#{null}}")
+    private String password;
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        SingleServerConfig singleServerConfig = config.useSingleServer();
+        singleServerConfig.setAddress("redis://".concat(host).concat(":").concat(port));
+        if (StringUtils.isNotEmpty(password)) {
+            singleServerConfig.setPassword(password);
+        }
+        singleServerConfig.setDatabase(database);
+        return Redisson.create(config);
+
+    }
+}

+ 2 - 0
4dkankan-utils-redis/src/main/java/com/fdkankan/redis/util/RedisBloomUtils.java

@@ -3,9 +3,11 @@ package com.fdkankan.redis.util;
 import org.redisson.api.RBloomFilter;
 import org.redisson.api.RedissonClient;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.stereotype.Component;
 
 @Component
+@ConditionalOnProperty(name = "spring.redis.bloom", havingValue = "true")
 public class RedisBloomUtils {
 
     @Autowired