Halo备份定时上传七牛云
由于域名到期后我没注意,导致域名解析错误。域名续费后halo也存在故障,我折腾半天,终于把数据都折腾没了。这才想到备份数据,但是我的服务器只有一个系统盘,就算备份到服务器也不安全,所以想把备份文件上传到cdn。应用市场有这个插件,但是是付费的,于是我准备结合现有的免费备份插件再写一个应用
环境
centos9
jdk25
前期准备
在应用市场安装自动备份插件,免费的那个。这个插件会定期备份到halo目录,例如我的备份文件路径是:
/root/halo/halo2/backups
准备七牛云空间,既然你都有博客了,那应该会配置七牛云了吧。按照教程来,很简单。
开始
项目根目录创建.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创建一个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>新建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];
}
}
创建任务调度器
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("调度器启动成功");
}
}
打包部署
这个没什么好说的,构建成jar包上传到服务器直接后台运行既可
java -jar buckup.jar &注意事项
我的程序是每个月1号和15号启动上传,你可以根据自己需求修改。
暂时先这样,有问题可以留言
Halo备份定时上传七牛云
https://xuyuanhang.com/archives/halobei-fen-ding-shi-shang-chuan-qi-niu-yun