在一個(gè)集群中，顯然不能通過(guò)keys方法通過(guò)pattern直接獲取key的集合；
鑒于這種問(wèn)題，產(chǎn)生了兩種思路，如下：
方案1：
已知相同的tag的KV會(huì)在一個(gè)節(jié)點(diǎn)上，所以只要key帶有相同的hashtag，則會(huì)在一個(gè)節(jié)點(diǎn)上，所以只要掃描該節(jié)點(diǎn)即可，這樣就將集群轉(zhuǎn)化為了單點(diǎn)。
@RequestMapping(value = "/ceshi", method = RequestMethod.GET)
@ResponseBody
public void Rediskeys() {
/**
* 模糊匹配
* @param pattern key的正則表達(dá)式
* @param count 每次掃描多少條記錄，值越大消耗的時(shí)間越短，但會(huì)影響redis性能。建議設(shè)為一千到一萬(wàn)
* @return 匹配的key集合
*/
try{
jedisCluster.getClusterNodes();
ScanParams scanParams = new ScanParams();
scanParams.match("{operatingSystem}*");
scanParams.count(1000);
ScanResultString> result = jedisCluster.scan("0", scanParams);
ListString> keyList = result.getResult();
System.out.println("keyList======="+keyList);
}finally{
}
}
//scanParams.match("*{zmc}*");//success
//scanParams.match("ZMC_text:{zmc}*");//success
上述match方法中：括號(hào)中的參數(shù)也可以按照如上方式編寫(xiě)；
其關(guān)鍵在于 key 上傳到redis中，命名方式里面，必須含有 {}；
并且{}前面、后面有無(wú)參數(shù)必須指定；若key為 ZMC_text: {zmc}：1
scanParams.match("{zmc}*");查不出結(jié)果
方案2：
獲取所有的節(jié)點(diǎn)，分別掃描每個(gè)節(jié)點(diǎn)，根據(jù)pattern獲取節(jié)點(diǎn)中的key，整合起來(lái)即可；
注意：cluster模式執(zhí)行多key操作的時(shí)候，這些key必須在同一個(gè)slot上，不然會(huì)報(bào)JedisDataException異常；
@RequestMapping(value = "/ceshi3", method = RequestMethod.GET)
@ResponseBody
public void RedisKeys() {
String redisKeyStartWith="Ad:ads:id:";
try {
MapString, JedisPool> clusterNodes = jedisCluster.getClusterNodes();
for (Map.EntryString, JedisPool> entry : clusterNodes.entrySet()) {
Jedis jedis = entry.getValue().getResource();
// 判斷非從節(jié)點(diǎn)(因?yàn)槿糁鲝膹?fù)制，從節(jié)點(diǎn)會(huì)跟隨主節(jié)點(diǎn)的變化而變化)
if (!jedis.info("replication").contains("role:slave")) {
SetString> keys = jedis.keys(redisKeyStartWith + "*");
if (keys.size() > 0) {
MapInteger, ListString>> map = new HashMap>();
for (String key : keys) {
// cluster模式執(zhí)行多key操作的時(shí)候，這些key必須在同一個(gè)slot上，不然會(huì)報(bào):JedisDataException:
// CROSSSLOT Keys in request don't hash to the same slot
int slot = JedisClusterCRC16.getSlot(key);
// 按slot將key分組，相同slot的key一起提交
if (map.containsKey(slot)) {
map.get(slot).add(key);
} else {
map.put(slot, Lists.newArrayList(key));
}
}
for (Map.EntryInteger, ListString>> integerListEntry : map.entrySet()) {
System.out.println("integerListEntry="+integerListEntry);
//jedis.del(integerListEntry.getValue().toArray(new String[integerListEntry.getValue().size()]));
}
}
}
}
logger.info("success redisKeys:{}", redisKeyStartWith);
} finally {
}
}
redis集群獲取所有的key
redis單機(jī)查詢所有key命令
keys *
查詢結(jié)果示例:
redis集群查所有key命令：
如果使用keys *,那么查詢的仍舊是本服務(wù)器的所有key,不是集群的(結(jié)合本圖結(jié)果以及參考上圖,都是插入后查詢,無(wú)心插入或者刪除key)
正確的命令是
./redis-cli -c --cluster call 192.168.168.161:7001 keys \*
注意：
1.不能去掉\;
2.換成你redis集群的一個(gè)節(jié)點(diǎn)的ip和端口
3.如果集群有密碼加上參數(shù) -a password(你的redis集群密碼) 如本地測(cè)試環(huán)境查詢結(jié)果:
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:- Java使用RedisTemplate模糊刪除key操作
- Spring Boot集成redis,key自定義生成方式
- redis 查看所有的key方式
- Springboot Redis設(shè)置key前綴的方法步驟
- Redis遍歷所有key的兩個(gè)命令(KEYS 和 SCAN)
- redis keys與scan命令的區(qū)別說(shuō)明
- redis通過(guò)lua腳本,獲取滿足key pattern的所有值方式
