Jnotify動態監聽文件夾，郵件系統文件夾監聽示例

JNotify，一個支持動態監控文件和文件夾（支持級聯監控）的架包。在linux系統中，調用的是linux底層的inotify服務，只是添加了對子文件夾級聯監控的功能。在windows中，需要添加附件的dll文件，因為windows預設沒有該服務

一、郵件系統對本地文件夾的監聽

1、使用 jnotify 需要導入 jnotify.jar

2、需要在jdk/bin 添加jnotify 本地方法：jnotify.dll  jnotify_64bit.dll

二、步驟

1、jnotify監聽目錄

public class MailWatcher {
    /** 日誌 */
    private static final Logger LOG = LoggerFactory
            .getLogger(MailWatcher.class);
    // 收件路徑
    private String path;
    public MailWatcher() {
        // 收件郵件路徑
         path = Configure.getString("path");
    }
    // 監聽主線程
    public void start() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    int mask = JNotify.FILE_CREATED | JNotify.FILE_DELETED
                            | JNotify.FILE_MODIFIED | JNotify.FILE_RENAMED;
                    // 監聽接收郵件
                    int watchId = JNotify.addWatch(path, mask, true, new  MailListener());
                    // 是否監聽子目錄
                    boolean watchSubtree = true;
                    // 日誌
                    LOG.info("watcher開始監聽:{} {}", path, watchId);
                } catch (Exception e) {
                    LOG.error("監聽失敗", e);
                }
            }
        }).start();

        // 不讓主線程掛掉
        while (true) {
            try {
                Thread.sleep(200);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

2、監聽器，

//文件創建 動態監聽
public class MailListener implements JNotifyListener ｛

    /** 日誌 */
    private static final Logger LOG = LoggerFactory.getLogger(MailListener.class);
//文件重命名時
    public void fileRenamed(int wd, String rootPath, String oldName, String newName) {
        LOG.debug("{} renamed to {}", oldName, newName);
    }
//文件修改時
    public void fileModified(int wd, String rootPath, String name) {
        LOG.debug("{} modified", name);
    }
//文件刪除時
    public void fileDeleted(int wd, String rootPath, String name) {
        LOG.debug("{} deleted", name);
    }
//文件創建時
    public void fileCreated(final int wd, final String rootPath, final String name) {
        if (name.endsWith(".eml")) {
            LOG.info("{} created", name);
            new Thread(new Runnable() {
                @Override
                public void run() {
                    LOG.info("{},開始讀取", name);
                    MimeMessage msg = null;
                    File file = new File(rootPath, name);
                    try {
                        Thread.sleep(Configure.getLong("wait_first_time"));
                    } catch (Exception e) {
                        LOG.warn("{},初始等待失敗", name);
                    }
                    // 再迴圈等待50次，每次等待10秒，共計500秒
                    // 寫入郵件需要時間，所以迴圈
                    for (int i = 0; i < Configure.getInt("wait_times"); i++) {
                        try {

　　　　　　　　　　//這裡寫的封裝，file--->mimemessage
                            msg = EmlFileHelper.getMimeFile(file);
                            break;
                        } catch (Exception e) {
                            LOG.debug("第{}次讀取文件{}失敗", i + 1, name, e);
                        }
                        try {
                            Thread.sleep(Configure.getLong("wait_time_interval") * 1000l);
                        } catch (InterruptedException e) {
                            LOG.debug("等待失敗", e);
                        }
                    }
                    if (msg == null) {
                        LOG.error("{},重試後讀取失敗", name);
                        return;
                    }
                    if (!Configure.getBoolean("not_intercept_send_email")) {
                        // 判斷是否是發出的郵件，如果是，就不記錄
                        try {
                            String receiver = name.substring(0, name.indexOf(File.separator));

　　　　　　　　　　//這裡是我寫的郵件幫助類，忽略
                            String from = MailHelper.getFrom(msg);
                            if (from.startsWith(receiver + "@")) {
                                LOG.info("{}是發出的郵件，不記錄", name);
                                return;
                            }
                        } catch (Exception e) {
                            LOG.error("判斷是否是發出的郵件失敗", e);
                        }
                    }
                    try {
                        saveMsg(msg, name);
                        LOG.info("{},保存成功", name);
                    } catch (Exception e) {
                        LOG.error("{},保存失敗", name, e);
                    }
                }
            }).start();
        }       
    }
}

3、開啟監聽，

public class Main {
    public static void main(String[] args) throws Exception {
        new MailWatcher().start();
    }
}

4、說明，在main中開啟主線程，文件修改觸發jnotify 監聽方法，