java如何实现批量修改文件类型

// =================================================
// 文件：src/main/java/com/example/filerenamer/filefilterstrategy.java
// =================================================
package com.example.filerenamer;
 
import java.nio.file.path;
 
/**
 * 文件过滤策略接口
 */
public interface filefilterstrategy {
    /**
     * 判断是否接受该文件进行重命名
     * @param path 文件路径
     * @return true 则重命名
     */
    boolean accept(path path);
}
 
// =================================================
// 文件：src/main/java/com/example/filerenamer/suffixfilterstrategy.java
// =================================================
package com.example.filerenamer;
 
import java.nio.file.path;
import java.util.set;
 
/**
 * 按文件后缀过滤策略
 */
public class suffixfilterstrategy implements filefilterstrategy {
    private final set<string> sourcesuffixes;
    private final boolean ignorecase;
 
    public suffixfilterstrategy(set<string> suffixes, boolean ignorecase) {
        this.sourcesuffixes = suffixes;
        this.ignorecase = ignorecase;
    }
 
    @override
    public boolean accept(path path) {
        string name = path.getfilename().tostring();
        int idx = name.lastindexof('.');
        if (idx < 0) return false;
        string ext = name.substring(idx + 1);
        return sourcesuffixes.stream()
            .anymatch(s -> ignorecase
                ? s.equalsignorecase(ext)
                : s.equals(ext));
    }
}
 
// =================================================
// 文件：src/main/java/com/example/filerenamer/renamehook.java
// =================================================
package com.example.filerenamer;
 
import java.nio.file.path;
 
/**
 * 重命名钩子接口
 */
public interface renamehook {
    /**
     * 重命名前回调
     * @param oldpath 原始文件路径
     */
    void before(path oldpath);
 
    /**
     * 重命名后回调
     * @param newpath 新文件路径
     */
    void after(path newpath);
}
 
// =================================================
// 文件：src/main/java/com/example/filerenamer/batchresult.java
// =================================================
package com.example.filerenamer;
 
import java.nio.file.path;
import java.util.list;
 
/**
 * 批量重命名结果
 */
public class batchresult {
    private final list<path> succeeded;
    private final list<path> failed;
    public batchresult(list<path> succ, list<path> fail) {
        this.succeeded = succ; this.failed = fail;
    }
    public list<path> getsucceeded() { return succeeded; }
    public list<path> getfailed() { return failed; }
}
 
// =================================================
// 文件：src/main/java/com/example/filerenamer/filetypebatchrenamer.java
// =================================================
package com.example.filerenamer;
 
import java.io.ioexception;
import java.nio.file.*;
import java.util.*;
import java.util.concurrent.forkjoinpool;
import java.util.stream.collectors;
import java.util.stream.stream;
 
/**
 * 批量修改文件类型工具类
 */
public class filetypebatchrenamer {
 
    private final path rootdir;
    private final string targetsuffix;
    private final boolean backup;
    private final filefilterstrategy filter;
    private final list<renamehook> hooks;
 
    public filetypebatchrenamer(path rootdir,
                                string targetsuffix,
                                boolean backup,
                                filefilterstrategy filter,
                                list<renamehook> hooks) {
        this.rootdir = rootdir;
        this.targetsuffix = targetsuffix.startswith(".")
            ? targetsuffix.substring(1) : targetsuffix;
        this.backup = backup;
        this.filter = filter;
        this.hooks = hooks != null ? hooks : collections.emptylist();
    }
 
    /**
     * 同步批量重命名
     */
    public batchresult renameall() {
        list<path> succ = new arraylist<>();
        list<path> fail = new arraylist<>();
        try (stream<path> stream = files.walk(rootdir)) {
            for (path p : (iterable<path>) stream::iterator) {
                if (!files.isregularfile(p) || !filter.accept(p)) continue;
                try {
                    hooks.foreach(h -> h.before(p));
                    path renamed = dorename(p);
                    hooks.foreach(h -> h.after(renamed));
                    succ.add(renamed);
                } catch (ioexception ex) {
                    fail.add(p);
                }
            }
        } catch (ioexception e) {
            // 根目录无法访问
        }
        return new batchresult(succ, fail);
    }
 
    /**
     * 并行批量重命名
     */
    public batchresult renameallparallel() {
        forkjoinpool pool = new forkjoinpool();
        try {
            list<path> all = files.walk(rootdir)
                .filter(files::isregularfile)
                .filter(filter::accept)
                .collect(collectors.tolist());
            list<path> succ = collections.synchronizedlist(new arraylist<>());
            list<path> fail = collections.synchronizedlist(new arraylist<>());
            pool.submit(() ->
                all.parallelstream().foreach(p -> {
                    try {
                        hooks.foreach(h -> h.before(p));
                        path r = dorename(p);
                        hooks.foreach(h -> h.after(r));
                        succ.add(r);
                    } catch (ioexception ex) {
                        fail.add(p);
                    }
                })
            ).get();
            return new batchresult(succ, fail);
        } catch (exception e) {
            return new batchresult(collections.emptylist(), collections.emptylist());
        } finally {
            pool.shutdown();
        }
    }
 
    // 执行单个文件重命名（含备份逻辑）
    private path dorename(path p) throws ioexception {
        string name = p.getfilename().tostring();
        int idx = name.lastindexof('.');
        string base = idx < 0 ? name : name.substring(0, idx);
        if (backup) {
            path bak = p.resolvesibling(base + "." + targetsuffix + ".bak");
            files.copy(p, bak, standardcopyoption.replace_existing);
        }
        path dest = p.resolvesibling(base + "." + targetsuffix);
        return files.move(p, dest, standardcopyoption.replace_existing);
    }
 
    /**
     * 示例 main
     */
    public static void main(string[] args) {
        path dir = paths.get("c:/data/files");
        set<string> srcsuffix = set.of("jpg","png","bmp");
        filefilterstrategy filter = new suffixfilterstrategy(srcsuffix, true);
        filetypebatchrenamer renamer = new filetypebatchrenamer(
            dir, "webp", true, filter, null
        );
        batchresult result = renamer.renameallparallel();
        system.out.println("成功：" + result.getsucceeded().size());
        system.out.println("失败：" + result.getfailed().size());
    }
}