createFiltersWithExpireAt 方法

spring-boot-starter-dsp-util/src/main/java/cn/com/duiba/spring/boot/starter/dsp/util/RedisBloomHandler.java

@@ -264,6 +264,19 @@ public class RedisBloomHandler<K, V> {
         }, true);
     }
 
+    public void createFiltersWithExpireAt(RedisTemplate redisTemplate,List<K> keys, double errorRate, long initCapacity, long expireAt) {
+        byte[] rawErrorRate = rawString(String.valueOf(errorRate));
+        byte[] rawInitCapacity = rawString(String.valueOf(initCapacity));
+        Object execute = redisTemplate.execute(connection -> {
+            keys.forEach(key -> {
+                byte[] rawKey = rawKey(key);
+                connection.execute(RESERVE, rawKey, rawErrorRate, rawInitCapacity);
+                connection.expireAt(rawKey, expireAt);
+            });
+            return null;
+        }, true);
+    }
+
     /**
      * 根据key判断redis key是否设置过期时间
      *