热负荷.jar文件：随机FileNotFoundException异常

Question

我有一个PluginManager类手表./plugins目录使用WatchService文件创建，然后从PluginLoader类在运行时加载新添加的罐子采用静态方法loadPlugin(File)。文件夹中的所有jar也会在应用程序启动时加载并启动，在这种情况下，即使插入一堆插件，情况也会一切顺利。
但是当我通过一个拖放插件到该文件夹​​一个，我得到一个奇怪的现象：只有5％左右的时间

第二98％

• 第一罐子装精
• 第三只在非常罕见的情况下，但它发生

我所得到的是这样的：

java.io.FileNotFoundException: .\plugins\test2.jar (Der Prozess kann nicht auf die Datei zugreifen, da sie von einem anderen Prozess verwendet wird) 
at java.util.zip.ZipFile.open(Native Method) 
at java.util.zip.ZipFile.<init>(ZipFile.java:220) 
at java.util.zip.ZipFile.<init>(ZipFile.java:150) 
at java.util.jar.JarFile.<init>(JarFile.java:166) 
at java.util.jar.JarFile.<init>(JarFile.java:130) 
at PluginLoader.loadPlugin(PluginLoader.java:34) 
at PluginManager$WatchQueueReader.run(PluginManager.java:118) 
at java.lang.Thread.run(Thread.java:745) 
Exception in thread "FileWatcher" java.lang.NullPointerException 
at PluginLoader.loadPlugin(PluginLoader.java:41) 
at PluginManager$WatchQueueReader.run(PluginManager.java:118) 
at java.lang.Thread.run(Thread.java:745) 

这是说该文件在另一个进程中使用。

插件加载：

public static BasePlugin loadPlugin(File pluginJar) { 
    Attributes attrib = null; 
    JarFile file = null; 
    try { 
     file = new JarFile(pluginJar); 
     Manifest manifest = file.getManifest(); 
     attrib = manifest.getMainAttributes(); 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } 

    String main = attrib.getValue(Attributes.Name.MAIN_CLASS); 
    String name = attrib.getValue("Plugin-Name"); 

    if (main == null || name == null) { 
     System.out.println("Not a valid manifest: " + pluginJar.getName()); 
     return null; 
    } 

    URLClassLoader loader = null; 
    try { 
     loader = URLClassLoader.newInstance(new URL[] { pluginJar.toURI().toURL() }, PluginLoader.class.getClassLoader()); 
    } catch (MalformedURLException e2) { 
     e2.printStackTrace(); 
    } 
    Class<?> cl = null; 
    try { 
     cl = Class.forName(main, true, loader); 
    } catch (ClassNotFoundException e1) { 
     e1.printStackTrace(); 
    } finally { 
     try { 
      loader.close(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 

    try { 
     Class<? extends BasePlugin> c = cl.asSubclass(BasePlugin.class); 
     Constructor<? extends BasePlugin> ctr = c.getConstructor(String.class, SystemManager.class); 
     return ctr.newInstance(name, this.sm); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
    return null; 
} 

WatchService内插件管理：

private static class WatchQueueReader implements Runnable { 

    private WatchService watcher; 
    private PluginManager pm; 

    public WatchQueueReader(PluginManager pm, WatchService watcher) { 
     this.pm = pm; 
     this.watcher = watcher; 
    } 

    @Override 
    public void run() { 
     try { 
      WatchKey key = watcher.take(); 
      while (key != null) { 
       for (WatchEvent<?> event : key.pollEvents()) { 
        switch (event.kind().toString()) { 
        case "ENTRY_CREATE": 
         Path dir = (Path) key.watchable(); 
         Path fullPath = dir.resolve(event.context().toString()); 
         BasePlugin plugin = PluginLoader.loadPlugin(fullPath.toFile()); 
         if (plugin != null) { 
          this.pm.startPlugin(plugin); 
         } 
         break; 
        case "ENTRY_MODIFY": 
         break; 
        case "ENTRY_DELETE": 
         this.pm.stopPlugin(event.context().toString()); // TODO wrong name (.jar) 
         break; 
        default: 
         break; 
        } 
       } 
       key.reset(); 
       key = watcher.take(); 
      } 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    } 
} 

BasePlugin是一个抽象类，插件扩展。

Answer 1

该文件仍在复制，WatchService只是发现它太快。实际上，只要创建了[inode]，但它还没有被填充信息（字节，你知道），它就会立即报告文件存在。

我的第一个提示是，如果遇到此异常，请等待几秒钟，然后重试。就在10-30秒的无用尝试之后，你可以放弃，因为它可能已被删除。但是这部分需要微调，因为复制操作可能很慢。