创建定时任务类

内容仅供参考

import com.ruoyi.common.utils.file.FileUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;

/**
 * 定时备份数据库
 */
@Component("DatabaseBackupTask")
public class DatabaseBackupTask {

    private static final Logger log = LoggerFactory.getLogger(DatabaseBackupTask.class);

    // 文件过期时间（天，只保留30天内的备份文件）
    private static final int DATE = 30;
    
	// ip
    private static final String HOST= "127.0.0.1";
    
	// 端口
    private static final String PORT= "3306";
    
    // 用户名
    private static final String USER = "root";

    // 密码
    private static final String PASSWORD = "root";

    // 备份数据库
    private static final String DATABASE = "chat";

    // 备份目录
    private static final String BACKUP_DIR = "D:\\myProject";

    /**
     * 定时备份数据库
     * 配置定时任务执行此方法即可
     */
    public static void backupDatabase() {
        try {
            // 创建备份文件
            String dateTime = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());
            String backupFile = BACKUP_DIR + "\\"  + dateTime + ".sql";
            File backupFilePath = new File(backupFile);

            // 如果找不到目标文件
            if (!backupFilePath.exists())
            {
                //这说明目标文件的上级目录不存在，先新建所有的上级目录
                backupFilePath.getParentFile().mkdirs();
            }

            // 构建mysqldump命令
            // windows下 cmd  
            String command = "cmd /c mysqldump" + " -h " + HOST + " -P " + PORT + " -u " + USER + " -p" + PASSWORD + " " + DATABASE + " > " + backupFilePath.getAbsolutePath();
            
			// Linux下 /bin/sh
            //String[] command = new String[]{"/bin/sh", "-c", "/usr/bin/mysqldump" + " -h " + HOST + " -P " + PORT  " -u " + USER + " -p" + PASSWORD + " " + DATABASE + " > " + backupFilePath.getAbsolutePath()}
            
            // 执行命令
            Process process = Runtime.getRuntime().exec(command);
            int exitCode = process.waitFor();

            if (exitCode == 0) {
                log.error("Database backup successful: " + backupFile);

                // 压缩文件
                //FileZipUtil.zipFile(backupFile,BACKUP_DIR + "\\" + dateTime + ".zip");

                // 压缩文件加密
                FileZipUtil.encryptAndZip(backupFile,BACKUP_DIR + "\\" + dateTime + ".zip","123456");

                // 删除未加密之前的sql文件
                FileUtils.deleteFile(backupFile);

                // 删除过期的备份文件（例如，超过30天的文件）
                File backupDir = new File(BACKUP_DIR);
                File[] files = backupDir.listFiles();
                if (files != null) {
                    for (File file : files) {
                        if (file.isFile() && isExpired(file)) {
                            file.delete();
                        }
                    }
                }
            } else {
                log.error("Database backup failed.");
            }

        } catch (Exception e) {
            log.error("Database backup failed：" + e);
        }
    }

    /**
     * 查找过期文件
     * @param file
     * @return
     */
    private static boolean isExpired(File file) {
        long expiryDate = System.currentTimeMillis() - TimeUnit.DAYS.toMillis(DATE);
        return file.lastModified() < expiryDate;
    }

    /**
     * 测试
     * @param args
     */
    public static void main(String[] args) {
        backupDatabase();
    }
}

Springboot 有哪些加密压缩文件？

在Spring Boot中，没有直接内置的加密压缩文件功能。但是，你可以使用Java的内置库或第三方库来实现加密和压缩文件的功能。以下是一些在Spring Boot中常用的加密和压缩文件的方法：

1. 使用Java的内置库
   • 压缩: Java的java.util.zip包提供了ZipOutputStream类，可以用来创建ZIP文件。
   • 加密: Java的javax.crypto包提供了加密功能。你可以使用AES、DES等加密算法来加密数据。
2. 使用第三方库
   • Zip4j: 这是一个处理ZIP文件的强大库，支持加密和解密ZIP文件。你可以使用它来创建加密的ZIP文件。
   • Bouncy Castle: 这是一个流行的加密库，提供了广泛的加密算法，包括对称加密（如AES）和非对称加密（如RSA）。
   • Apache Commons Compress: 这是一个用于处理压缩和解压缩的库，它支持多种压缩格式，如ZIP、GZIP、BZIP2等。

Zip4j使用示例

引入依赖

<!-- 加密压缩文件的依赖配置-->
        <dependency>
            <groupId>net.lingala.zip4j</groupId>
            <artifactId>zip4j</artifactId>
            <version>1.3.1</version>
        </dependency>

工具类（普通压缩、加密压缩）

import com.ruoyi.common.utils.StringUtils;
import net.lingala.zip4j.core.ZipFile;
import net.lingala.zip4j.model.ZipParameters;
import net.lingala.zip4j.util.Zip4jConstants;

import java.io.*;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

/**
 * 文件压缩
 */
public class FileZipUtil {

    /**
     * 压缩文件
     * @param sourceFile 目标文件路径
     * @param zipFile 压缩文件路径
     * @throws IOException
     */
    public static void zipFile(String sourceFile, String zipFile) throws IOException {
        FileOutputStream fos = new FileOutputStream(zipFile);
        ZipOutputStream zos = new ZipOutputStream(fos);

        File fileToZip = new File(sourceFile);
        FileInputStream fis = new FileInputStream(fileToZip);
        ZipEntry zipEntry = new ZipEntry(fileToZip.getName());
        zos.putNextEntry(zipEntry);

        byte[] bytes = new byte[1024];
        int length;
        while ((length = fis.read(bytes)) >= 0) {
            zos.write(bytes, 0, length);
        }

        zos.closeEntry();
        fis.close();
        zos.close();
    }

    /**
     * 加密压缩文件
     * @param inputFilePath 目标文件路径
     * @param outputZipFilePath 输出文件路径
     * @param password 加密密码
     * @throws Exception
     */
    public static void encryptAndZip(String inputFilePath, String outputZipFilePath, String password) throws Exception {
        ZipParameters parameters = new ZipParameters();
        // 压缩方式
        parameters.setCompressionMethod(Zip4jConstants.COMP_DEFLATE);
        // 压缩级别
        parameters.setCompressionLevel(Zip4jConstants.DEFLATE_LEVEL_NORMAL);
        parameters.setFileNameInZip(inputFilePath.substring(inputFilePath.lastIndexOf("\\") + 1));
        if (StringUtils.isNotEmpty(password)) {
            // 加密方式
            parameters.setEncryptFiles(true);
            parameters.setEncryptionMethod(Zip4jConstants.ENC_METHOD_AES); // 使用AES加密算法
            parameters.setAesKeyStrength(Zip4jConstants.AES_STRENGTH_256); // 设置AES密钥强度
            parameters.setPassword(password.toCharArray());
        }
        // 加入压缩文件
        ZipFile zipFile = new ZipFile(outputZipFilePath);
        zipFile.addFile(new File(inputFilePath), parameters);
    }

}