```private static void deleteAllKeys() {JedisCluster jedisCluster = new JedisCluster(new HostAndPort(127.0.0.1, 6379));try {// 获取集群中所有的节点CollectionJedisPool jedisPools = jedisCluster.get...

```
private static void deleteAllKeys() {
JedisCluster jedisCluster = new JedisCluster(new HostAndPort("127.0.0.1", 6379));
try {
// 获取集群中所有的节点
Collection<JedisPool> jedisPools = jedisCluster.getClusterNodes().values();
boolean isSuccess = false;
// 遍历所有的节点,获取每个节点上对应数据匹配的结果,并删除
for (JedisPool pool : jedisPools) {
Jedis jedis = null;
try {
jedis = pool.getResource();
Set<String> keys = jedis.keys("*");
Iterator<String> it = keys.iterator();
while (it.hasNext()) {
String key = it.next();
jedis.del(key);
}
pool.returnResource(jedis);
isSuccess = true;
} catch (JedisMovedDataException ignore) {
isSuccess = false;
pool.returnBrokenResource(jedis);
} catch (Exception e) {
pool.returnBrokenResource(jedis);
isSuccess = false;
System.out.println("Error message: " + e.getMessage());
}
}
if (isSuccess) {
System.out.println("Complete!");
} else {
System.out.println("Error!");
}
jedisCluster.close();
} catch (Exception e) {
try {
jedisCluster.close();
} catch (IOException e1) {
e1.printStackTrace();
}
e.printStackTrace();
} }
```
织梦狗教程
本文标题为:redis集群删除所有数据


基础教程推荐
猜你喜欢
- Python常见库matplotlib学习笔记之画图中各个模块的含义及修改方法 2023-07-27
- redis 数据库 2023-09-13
- Python安装第三方库的方法(pip/conda、easy_install、setup.py) 2023-07-28
- redis乐观锁与悲观锁的实战 2023-07-13
- Mariadb数据库主从复制同步配置过程实例 2023-07-25
- Java程序员从笨鸟到菜鸟(五十三) 分布式之 Redis 2023-09-11
- oracle数据库排序后如何获取第一条数据 2023-07-24
- SQL Server如何设置用户只能访问特定数据库和访问特定表或视图 2023-07-29
- Windows10系统中Oracle完全卸载正确步骤 2023-07-24
- oracle19c卸载教程的超详细教程 2023-07-23