如何实时同步大量小文件

arganzheng's Weblog 2014-08-04 5832 阅读

需求

静态资源服务器存放新闻、视频、图片，每隔一段时间定时拉取更新。为了反正静态资源服务器(现在是用MFS)挂掉，需要将静态资源同步到普通的linux文件系统做备份。这样故障的时候可以切换回去。

大概有900w+的小文件，使用rsync，在没有任何文件变更的情况下，都需要执行20多分钟（扫描对比差异）。如何实时的同步呢？

方案

1、cron + rsync

[work@xxx-xxxx-mob01.hk01.baidu.com zhengzhibin]$ cat ~/userbin/sync_static_mbrowser.sh
#!/bin/bash
source /home/work/.bashrc
BASH_PATH="/home/work/.bashrc"
LOG_PATH="/home/work/userbin/log"
RSYNC_RESULT=`ps auxf | grep rsync | grep -v grep`
RSYNC_PID=`ps auxf | grep rsync | grep -v grep | awk '{print $2}'`  # may be more one 
count=`ps auxf | grep rsync | grep -v grep | awk '{print $2}' | wc -l` 
if [ $count -ge 16 ];then
        echo "[FATAL]"`date`" rsync running time out, killing!" >> $LOG_PATH
        kill -9 $RSYNC_PID
        exit 0
fi
# check if rsync is still running
if [ "$RSYNC_RESULT"x == ""x ];then
        echo "[NORMAL]"`date`" rsync will be running normally." >> $LOG_PATH
        rsync -auv --delete-after argan@xxx-xxx-mob05.hk01:/home/work/STATIC/mbrowser  /home/work/mnt/mfs/
else
        echo "[WARNING]"`date`" last rsync is still running, new one will NOT run!" >> $LOG_PATH
fi

优点: 简单

缺点：定时执行，实时性比较差；另外，rsync同步数据时，需要扫描所有文件后进行比对，进行差量传输。如果文件数量达到了百万甚至千万量级，扫描所有文件将是非常耗时的。而且正在发生变化的往往是其中很少的一部分，这是非常低效的方式。

2. inotify + rsync

为了避免每次都扫描对比差异，可以使用inotify得到关注目录的变更情况，然后使用rsync同步变更文件。例如下面的脚本：

#!/bin/bash
DEST="$1"
if [ -z "$DEST" ]; then exit 1; fi
inotifywait -r -m -e close_write --format '%w%f' . |\
while read file
do
        echo $file
    rsync -azvq $file ${DEST}/$file
    echo -n 'Completed at '
    date
done

这个脚本会监控本地文件夹并且当有文件变更的时候执行rsync同步到远程备份机器。可以这么执行：

sync.sh argan@myhost.domain.com:STATIC/

但是这个脚本有个问题，就是他对每个变更文件都使用了rsync。而每一次rsync都要建立SSH链接，这个其实是比较费时间的。特别是当你的文件很小的时候，这个建立SSH链接时间相比真正的同步时间（传输变更文件时间）就非常浪费。针对这种情况，OpenSSH提供了一个非常实用的特性可以解决这个问题——SSH Connection Multiplexing。它可以复用同一个SSH链接。因此只有第一次建立SSH链接比较耗时。只需要在~/.ssh/config文件配置一下：

Host myhost.domain.com
    ControlMaster auto
    ControlPath /tmp/%h%p%r

如果是OpenSSH 5.6+的，还可以使用ControlPersist，保持SSH链接时间。

也可以先采用NFS协议将dest目录mount到source目录所在机器，然后直接使用cp进行同步。

TIPS Trailing Slashes Do Matter...Sometimes

rsync对SourceDir和DestDir最后是否带斜杠有不同的处理。例如：

rsync -auv /home/work/STATIC/mbrowser/guanxing  /home/work/mnt/mfs/mbrowser

将产生备份到 /home/work/mnt/mfs/mbrowser/guanxing 目录

而

rsync -auv /home/work/STATIC/mbrowser/guanxing/  /home/work/mnt/mfs/mbrowser

将产生备份到 /home/work/mnt/mfs/mbrowser 目录

DestDir最后有没有斜杠也会对rsync产生影响。例如：

rsync -auv --progress --delete-after /home/work/arganzheng/test.txt work@xxx-xxx-mob05.hk01:/home/work/arganzheng/

将产生备份到hk01-hao123-mob05.hk01:/home/work/arganzheng/test.txt。而且如果arganzheng目录不存在，会自动创建。

而 rsync -auv --progress --delete-after /home/work/arganzheng/test.txt work@hxxx-xxx-mob05.hk01:/home/work/arganzheng

将产生备份到xxx-xxx-mob05.hk01:/home/work/arganzheng。也就是说将test.txt重命名为arganzheng了。当然，如果xxx-xxx-mob05.hk01:/home/work/arganzheng已经存在，并且是目录，那么这种情况DestDir有没有最后斜杆就没有影响。

