Flutter任务管理插件dtorrent_task的使用

Flutter任务管理插件dtorrent_task的使用

关于

Dart库用于实现BitTorrent客户端。

整个Dart Torrent客户端包含多个部分：

• Bencode
• Tracker
• DHT
• Torrent模型
• Common库
• UTP

此包实现了常规BitTorrent协议，并通过协调上述包来共同完成下载任务。

BEP支持

支持以下BEP规范：

• [BEP 0003 The BitTorrent Protocol Specification]
• [BEP 0005 DHT Protocal]
• [BEP 0006 Fast Extension]
• [BEP 0010 Extension Protocol]
• [BEP 0011 Peer Exchange (PEX)]
• [BEP 0014 Local Service Discovery]
• [BEP 0015 UDP Tracker Protocal]
• [BEP 0029 uTorrent transport protocol]
• [BEP 0055 Holepunch extension]

开发中支持：

• [BEP 0009 Extension for Peersers to Send Metadata Files]

其他支持将在不久后到来。

如何使用

此包需要依赖 dtorrent_parser：

dependencies:
  dtorrent_parser: ^1.0.4
  dtorrent_task: '>= 0.2.1 < 2.0.0'

首先，通过 .torrent 文件创建一个 Torrent 模型：

var model = await Torrent.parse('some.torrent');

然后，创建一个 Torrent Task 并启动它：

var task = TorrentTask.newTask(model, 'savepath');
task.start();

用户可以添加一些监听器来监控 TorrentTask 的运行状态：

task.onTaskComplete(() {
  // 监听任务完成事件
});

task.onFileComplete((String filePath) {
  // 监听文件完成事件
});

还有一些方法来控制 TorrentTask：

// 停止任务:
task.stop();

// 暂停任务:
task.pause();

// 继续任务:
task.resume();

示例代码

import 'dart:async';
import 'dart:io';

import 'package:dtorrent_common/dtorrent_common.dart';
import 'package:dtorrent_parser/dtorrent_parser.dart';
import 'package:dtorrent_task/src/task.dart';
import 'package:dtorrent_task/src/task_events.dart';
import 'package:events_emitter2/events_emitter2.dart';
import 'package:logging/logging.dart';
import 'package:path/path.dart' as path;

var scriptDir = path.dirname(Platform.script.path);
var torrentsPath =
    path.canonicalize(path.join(scriptDir, '..', '..', '..', 'torrents'));
var _log = Logger('task_example');
void main() async {
  try {
    var torrentFile = path.join(torrentsPath, 'big-buck-bunny.torrent');
    var savePath = path.join(scriptDir, '..', 'tmp');
    var model = await Torrent.parse(torrentFile);
    // model.announces.clear();
    var task = TorrentTask.newTask(model, savePath);
    Timer? timer;
    Timer? timer1;
    var startTime = DateTime.now().millisecondsSinceEpoch;
    EventsListener<TaskEvent> listener = task.createListener();
    listener
      ..on<TaskCompleted>((event) {
        print(
            'Complete! spend time : ${((DateTime.now().millisecondsSinceEpoch - startTime) / 60000).toStringAsFixed(2)} minutes');
        timer?.cancel();
        timer r cancel();
        task.stop();
      })
      ..on<TaskStopped>(((event) {
        print('Task Stopped');
      }));

    var map = await task.start();
    findPublicTrackers s().listen((announceUrls) {
      for (var element in announceUrls) {
        task.startAnnounceUrl(element, model.infoHashBuffer);
      }
    });
    _log.info('Adding dht nodes');
    for (var element in model.nodes) {
      _log.info('dht node $element');
      task.addDHTNode(element);
    }
    print(map);

    timer = Timer.periodic(Duration(seconds: 2), (timer) async {
      var progress = '${(task.progress * 100).toStringAsFixed(2)}%';
      var ads = ((task.averageDownloadSpeed) * 1000 / 1024).toStringAsFixed(2);
      var aps = ((task.averageUploadSpeed) * 1000 / 1024).toStringAsFixed(2);
      var ds = ((task.currentDownloadSpeed) * 1000 / 1024).toStringAsFixed(2);
      var ps = ((task.uploadSpeed) * 1000 / 1024).toStringAsFixed(2);

      var utpDownloadSpeed =
          ((task.utpDownloadSpeed) * 1000 / 1024).toStringAsFixed(2);
      var utpUploadSpeed =
          ((task.utpUploadSpeed) * 1000 / 1024).toStringAsFixed(2);
      var utpPeerCount = task.utpPeerCount;

      var active = task.connectedPeersersNumber;
      var seeders = task.seederNumber;
      var all = task.allPeersersNumber;
      print(
          'Progress : $progress , Peerses:($active/$seeded/$all)($utpPeerCount) . Download speed : ($utpDownloadSpeed)($ads/$ds)kb/s , upload speed : ($utpUploadSpeed)($aps/$ps)kb/s');
    });
  } catch (e) {
    print(e);
  }
}