勉强能用的依赖加载系统做好了

src/main/java/com/ilummc/tlib/dependency/TDependency.java

@@ -0,0 +1,77 @@
+package com.ilummc.tlib.dependency;
+
+import com.ilummc.eagletdl.EagletTask;
+import me.skymc.taboolib.Main;
+import me.skymc.taboolib.message.MsgUtils;
+
+import java.io.File;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class TDependency {
+
+    public static final String MAVEN_REPO = "http://repo.maven.apache.org/maven2";
+
+    /**
+     * 请求一个插件作为依赖，这个插件将会在所有已经添加的 Jenkins 仓库、Maven 仓库寻找
+     * <p>
+     * 阻塞线程进行下载/加载
+     *
+     * @param args 插件名称，下载地址（可选）
+     * @return 是否成功加载了依赖
+     */
+    public static boolean requestPlugin(String... args) {
+        return false;
+    }
+
+    /**
+     * 请求一个库作为依赖，这个库将会在 Maven Central、oss.sonatype 以及自定义的 Maven 仓库寻找
+     * <p>
+     * 阻塞线程进行下载/加载
+     *
+     * @param args 依赖名，格式为 groupId:artifactId:version
+     * @return 是否成功加载库，如果加载成功，插件将可以任意调用使用的类
+     */
+    public static boolean requestLib(String... args) {
+        if (args[0].matches(".*:.*:.*")) {
+            String[] arr = args[0].split(":");
+            File file = new File(Main.getInst().getDataFolder(), "/libs/" + String.join("-", arr) + ".jar");
+            if (file.exists()) {
+                TDependencyLoader.addToPath(Main.getInst(), file);
+                return true;
+            } else if (downloadMaven(MAVEN_REPO, arr[0], arr[1], arr[2], file)) {
+                TDependencyLoader.addToPath(Main.getInst(), file);
+                return true;
+            } else return false;
+        }
+        return false;
+    }
+
+    private static boolean downloadMaven(String url, String groupId, String artifactId, String version, File target) {
+        ReentrantLock lock = new ReentrantLock();
+        AtomicBoolean failed = new AtomicBoolean(false);
+        new EagletTask()
+                .url(url + "/" + groupId.replace('.', '/') + "/" + artifactId + "/" + version + "/" + artifactId + "-" + version + ".jar")
+                .file(target)
+                .setThreads(8)
+                .setOnStart(event -> lock.lock())
+                .setOnProgress(event -> MsgUtils.send("    下载速度 " + event.getSpeedFormatted()))
+                .setOnConnected(event -> MsgUtils.send("  正在下载 " + String.join(":", new String[]{groupId, artifactId, version}) +
+                        " 大小 " + event.getContentLength()))
+                .setOnError(event -> failed.set(true))
+                .setOnComplete(event -> {
+                    lock.unlock();
+                    MsgUtils.send("  下载 " + String.join(":", new String[]{groupId, artifactId, version}) + " 完成");
+                })
+                .start();
+        try {
+            while (lock.tryLock()) lock.unlock();
+        } catch (Exception ignored) {
+        } finally {
+            lock.lock();
+            lock.unlock();
+        }
+        return !failed.get();
+    }
+
+}