3. lsyncd

有很多工具封装了inotify监听和rsync的同步机制，提供了更便利的使用方式。比如Lsyncd。lsyncd的配置文件是用lua语言写的，可读性很不错。Lua作为配置语言从这里可以看出来。inosync，是python版本的lsyncd。最后决定使用isyncd，主要是因为它能够控制进程数，而且它是递归对子目录添加事件监听。

安装lsyncd

lsyncd依赖于lua和lua-dev lib包，这个在configure的时候就会检测报告。具体参见Lsyncd 2.1.x ‖ Compiling 。

编写lua配置文件

一开始自己写了这么一个配置文件，用于同步STATIC目录到MFS分布式文件系统。

settings {
    statusFile = "/tmp/lsyncd.stat",
    logfile    = "/tmp/lsyncd.log",
    logfacility = daemon,
    statusIntervall = 20,
    maxDelays    = 10
}
backup = {
    delay = 5,
    maxProcesses = 4,
    onCreate = "cp -r ^sourcePathname ^targetPathname",
    onModify = "cp -r ^sourcePathname ^targetPathname",
    onDelete = "rm -rf ^targetPathname",
    onMove   = "mv ^o.targetPathname ^d.targetPathname",
    onStartup = "rsync --progress -auv --delete-after ^sourcePathname ^target",
}
sync { 
    backup,
    source="/home/work/STATIC",
    target="/home/work/mnt/mfs"
}

注意到我们这里除了startup的时候使用了rsync做了全量同步之后，后面都是根据inotify提供的事件进行增量同步，而且直接使用了cp、mv、rm，因为我们已经将MFS mount到本地目录了。另外我们还控制了进程数和合并时间时间，以避免系统过载。

后来无意中翻看了一下lsyncd的文档，发现它本身有个内建的行为可以进行本地目录的同步。就是default.direct：

Default.direct can be used to keep two local directories in sync with better performance than simply using default.rsync. Default.direct uses on startup rsync just like default.rsync to initially synchronize the target directory with the source directory. However, during normal operation default.direct uses /bin/cp, /bin/rm and /bin/mv to keep the synchronization. All parameters are just like default.rsync.

其实它的行为就是我们上面的那个脚本。但是既然已经有了，所以我们可以简化我们的配置文件：

settings {
    statusFile = "/tmp/lsyncd.stat",
    logfile    = "/tmp/lsyncd.log",
    logfacility = daemon,
    statusIntervall = 20,
    maxDelays    = 10,
    maxProcesses = 4
}
sync {
    default.direct,
    source="/home/work/STATIC",
    target="/home/work/mnt/mfs"
}

NOTES

1、startup rsync take too much time!

令人吃惊的是，lsyncd的starup rsync运行的时间就像目标目录不存在一样！对于差异很小的两个目录，笔者单独运行rsync的话，只需要20多分钟就可以同步完成。但是lsyncd的startup rsync居然跑了一天一夜还没有跑完。。不知道它内部是怎么处理的。但是不管怎样，对于需要及时切换目录，并且建立同步的需求，lsyncd的这个特点显然是不能接受的。解决方案有下面几个：

关闭lsyncd的startup rsync：sync{..., init = false}。前提是source和target目录已经是一致的。
自己写脚本，比如我们上面一开始写的那个。

2、lsyncd默认是开启--delete选项的，而且默认不打印rsync日志。可以通过delete配置项配置。

3、有时候会报"rsync: failed to set times"错误，可以使用rsyncOps="-O"解决。

TIPS 双向同步

为了更快的切换，最好的方式就是双向同步，而且双向同步还可以解决startup rsync耗时问题，因为我们可以同时跑同步脚本。不过双向同步要解决一个关键问题就是避免死循环同步。这个lsyncd的default.direct因为简单使用cp、mv、delete，是会死循环同步的。需要自己写同步脚本，比如onCreate = "cp -r -u ^sourcePathname ^targetPathname"或者onCreate = "rsync -auv ^sourcePathname ^targetPathname"。另外一个需要注意的是rsync的--delete选项，双向同步容易出问题。

运行

运行lsyncd很简单：

lsyncd CONFIGFILE

不过这里有一个tip，就是在测试期间，先不要使用daemon模式启动：

lsyncd -nodaemon CONFIGFILE

还有可以指定日志分类：

lsyncd -log all CONFIGFILE
lsyncd -log Exec CONFIGFILE

4. 使用watchdog

5. 使用lipsync

具体参见: https://github.com/philcryer/lipsync

参考文档

文件同步

作者：arganzheng's Weblog

原文地址：如何实时同步大量小文件, 感谢原作者分享。

→Java网络IO编程 ←服务端监控方案