package org.springblade.mdm.machineback.filewatch;
|
import java.io.*;
|
import java.nio.channels.FileChannel;
|
import java.nio.channels.FileLock;
|
import java.nio.file.Files;
|
import java.nio.file.Path;
|
/*
|
监控文件是否传输完成（使用可否锁定来判断）
|
*/
|
|
public class FileLockChecker {
|
public static boolean isFileCompletelyWritten(Path file) {
|
try (RandomAccessFile raf = new RandomAccessFile(file.toFile(), "rw");
|
FileChannel channel = raf.getChannel()) {
|
|
// 尝试获取独占锁
|
FileLock lock = channel.tryLock();
|
if (lock != null) {
|
lock.release();
|
// 如果能获取锁，说明文件不再被写入
|
return true;
|
}
|
return false;
|
} catch (Exception e) {
|
// 如果发生异常，可能文件仍在被写入
|
return false;
|
}
|
}
|
|
/**
|
* 文件是否传输完成（采用前后文件大小比对方法）
|
* @param file
|
* @return
|
* @throws IOException
|
* @throws InterruptedException
|
*/
|
public static boolean isFileComplete(Path file) throws IOException, InterruptedException {
|
long initialSize = Files.size(file);
|
Thread.sleep(3000); // 等待1秒
|
long currentSize = Files.size(file);
|
return initialSize == currentSize;
|
}
|
}
|
