改用 aria2 实现下载器

2025-06-28 09:04:45 +08:00 · 2024-02-23 00:07:48 +08:00
parent 46808e96c5
commit 65ffd6a92f
6 changed files with 210 additions and 75 deletions
--- a/lib/common/io/aria2c.dart
+++ b/lib/common/io/aria2c.dart
@ -0,0 +1,90 @@
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:aria2/aria2.dart';
+import 'package:flutter/foundation.dart';
+import 'package:starcitizen_doctor/base/ui.dart';
+import 'package:starcitizen_doctor/common/conf/app_conf.dart';
+import 'package:starcitizen_doctor/common/helper/system_helper.dart';
+
+class Aria2cManager {
+  static bool _isDaemonRunning = false;
+
+  static final String _aria2cDir =
+      "${AppConf.applicationSupportDir}\\modules\\aria2c";
+
+  static Aria2c? _aria2c;
+
+  static Aria2c get aria2c {
+    if (!_isDaemonRunning) throw Exception("Aria2c Daemon not running!");
+    if (_aria2c == null) {
+      _aria2c = Aria2c(
+          "ws://127.0.0.1:64664/jsonrpc", "websocket", "ScToolbox_64664");
+      _aria2c!.getVersion().then((value) {
+        dPrint("Aria2cManager.connected!  version == ${value.version}");
+      });
+    }
+    return _aria2c!;
+  }
+
+  static Future launchDaemon() async {
+    if (_isDaemonRunning) return;
+
+    /// skip for debug hot reload
+    if (kDebugMode) {
+      if ((await SystemHelper.getPID("aria2c")).isNotEmpty) {
+        dPrint("[Aria2cManager] debug skip for hot reload");
+        _isDaemonRunning = true;
+        return;
+      }
+    }
+
+    final sessionFile = File("$_aria2cDir\\aria2.session");
+    if (!await sessionFile.exists()) {
+      await sessionFile.create(recursive: true);
+    }
+
+    final exePath = "$_aria2cDir\\aria2c.exe";
+    dPrint("Aria2cManager .-----  aria2c start ------");
+    final p = await Process.start(
+        exePath,
+        [
+          "-V",
+          "-c",
+          "-x 10",
+          "--dir=$_aria2cDir\\downloads",
+          "--disable-ipv6",
+          "--enable-rpc",
+          "--pause",
+          "--rpc-listen-port=64664",
+          "--rpc-secret=ScToolbox_64664",
+          "--input-file=${sessionFile.absolute.path.trim()}",
+          "--save-session=${sessionFile.absolute.path.trim()}",
+          "--save-session-interval=60",
+          "--file-allocation=trunc",
+        ],
+        workingDirectory: _aria2cDir,
+        runInShell: false);
+    p.stdout.transform(utf8.decoder).listen((event) {
+      if (event.trim().isEmpty) return;
+      dPrint("[aria2c]: $event");
+      if (event.contains("IPv4 RPC: listening on TCP port")) {
+        _isDaemonRunning = true;
+        aria2c;
+      }
+    }, onDone: () {
+      dPrint("[aria2c] onDone: ");
+      _isDaemonRunning = false;
+    }, onError: (e) {
+      dPrint("[aria2c] stdout ERROR: $e");
+      _isDaemonRunning = false;
+    });
+    p.stderr.transform(utf8.decoder).listen((event) {
+      dPrint("[aria2c] stderr ERROR : $event");
+    });
+    while (true) {
+      if (_isDaemonRunning) return;
+      await Future.delayed(const Duration(milliseconds: 100));
+    }
+  }
+}