热负荷.jar文件:随机FileNotFoundException异常
问题描述:
我有一个PluginManager
类手表./plugins
目录使用WatchService
文件创建,然后从PluginLoader
类在运行时加载新添加的罐子采用静态方法loadPlugin(File)
。文件夹中的所有jar也会在应用程序启动时加载并启动,在这种情况下,即使插入一堆插件,情况也会一切顺利。
但是当我通过一个拖放插件到该文件夹一个,我得到一个奇怪的现象:只有5%左右的时间 热负荷.jar文件:随机FileNotFoundException异常
- 第一罐子装精
- 第三只在非常罕见的情况下,但它发生
我所得到的是这样的:
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是一个抽象类,插件扩展。
答
该文件仍在复制,WatchService只是发现它太快。实际上,只要创建了[inode],但它还没有被填充信息(字节,你知道),它就会立即报告文件存在。
我的第一个提示是,如果遇到此异常,请等待几秒钟,然后重试。就在10-30秒的无用尝试之后,你可以放弃,因为它可能已被删除。但是这部分需要微调,因为复制操作可能很慢。
谢谢,那就是问题所在。也许可以在ENTRY_CREATE之后等待ENTRY_MODIFY? – Benjoyo
我不确定。该文档说:“当报告某个事件表明已监视目录中的文件已被修改时,则不能保证已修改该文件的程序(或程序)已完成。” – Koshinae