scala/java redis的cluster模式 删除固定前缀的key

概述

使用jedis

针对 cluster模式的redis

功能: 删除固定前缀的 且满足某些条件(ttl和value值)的 key. 

实现方式概述: 

获取clusterClient 通过cluster获取每个master的client(clusterClient获取到所有节点,返回会有重复,所以下面代码比连接中操作更多).

使用master的client进行scan(因为clusterClient不允许使用scan).

scan到key,再通过clusterClient去get del 等操作.

参考

Scan a Redis Cluster - Don't Panic!

代码

package com.dahua88
 
import redis.clients.jedis.HostAndPort
import redis.clients.jedis.Jedis
import redis.clients.jedis.JedisCluster
import redis.clients.jedis.JedisPoolConfig
import redis.clients.jedis.ScanParams
 
import java.util
import scala.collection.JavaConverters._
import scala.collection.mutable.ListBuffer
import scala.util.Failure
import scala.util.Success
import scala.util