【監聽文件 多線程】使用java--WatchService監聽文件 開啟多線程copy文件

有一個小需求：

在PC跟前沒有人的時候，迅雷下載文件 至PC磁盤上，並且自動移動文件到U盤上，小主只要在走的時候取走U盤即可。

基於這個需求，有了下面這段代碼：【JDK  1.8】

package com.sxd.moveFile;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardWatchEventKinds;
import java.nio.file.WatchKey;
import java.nio.file.WatchService;
import java.util.concurrent.TimeUnit;

import org.junit.Test;

import com.google.common.io.Files;

/**
 * 監聽某個文件夾下--如果有新的文件出現 則移動文件到指定目錄下
 * @author Administrator
 *
 */
public class MoveFile implements Runnable{
    
    public static String fileName = null;
    
    @Test
    public void test() throws IOException, InterruptedException{
        moveFile();
    }
    
    public void moveFile() throws IOException, InterruptedException{
        
        
            final Path path = Paths.get("E:/迅雷下載");
            final WatchService watchService = path.getFileSystem().newWatchService();
            path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE);//創建並啟動監聽 --創建文件的事件
            
//            final WatchKey watchKey = watchService.poll(20, TimeUnit.MINUTES);//poll()監聽停止的條件--持續20分鍾 20分鍾后關閉監聽
            final WatchKey  watchKey = watchService.take();//take()等不到此類事件發生就一直運行
            
            if(watchKey != null) {
                watchKey.pollEvents().stream().forEach(event ->
                {
                    //執行本次 觸發后的方法體
                    System.out.println(event.context());System.out.println(event.kind().name());
                    //僅 判斷 新創建文件后綴為.rmvb的   才進行如下 操作
                    if(event.context().toString().substring(event.context().toString().lastIndexOf(".")).equals(".rmvb")  || event.context().toString().substring(event.context().toString().lastIndexOf(".")).equals(".mkv")){
                        fileName = event.context().toString();
                        
                        MoveFile mf = new MoveFile();
                        Thread thread1 = new Thread(mf);//開啟一個新的線程 
                        thread1.start();
                    }
                });
                //再次執行
                try {
                    moveFile();
                } catch (Exception e1) {
                    e1.printStackTrace();
                }
                
            }
    
    }

    @Override
    public void run() {
        try {
            Files.copy(new File("E:/迅雷下載/"+fileName), new File("J:/U盤/迅雷下載/"+fileName));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 

 

其中 關於文件系統注冊的監聽器上，有監聽事件類型：

Overflow包含了文件的創建/刪除/修改各種事件。