投稿介绍:xiaotianqio,资深linux菜鸟程序员,搜索系统砖家,曾混迹于百度的互联网吊丝。刚开始接触Redis,大言不惭,聊卿一读。html
一开始数据比较少,一台服务器的内存就足够,所以一个Redis 就能知足需求,可是随着业务发展,数据量变大,可能须要在多台服务器上运行多个Redis,因此须要将已有的数据进行分片(避免数据丢失),不一样的片交给不一样的Redis 服务。若是在一开始就考虑到这个问题,在只有一个Redis时,也将数据存放在Redis的不一样db中,当增长Redis时,将dump.rdb中的数据按照db切分为多个文件,每一个Redis使用各自的db,经过这种方式来实现无缝的扩展,所以须要有脚本可以切分dump.rdb。linux
咱们单服务器的内存是64G,咱们估计64* 16G 在很长一段时间内是知足需求的,可是这个数据积累的过程可能比较缓慢,很长一段时间不会超过64G,所以一台Redis 服务器就足够,可是为了考虑到之后的扩展,一开始将数据sharding 到16个db中,也就是说在只有一个Redis时,client每次写数据会先计算key的hash,模16,获得db num,select db,而后写入,也能够为每一个db 保持一个client,这样就能够避免每次select db 了。 当须要变动为两个Redis时,为了避免丢失数据,须要将原来Redis的数据分为2份,一份是db 0-7,第二份是db 8-15, 用这两个数据启动Redis,就能够实现扩容了,所以必需要要有脚本可以切分Redis dump 出来的dump.rdb, 下面介绍咱们的切分脚本:程序员
例如咱们的例子redis
切分脚本以下sql
echo "Usage start-end db" startdb=$1 #上面的例子start 0 enddb=$2 # end 是 7 outdb="$1-$2.rdb" #输出文件的名字 if [[ ! -f "dump.rdb" ]]; then #使用当前目录下dump.rdb 做为源文件 echo "no dump.rdb,must have" exit -1 fi #使用修改过的redis,打印offset,而后退出,使用awk 获得head 的offset headstart=`/global/share/bin/chenjp/redis-db-offset >& tmp.log ; cat tmp.log | grep offset | grep -v dbid | awk -F '=' '{print $NF}'` headfile="split-0-$headstart" #head所在文件 /global/share/bin/chenjp/vsplit dump.rdb 0 $headstart #根据offset 切分文件,0- headoffset 为head dbstartoffset=`cat tmp.log | grep "dbid=$startdb" | awk -F '=|,' '{print $(NF-2)}'` #找到db的offset dbendoffset=`cat tmp.log | grep "dbid=$enddb" | awk -F '=|,' '{print $(NF-2)}'` if [[ $dbendoffset -eq "" ]];then dbendoffset=`ls -l dump.rdb | awk -F ' ' '{print $5}'` fi echo "start:"$dbstartoffset":"$dbendoffset dbfile="split-$dbstartoffset-$dbendoffset" /global/share/bin/chenjp/vsplit dump.rdb $dbstartoffset $dbendoffset #获得db 文件 cat $headfile $dbfile > $outdb #拼接 printf "\xff" >> $outdb #eof #rm -rf tmp.log #rm -rf split-* echo "file $dbfile ok, containts db $startdb to $enddb, pls mv to dump.rdb to start redis server"
而上面的redis-db-offset实现也并不困难,只须要在load的时候将各个db开始的offset值打印也来就好了。diff以下:服务器
[chenjp@nb290 redis-2.4.10]$ diff src/rdb.c ../../redis-2.4.10/src/rdb.c 959c959 < --- > fprintf(stderr,"redis_db head finished,offset=%lld\n",ftell(fp)); 982a983,984 > > long db_start = ftell(fp) - 1; 988a991 > fprintf(stderr,"redis_db select,offset=%lld,dbid=%d\n",db_start,dbid); [chenjp@nb290 redis-2.4.10]$ diff src/redis.c ../../redis-2.4.10/src/redis.c 1790a1791,1792 > > //exit(1);