如何使用 java 锁定文件(如果可能的话)

小开

如果你可以使用 Java NIO(JDK 1.4或更高版本) ，那么我认为你正在寻找 java.nio.channels.FileChannel.lock()

Lock ()

小开

与通道文件通道一起使用通道文件锁定

小开

最佳答案

您可能需要 FileChannel. lock。

try (
FileInputStream in = new FileInputStream(file);
java.nio.channels.FileLock lock = in.getChannel().lock();
Reader reader = new InputStreamReader(in, charset)
) {
...
}

(免责声明: 代码未编译，当然也未测试。)

请注意文件锁的 API 文档中题为“平台依赖性”的部分。

小开

使用随机访问文件，获取它的信道，然后调用 lock ()。输入或输出流提供的通道没有足够的特权来正确锁定。确保在 finally 块中调用 lock ()(关闭文件并不一定释放锁)。

小开

这可能不是你想要的，但是为了从另一个角度解决问题... ..。

这两个 Java 进程是否希望访问同一应用程序中的同一文件？也许您可以通过一个单一的、同步的方法(或者更好的方法，使用 JSR-166)过滤对文件的所有访问？这样，您就可以控制对文件的访问，甚至可以控制队列访问请求。

小开

不要使用 java.io包中的类，而是使用 java.nio包。后者有一个 FileLock类。可以对 FileChannel应用锁。

 try {
// Get a file channel for the file
File file = new File("filename");
FileChannel channel = new RandomAccessFile(file, "rw").getChannel();


// Use the file channel to create a lock on the file.
// This method blocks until it can retrieve the lock.
FileLock lock = channel.lock();


/*
use channel.lock OR channel.tryLock();
*/


// Try acquiring the lock without blocking. This method returns
// null or throws an exception if the file is already locked.
try {
lock = channel.tryLock();
} catch (OverlappingFileLockException e) {
// File is already locked in this thread or virtual machine
}


// Release the lock - if it is not null!
if( lock != null ) {
lock.release();
}


// Close the file
channel.close();
} catch (Exception e) {
}

小开

下面是一个示例代码片段，用于锁定一个文件，直到该文件的进程由 JVM 完成。

 public static void main(String[] args) throws InterruptedException {
File file = new File(FILE_FULL_PATH_NAME);
RandomAccessFile in = null;
try {
in = new RandomAccessFile(file, "rw");
FileLock lock = in.getChannel().lock();
try {


while (in.read() != -1) {
System.out.println(in.readLine());
}
} finally {
lock.release();
}
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}


}

小开

如果使用 winscp 或 ftp 进行传输，可以对 unix 使用这个函数:

public static void isFileReady(File entry) throws Exception {
long realFileSize = entry.length();
long currentFileSize = 0;
do {
try (FileInputStream fis = new FileInputStream(entry);) {
currentFileSize = 0;
while (fis.available() > 0) {
byte[] b = new byte[1024];
int nResult = fis.read(b);
currentFileSize += nResult;
if (nResult == -1)
break;
}
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("currentFileSize=" + currentFileSize + ", realFileSize=" + realFileSize);
} while (currentFileSize != realFileSize);
}

如何使用 java 锁定文件(如果可能的话)

澄清: