添加redis set集合操作

base-common/src/main/java/com/ozs/common/constant/Constants.java

@@ -155,4 +155,14 @@ public class Constants
      */
     public static final String[] JOB_ERROR_STR = {"java.net.URL", "javax.naming.InitialContext", "org.yaml.snakeyaml",
             "org.springframework", "org.apache", "com.hx.common.utils.file", "com.hx.common.config"};
+
+    /**
+     * ALARM_SET 报警信息集合
+     */
+    public static final String ALARM_SET = "alarm_set";
+
+    /**
+     * NORMAL_SET 报警信息集合
+     */
+    public static final String NORMAL_SET = "normal_set";
 }

base-common/src/main/java/com/ozs/common/core/redis/RedisCache.java

@@ -7,10 +7,7 @@ import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.core.BoundSetOperations;
-import org.springframework.data.redis.core.HashOperations;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.data.redis.core.*;
 import org.springframework.stereotype.Component;
 
 /**
@@ -265,4 +262,24 @@ public class RedisCache
     {
         return redisTemplate.keys(pattern);
     }
+
+    /**set集合添加元素
+     * @param key Redis键
+     * @param value
+     * @return 是否成功
+     */
+    public void addCacheSetValue(final String key, final String value)
+    {
+        SetOperations<String, String> setOps = redisTemplate.opsForSet();
+        setOps.add(key, value);
+    }
+    /**set集合移除元素
+     * @param key Redis键
+     * @param member
+     * @return 是否成功
+     */
+    public void removeMemberFromSet(String key, String member) {
+        SetOperations<String, String> setOps = redisTemplate.opsForSet();
+        setOps.remove(key, member);
+    }
 }