Flutter分布式哈希表(DHT)网络插件bittorrent_dht的使用

Flutter分布式哈希表(DHT)网络插件bittorrent_dht的使用

关于

Bittorrent DHT由Dart实现。

支持：

• BEP 0005 DHT协议

使用

一个简单的使用示例：

import 'package:bittorrent_dht/bittorrent_dht.dart';

main() async {
  var dht = DHT();
  var infohashStr = "your_infohash_str"; // 替换为你的infohash字符串
  var port = 22123; // 替换为你希望使用的端口
  dht.announce(infohashStr, port);
  await dht.bootstrap();
}

announce 方法可以在 DHT 启动后调用。但建议在启动 DHT 之前就调用它。一旦 DHT 启动，它会检查是否有 announce 操作，如果有，在每次新增 DHT 节点时，都会尝试将本地节点通告给新节点。

在发送 announce_peer 查询之前，应该先发送 get_peers 查询以获取 token。因此，当用户调用 announce 方法时，它会自动触发 get_peers 查询并返回结果。换句话说，如果用户没有下载任何资源，则无需通告本地节点，也不需要任何相关的节点。然而，用户可以通过调用 requestPeers 方法来请求节点：

dht.requestPeers(infoHashStr);

当 DHT 发现任何新节点时，它会通知监听器：

dht.onNewPeer((address, port, infoHash) {
  // 找到新的InfoHash节点
});

用户可以添加一个监听器来接收来自其他节点的错误信息：

dht.onError((code, msg) {
  print('发生错误: [$code]$msg');
});

要停止 DHT，只需调用 stop 方法：

dht.stop();

一旦 DHT 停止，每个处理程序都将被移除，且不会保存任何数据。如果用户在停止后重新启动 DHT，一切都会从头开始。

完整示例

以下是一个完整的示例代码：

import 'package:bittorrent_dht/src/dht_base.dart';
import 'package:bittorrent_dht/src/dht_events.dart';
import 'package:dtorrent_common/dtorrent_common.dart';
import 'package:dtorrent_parser/dtorrent_parser.dart';
import 'package:logging/logging.dart';

var _log = Logger('Dht Example');

void main() async {
  var torrent = await Torrent.parse('example/test7.torrent');
  var infohashStr = String.fromCharCodes(torrent.infoHashBuffer);
  var dht = DHT();
  
  // 存储已发现的节点
  var test = <CompactAddress>{};
  
  dht.announce(infohashStr, 22123);
  
  // 创建监听器
  var dhtListener = dht.createListener();
  dhtListener
    ..on<DHTError>((event) => 
        _log.warning('Error happened:', '[${event.code}]${event.message}'))
    ..on<NewPeerEvent>(
      (event) {
        if (test.add(event.address)) {
          _log.info(
              'Found new peer address : ${event.address}  ，Have ${test.length} peers already');
        }
      },
    );

  // 启动DHT
  await dht.bootstrap(udpTimeout: 5, cleanNodeTime: 5 * 60);

  // 添加引导节点
  for (var url in torrent.nodes) {
    await dht.addBootstrapNode(url);
  }

  // 10秒后停止DHT
  Future.delayed(Duration(seconds: 10), () {
    dht.stop();
  });
}

// 将整数转换为二进制字符串
String intToRadix2String(int element) {
  var s = element.toRadixString(2);
  if (s.length != 8) {
    var l = s.length;
    for (var i = 0; i < 8 - l; i++) {
      s = '0$s';
    }
  }
  return s;
}