java new File() 挂在过时的 NFS 挂载点上

Question

在我的 java 代码中，我正在读取一个 NFS 挂载目录（代码在 NFS client 机器上运行）。只要 NFS 服务器机器启动并运行，一切都很好，但是当 NFS 服务器关闭时（出于任何原因），代码会挂在任何创建新文件到 nfs 挂载目录的地方。如果我只是 umount nfs 目录，我的代码运行没有问题，但我不想每天手动检查此类问题，只想在我的代码中处理这种情况

这是 NFS 服务器的 /etc/exports：

/var/nfs/general *(rw,insecure,all_squash,no_subtree_check)

实际的java代码很简单：

log.info("before new");
File file = new File("/var/nfs/general");
log.info("after new");

它只在日志文件中打印“before new”，永远不会到达“after new”

我将新文件放入 Executor 服务中，超时时间与建议的一样，但即使超时 2 秒仍会挂起：

How do I call some blocking method with a timeout in Java?

• 操作系统：两台服务器（NFS 客户端和服务器）上的 ubuntu 服务器 16.04

  Java 版本：1.8_172

Answer 1

您可以简单地将其包装在 Callable 下并使用 get() 并设置超时。下面是一个示例代码，如果结果（此处的文件）不可用，它会在 20 秒后超时！

FutureTask<File> futureFile = new  FutureTask<File>(new Callable<File>(){
    public File call() throws Exception {
        return new File(filePath);
    }
});

futureFile.get(20, TimeUnit.SECONDS);

出于测试目的，我已将超时设置为 3 ns。在这种情况下，文件肯定会超时。

public static File readTimeOut(final String filePath, int timeOutInMillis) throws InterruptedException, ExecutionException, TimeoutException {
        ExecutorService executor = Executors.newFixedThreadPool(1);
        FutureTask<File> futureFile = new FutureTask<File>(new Callable<File>() {

            public File call() throws Exception {
                System.out.println("I am called");
                return new File("/usr/mohamed");
            }
    });
    executor.execute(futureFile);
    return futureFile.get(3, TimeUnit.NANOSECONDS);
}

（保持一切简单。资源没有正确关闭！）但这肯定可以用 FutureTask 处理。