Zookeeper数据备份在CentOS上如何操作

./zkCli.sh -server host1:port1

save --path /target/path

scp username@zookeeper_host:/path/to/snapshot /path/to/local/backup

# 编辑crontab文件
crontab -e

# 添加定时任务
0 3 * * * ./zkCli.sh -server host1:port1 save --path /tmp/zookeeper_backup && scp username@zookeeper_host:/tmp/zookeeper_backup /path/to/local/backup

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.util.List;

public class ZookeeperDataBackup {
    private static final String QUORUM_SERVERS = "host1:port1";
    private static final int SESSION_TIMEOUT = 3000;

    public static void main(String[] args) throws Exception {
        ZooKeeper zk = new ZooKeeper(QUORUM_SERVERS, SESSION_TIMEOUT, event -> {});

        List<String> children = zk.getChildren("/", false);
        File backupDir = new File("/path/to/backup"); // 备份目录
        backupDir.mkdirs();
        for (String child : children) {
            String path = "/" + child;
            byte[] data = zk.getData(path, false, new Stat());
            String filename = backupDir.getAbsolutePath() + File.separator + child + ".data";
            try (FileWriter writer = new FileWriter(filename)) {
                writer.write(new String(data, "UTF-8"));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        zk.close();
    }
}