Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7000268
  • 博文数量: 590
  • 博客积分: 13065
  • 博客等级: 上将
  • 技术积分: 10253
  • 用 户 组: 普通用户
  • 注册时间: 2008-03-26 16:44
个人简介

推荐: blog.csdn.net/aquester https://github.com/eyjian https://www.cnblogs.com/aquester http://blog.chinaunix.net/uid/20682147.html

文章分类

全部博文(590)

分类: 系统运维

2020-09-03 09:34:41

FLUSHALL和FLUSHDB是单机命令,所以清空集群需要在所有Master节点上均执行一次。下载:https://github.com/eyjian/redis-tools/blob/master/clear_redis_cluster.sh

点击(此处)折叠或打开

  1. #!/bin/bash
  2. # Batch to clear all nodes using FLUSHALL command
  3. # 用来清空一个redis集群中的所有数据,要求 FLUSHALL 命令可用,
  4. # 如果在 redis.conf 中使用 rename 改名了 FLUSHALL,则不能执行本脚本。
  5. # 可带两个参数:
  6. # 1)参数1 集群中的任一可用节点(必须)
  7. # 2)连接redis的密码(设置了密码才需要)
  8. REDIS_CLI=${REDIS_CLI:-redis-cli}
  9. REDIS_IP=${REDIS_IP:-127.0.0.1}
  10. REDIS_PORT=${REDIS_PORT:-6379}
  11. # 显示用法函数
  12. function usage()
  13. {
  14. echo "Usage: clear_redis_cluster.sh a_redis_node_of_cluster redis_password"
  15. echo "Example1: clear_redis_cluster.sh '127.0.0.1:6379'"
  16. echo "Example2: clear_redis_cluster.sh '127.0.0.1:6379' '123456'"
  17. }
  18. # 检查参数个数
  19. if test $# -lt 1 -o $# -gt 2; then
  20. usage
  21. exit 1
  22. fi
  23. # 第一个参数为集群中的节点,
  24. REDIS_NODE="$1"
  25. # 第二个参数为密码
  26. REDIS_PASSWORD=""
  27. if test $# -ge 2; then
  28. REDIS_PASSWORD="$2"
  29. fi
  30. # 取得IP和端口
  31. eval $(echo "$REDIS_NODE" | awk -F[\:] '{ printf("REDIS_IP=%s\nREDIS_PORT=%s\n",$1,$2) }')
  32. if test -z "$REDIS_IP" -o -z "$REDIS_PORT"; then
  33. echo "Parameter error: \`$REDIS_NODE\`."
  34. usage
  35. exit 1
  36. fi
  37. # 确保redis-cli可用
  38. echo "Checking \`redis-cli\` ..."
  39. which "$REDIS_CLI" > /dev/null 2>&1
  40. if test $? -ne 0; then
  41. echo "Command \`redis-cli\` is not exists or not executable."
  42. echo "You can set environment variable \`REDIS_CLI\` to point to the redis-cli."
  43. echo "Example: export REDIS_CLI=/usr/local/bin/redis-cli"
  44. exit 1
  45. fi
  46. if test -z "$REDIS_PASSWORD"; then
  47. redis_nodes=`redis-cli -h $REDIS_IP -p $REDIS_PORT cluster nodes | awk -F[\ \:\@] '!/ERR/{ printf("%s:%s\n",$2,$3); }'`
  48. else
  49. redis_nodes=`redis-cli --no-auth-warning -a "$REDIS_PASSWORD" -h $REDIS_IP -p $REDIS_PORT cluster nodes | awk -F[\ \:\@] '!/ERR/{ printf("%s:%s\n",$2,$3); }'`
  50. fi
  51. if test -z "$redis_nodes"; then
  52. # Standlone(非集群)
  53. if test -z "$REDIS_PASSWORD"; then
  54. $REDIS_CLI -h $REDIS_IP -p $REDIS_PORT FLUSHALL ASYNC
  55. $REDIS_CLI -h $REDIS_IP -p $REDIS_PORT BGREWRITEAOF
  56. else
  57. $REDIS_CLI --no-auth-warning -a "$REDIS_PASSWORD" -h $REDIS_IP -p $REDIS_PORT FLUSHALL ASYNC
  58. $REDIS_CLI --no-auth-warning -a "$REDIS_PASSWORD" -h $REDIS_IP -p $REDIS_PORT BGREWRITEAOF
  59. fi
  60. else
  61. # Cluster(集群)
  62. for redis_node in $redis_nodes;
  63. do
  64. if test ! -z "$redis_node"; then
  65. eval $(echo "$redis_node" | awk -F[\:] '{ printf("redis_node_ip=%s\nredis_node_port=%s\n",$1,$2) }')
  66. if test ! -z "$redis_node_ip" -a ! -z "$redis_node_port"; then
  67. # clear
  68. echo -e "Clearing \033[1;33m${redis_node_ip}:${redis_node_port}\033[m ..."
  69. if test -z "$REDIS_PASSWORD"; then
  70. result=`$REDIS_CLI -h $redis_node_ip -p $redis_node_port FLUSHALL ASYNC`
  71. $REDIS_CLI -h $redis_node_ip -p $redis_node_port BGREWRITEAOF
  72. else
  73. result=`$REDIS_CLI --no-auth-warning -a "$REDIS_PASSWORD" -h $redis_node_ip -p $redis_node_port FLUSHALL ASYNC`
  74. $REDIS_CLI --no-auth-warning -a "$REDIS_PASSWORD" -h $redis_node_ip -p $redis_node_port BGREWRITEAOF
  75. fi
  76. if test ! -z "$result"; then
  77. # SUCCESS
  78. if test "$result" = "OK"; then
  79. echo -e "\033[0;32;32m$result\033[m"
  80. else
  81. echo -e "\033[0;32;31m$result\033[m"
  82. fi
  83. fi
  84. fi
  85. fi
  86. done
  87. fi

阅读(70) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~