8

我按照Watching a Directory for Changes Java7 nio2 教程使用代码示例 WatchDir.java 递归地监视目录的全部内容。

代码如下所示：

// Get list of events for the watch key.
for (WatchEvent<?> event : key.pollEvents()) {
// This key is registered only for ENTRY_CREATE events, but an OVERFLOW event 
// can occur regardless if events are lost or discarded.
if (event.kind() == OVERFLOW) {
    continue;
}

// Context for directory entry event is the file name of entry.
@SuppressWarnings("unchecked")
WatchEvent<Path> ev = (WatchEvent<Path>)event;
Path fileName = ev.context();
Path fullPath = dir.resolve(fileName);

try {
    // Print out event.
    System.out.print("Processing file: " + fileName);

    processed = fileProcessor.processFile(fullPath);

    System.out.println("Processed = " + processed);

    if (processed) {
        // Print out event.
        System.out.println(" - Done!");
    }
} 
catch (FileNotFoundException e) {
    System.err.println("Error message: " + e.getMessage());
}
catch (IOException e) {
    System.err.println("Error processing file: " + fileName.toString());
    System.err.println("Error message: " + e.getMessage());
}

好的，所以问题（我肯定会做一些愚蠢的事情）就在这里：

processed = fileProcessor.processFile(fullPath);

它的作用是这样的：

public synchronized boolean processFile(Path fullPath) throws IOException {
String line;
String[] tokens;
String fileName = fullPath.getFileName().toString();
String fullPathFileName = fullPath.toString();

// Create the file.
File sourceFile = new File(fullPath.toString());

// If the file does not exist, print out an error message and return.
if (sourceFile.exists() == false) {
    System.err.println("ERROR: " + fullPathFileName + ": No such file");
    return false;
}

// Check file extension.
if (!getFileExtension(fullPathFileName).equalsIgnoreCase("dat")) {
    System.out.println(" - Ignored.");
    return false;
}

// Process source file.
try (BufferedReader bReader = new BufferedReader(new FileReader(sourceFile))) {
    int type;

    // Process each line of the file.
    while (bReader.ready()) {

        // Get a single line.
        line = bReader.readLine();

        // Get line tokens.
        tokens = line.split(delimiter);

        // Get type.
        type = Integer.parseInt(tokens[0]);

        switch (type) {
        // Type 1 = Salesman.
        case 1:
            -> Call static method to process tokes.
            break;
        // Type 2 = Customer.
        case 2:
            -> Call static method to process tokes.
            break;
        // Type 3 = Sales.
        case 3:
            -> Call static method to process tokes.
            break;
        // Other types are unknown!
        default:
            System.err.println("Unknown type: " + type);
            break;
        }
    }

    PrintStream ps = null;
    try {

        // Write output file.
        // Doesn't matter. 

    } 
    finally {               
        if (ps != null) {
            ps.close();
        }
    }
    return true;
}
}

我第一次处理事件时，一切正常！即使有超过 1 个文件要处理。但是在连续的时间里，我收到了这个错误信息：

该进程无法访问该文件，因为它正被另一个进程使用

我在这里做错了什么？我该怎么做才能成功处理连续文件？

我忘记提及的两个重要注意事项：

  1. 我正在使用 Windows 7。
  2. 当我在调试模式下运行应用程序时，它可以工作。

编辑：如果我在尝试使用文件之前添加一个睡眠，它会起作用：

Thread.sleep(500);

// Process source file.
try (BufferedReader bReader = new BufferedReader(new FileReader(sourceFile))) {

那么，有没有可能是 Windows 没有及时解锁文件呢？我该如何解决（以适当的方式）？

4

4 回答 4

18

好的，我找到了解决方案。我不知道这是否是最好的方法，但它确实有效。不幸的是，file.canRead() 和 file.canWrite() 都返回 true，即使文件仍然被 Windows 锁定。所以我发现如果我尝试用相同的名称“重命名”它，我知道 Windows 是否正在处理它。所以这就是我所做的：

    while(!sourceFile.renameTo(sourceFile)) {
        // Cannot read from file, windows still working on it.
        Thread.sleep(10);
    }
于 2013-03-20T20:43:32.663 回答
2

Arundev 给出的解决方案对我有用。

我需要添加睡眠时间，否则它不适用于多个请求并用于获取错误“进程无法访问文件，因为它正在被另一个进程使用”

if (StandardWatchEventKinds.ENTRY_CREATE.equals(event.kind())) {
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

// now do your intended jobs ...
于 2020-04-27T23:53:04.713 回答
1

我有类似的问题。但是我的文件在被复制时没有被锁定。如果我在创建它为空的事件后立即尝试阅读它。

我认为在你的情况下没有必要的技巧，你可以简单地处理错误，如果你得到错误，你可以执行睡眠，然后再试一次。但对我来说，这不适合我。我没有收到错误。所以我尝试了你的解决方案，我明白这对我来说也是不可接受的，因为我除了阅读之外没有其他权利。所以我可以建议我的“技巧”。我正在使用类 java.io.RandomAccessFile：

List<String> lines = null;

while(true){
    try( RandomAccessFile raf = new RandomAccessFile( fileFullPath.toFile() , "r" ) ){
        lines = Files.readAllLines( fileFullPath , Charset.forName(ENCODING) );
        break;
    }catch(FileNotFoundException ex){
        LOG.warn("File isn't yet completed: {}",ex.getMessage() );
        LOG.info( "Waiting {} for next attempt to read it" , SLEEP_INTERVAL_READING );
        try {
            Thread.sleep(SLEEP_INTERVAL_READING);
        } catch (InterruptedException e) {
            LOG.error("Waiting was interrupted",e);
        }
    }catch(Exception ex){
        LOG.error("Error in reading file ",ex);
        clear();
        return false;
    }
}
于 2016-04-22T15:22:44.823 回答
0

当事件是 ENTRY_MODIFY 类型时，请允许当前线程休眠几秒钟。我无法确切说明为什么会发生这种情况，但有时我的日志中正在打印多个 ENTRY_MODIFY 事件。根据您的文件大小，请设置睡眠时间。

if(kind ==  StandardWatchEventKinds.ENTRY_MODIFY){
try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    e.printStackTrace();
}
//toDo - something
}
于 2018-02-22T10:53:07.777 回答