利用JNA对文件进行监听之观察者模式

JNA为第三方的JNI的一个实现包。里面实现了很多windows与linux的工具类。

 

package com.xiva.demo.jna;

import java.io.File;

import com.sun.jna.platform.FileMonitor;
import com.sun.jna.platform.FileMonitor.FileEvent;
import com.sun.jna.platform.FileMonitor.FileListener;
import com.xiva.lucene.IvIndexUpdate;

public class IvFileListener implements FileListener
{
    private long lastTime = System.currentTimeMillis();
    
    public void fileChanged(FileEvent fileevent)
    {
        if (fileevent.getType() == FileMonitor.FILE_MODIFIED)
        {
            fileevent.getFile();
            System.out.println(Thread.currentThread().getId());
            File file = fileevent.getFile();
            System.out.println("FILE_MODIFIED:" + file.getName());
            long currentTime = System.currentTimeMillis();
            System.out.println(currentTime);
            if (currentTime - 10000L > lastTime)
            {
                try
                {
                    IvIndexUpdate.updateIndex();
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                }
            }
            lastTime = currentTime;
        }
        
    }
    
}

 

 

package com.xiva.demo.jna;

import java.io.File;
import java.util.concurrent.TimeUnit;

import com.sun.jna.platform.FileMonitor;
import com.sun.jna.platform.win32.W32FileMonitor;

/**
 * 目录检视
 */
public class JNADemo
{
    public static void main(String[] args)
    {
        File dir = new File("E:\\data\\lucene");
        
        FileMonitor fileMon = W32FileMonitor.getInstance();
        IvFileListener fileListen = new IvFileListener();
        System.out.println(Thread.currentThread().getId());
        try
        {
            fileMon.addWatch(dir, 10, true);
            fileMon.addFileListener(fileListen);
            
            TimeUnit.SECONDS.sleep(1000);
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
}

 

其中有一个小的缺陷，就是修改文件会同时响应两次。也许与win的事件响应机制有关，可能是修改文件内容与修改文件属性各响应一次。给出的一个这种方法就是加上条件判断：(currentTime - 10000L > lastTime) 。