Halo备份定时上传七牛云

由于域名到期后我没注意,导致域名解析错误。域名续费后halo也存在故障,我折腾半天,终于把数据都折腾没了。这才想到备份数据,但是我的服务器只有一个系统盘,就算备份到服务器也不安全,所以想把备份文件上传到cdn。应用市场有这个插件,但是是付费的,于是我准备结合现有的免费备份插件再写一个应用

环境

  • centos9

  • jdk25

前期准备

  1. 在应用市场安装自动备份插件,免费的那个。这个插件会定期备份到halo目录,例如我的备份文件路径是:/root/halo/halo2/backups

  1. 准备七牛云空间,既然你都有博客了,那应该会配置七牛云了吧。按照教程来,很简单。

开始

  1. 项目根目录创建.env文件

QINIU_ACCESS_KEY=你的access_key,在七牛云控制台获取
QINIU_SECRET_KEY=你的secret_key,在七牛云控制台获取
QINIU_BUCKET=你的bucket名称
QINIU_DOMAIN=你的七牛云空间
#本地测试路径
#WATCH_FOLDER=E:/迅雷下载/buckups
#服务器路径
WATCH_FOLDER=/root/halo/halo2/backups
  1. 创建一个maven项目,下面是pom.xml内容

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.xuyuanahng</groupId>
    <artifactId>backup</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>25</maven.compiler.source>
        <maven.compiler.target>25</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>io.github.cdimascio</groupId>
            <artifactId>dotenv-java</artifactId>
            <version>3.0.0</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>com.squareup.okhttp3</groupId>
            <artifactId>okhttp</artifactId>
            <version>4.9.2</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.9</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>com.qiniu</groupId>
            <artifactId>happy-dns-java</artifactId>
            <version>0.1.6</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.13.1</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.qiniu</groupId>
            <artifactId>qiniu-java-sdk</artifactId>
            <version>[7.16.0, 7.16.99]</version>
        </dependency>
        <!-- 核心包 -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.3.2</version>
        </dependency>
        <!-- 工具包 -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz-jobs</artifactId>
            <version>2.4.0-rc1</version>
        </dependency>
        <!-- SLF4J API -->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>2.0.7</version>
        </dependency>

        <!-- Logback 实现 -->
        <dependency>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
            <version>1.5.13</version>
        </dependency>
    </dependencies>


</project>

  1. 新建UploadJob类,处理上传备份文件

package com.xuyuanahng;

import com.qiniu.http.Response;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.UploadManager;
import com.qiniu.util.Auth;
import io.github.cdimascio.dotenv.Dotenv;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.Arrays;
import java.util.Comparator;


public class UploadJob implements Job {
    private static final Logger logger = LoggerFactory.getLogger(UploadJob.class);

    @Override
    public void execute(JobExecutionContext context) {
        logger.info("执行任务{}", context.getJobDetail().getDescription());

        logger.info("加载环境变量");
        Dotenv dotenv = Dotenv.configure().load();
        String accessKey = dotenv.get("QINIU_ACCESS_KEY");
        String secretKey = dotenv.get("QINIU_SECRET_KEY");
        String bucket = dotenv.get("QINIU_BUCKET");
        String domain = dotenv.get("QINIU_DOMAIN");
        String folder = dotenv.get("WATCH_FOLDER");
        logger.info("配置信息:七牛云AccessKey:{},七牛云SecretKey:{},七牛云Bucket:{},七牛云域名:{},搜索文件夹:{}", accessKey, secretKey, bucket, domain, folder);

        Configuration cfg = new Configuration();
        UploadManager uploadManager = new UploadManager(cfg);
        Auth auth = Auth.create(accessKey, secretKey);
        String token = auth.uploadToken(bucket);
        logger.info("获取文件");
        File lastFile = getFileByLastTime(folder);
        logger.info("最新文件:{}", lastFile.getName());
        try {
            logger.info("开始上传");
            Response r = uploadManager.put(Files.readAllBytes(Paths.get(lastFile.getPath())), lastFile.getName(), token);
            logger.info("上传文件成功,Response:{}", r.bodyString());
        } catch (Exception e) {
            logger.error("上传失败");
        }

    }

    /**
     * 获取文件夹内最新的文件
     *
     * @param folderPath 文件夹路径
     * @return File 最新的文件
     */
    File getFileByLastTime(String folderPath) {
        File path = new File(folderPath);
        //列出该目录下所有文件和文件夹
        File[] files = path.listFiles();
        //按照目录中文件最后修改日期实现倒序排序
        if (files != null) {
            Arrays.sort(files, new Comparator<File>() {
                @Override
                public int compare(File file1, File file2) {
                    return (int) (file2.lastModified() - file1.lastModified());
                }
            });
        }
        if (null == files) {
            return null;
        }
        return files[0];
    }


}
  1. 创建任务调度器

package com.xuyuanahng;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class Main {
    private static final Logger logger = LoggerFactory.getLogger(Main.class);

    static void main() throws SchedulerException {
        logger.info("创建调度器");
        SchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();

        logger.info("创建任务");
        JobDetail job = JobBuilder.newJob(UploadJob.class).withIdentity("upload", "upload").build();


        logger.info("创建触发器");
        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("trigger", "upload")
                .startNow()
                .withSchedule(
                        // 每月1号和15号运行
                        CronScheduleBuilder.cronSchedule("* * * 1,15 * ?")
                ).build();


        logger.info("触发器绑定任务");
        scheduler.scheduleJob(job, trigger);
        logger.info("启动调度器");
        scheduler.start();
        logger.info("调度器启动成功");
    }

}

  1. 打包部署

这个没什么好说的,构建成jar包上传到服务器直接后台运行既可

java -jar buckup.jar &

注意事项

我的程序是每个月1号和15号启动上传,你可以根据自己需求修改。

暂时先这样,有问题可以留言


Halo备份定时上传七牛云
https://xuyuanhang.com/archives/halobei-fen-ding-shi-shang-chuan-qi-niu-yun
作者
Kinmax
发布于
2026年02月20日
许可协议