1

学校のプロジェクト用に単純な BitTorrent トラッカーを作ろうとしています。現在、完全にハッキングされていますが、どこが間違っているのかわかりません。サーバーの応答がどうあるべきかについて誤解があるのではないかと思っています。私はnode.jsとexpressを使用しています。

サーバーは、?info_hash データを含む /GET 要求を問題なく受け取ります。そして、その情報を JSON ファイルに保存できます。サーバーは、ベンコーディングを使用してクライアントに応答することもできます。応答は、間隔とピア リストを含む辞書です。リスト内にはいくつかのディクショナリがあり、各ディクショナリはピアの IP とポートを保持しています。

現在、どのピアも相互に接続されていません。デスクトップとは別のネットワークにラップトップを配置すると、デスクトップが潜在的なピア、正しい IP とポート (私の知る限り) として認識されますが、しばらくするとピア リストから削除されます。各クライアントで大洪水とqBitTorrentを使用しています。

アプリのコードは次のとおりです。

var express = require('express');
var app = express();
var fs = require("fs");
var contents = fs.readFileSync("data.json");
var data = JSON.parse(contents);

var findTorrent = function(data, hash) {
  for(var i = 0; i < data.length; i++) {
    if(data[i].info_hash === hash) {
      return data[i];
    }
  }
  return false;
}

var findID = function(data, qPort, qip) {
  for(var i = 0; i < data.length; i++) {
    //console.log(data[i].peer_id);
    if(data[i].port == qPort && data[i].ip === qip) {
      return true;
    }
  }
  return false;
}

var findHash = function(data, id) {
  for(var i = 0; i < data.length; i++) {
    if(data[i].peer_id === id) {
      return data[i];
    }
  }
  return false;
}

function hashy (str) {
  var url = str;
  var hexval = '';

  for(var i = 0; i < url.length; i++) {
    if(url[i] !== '%') {
      var code = url.charCodeAt(i);
      var hex = code.toString(16);
      hexval += hex;
    } else {
      hexval += url[i+1] + url[i+2];
      i += 2;
    }
  }
  return hexval;
}

app.get('/', function(req, res) {

  console.log(req.query);
  var info_hash = hashy(req.query.info_hash);
  console.log(info_hash);
  var peer_id = decodeURIComponent(req.query.peer_id);
  var escaped = escape(req.query.peer_id);
  console.log('escaped ' + escaped);
  console.log('decoded ' + peer_id);
  console.log('normal  ' + req.query.peer_id);

  var ip = req.connection.remoteAddress;
  if(ip.substring(0,7) == '::ffff:') {
    ip = ip.substring(7);
  }
  //var port = req.connection.remotePort;
  var port = req.query.port;
  console.log(ip);
  var torrent = findTorrent(data, info_hash);
  var completed;
  if (torrent === false){
    if(req.query.left === '0') {
      completed = true;
    } else {
      completed = false;
    }
    var obj = { "info_hash" : info_hash, "peers" : [{ "peer_id" : peer_id, "ip" : ip, "port" : port, "completed" : completed }]};
    data.push(obj);
    torrent = obj;
    //console.log(obj.peers);
  }
  else {
    //figure out if completed
    if(req.query.left == '0') {
      completed = true;
    } else {
      completed = false;
    }

    var peer = findHash(torrent.peers, peer_id);
    if(peer === false){
      var obj = { "peer_id" : peer_id, "ip" : ip, "port" : port, "completed" : completed };
      torrent.peers.push(obj);
    }
    else {
      peer.ip = ip;
      peer.port = port;
      peer.completed = completed;
    }
  }

  if(torrent) {
    var response = bencode(torrent);
  }
  else {
    response = 'error';
  }

  //console.log(data);

  fs.writeFileSync("data.json", JSON.stringify(data, null, 2), 'utf-8');
  res.send(response);
});

var bencode = function(torrent) {
  var response = 'd8:intervali600e12:min intervali30e'
  var complete = 0;
  var incomplete = 0;
  for(var i = 0; i < torrent.peers.length; i++) {
    if(torrent.peers[i].completed === true) {
      complete++;
    } else {
      incomplete++;
    }
  }
  var response = response.concat('8:completei' + complete + 'e');
  var response = response.concat('10:incompletei' + incomplete + 'e5:peersl');
  for(var i = 0; i < torrent.peers.length; i++) {
    response = response.concat('d');
    response = response.concat('2:ip');
    response = response.concat(torrent.peers[i].ip.length + ':');
    response = response.concat(torrent.peers[i].ip);
    //response = response.concat('7:peer id');
    //response = response.concat(torrent.peers[i].peer_id.length + ':');
    //response = response.concat(torrent.peers[i].peer_id);
    response = response.concat('4:port');
    response = response.concat('i' + torrent.peers[i].port + 'e');
    response = response.concat('e');
  }
  response = response.concat('ee');
  console.log(response);
  return response;
}

app.listen(4000, function() {
  console.log('Example app listening on port 4000!');
});

Amazon AWS でホストされているトラッカーに接続でき、qBitTorrent はそれを「動作中」と報告しています。また、GET リクエストが送信され、サーバーの応答が Wireshark 経由で受信されることも確認できます。リクエストには、次のコード化された文字列が含まれており、これで十分だと思います。

d8:intervali600e12:min intervali30e8:completei2e10:incompletei3e5:peersld2:ip13:73.66.138.2174:porti8999eed2:ip13:73.66.138.2174:porti63014eed2:ip13:73.66.138.2174:porti8999eed2:ip13:73.25.106.1804:porti6881eed2:ip13:73.66.249.1414:porti8999eeee

www.bittorrent.org によると、応答に必要なのは間隔と、ピアのリストにマッピングされたピア リストだけです。各ピアには ID、IP、およびポートが必要です。

クライアントがリクエストで報告しているポートにポートを切り替え、トレントクライアントがポート転送されていることを確認し、現在動作しているようです. 私はまだこれに取り組み続けるつもりですが。現在、ピアがシード/リーチングを停止したときにピアを削除する方法がありません。

4

2 に答える 2

0

これは主に、トラッカーではなくピア間の問題のようです。それらが両方とも NAT されている場合、相互に接続できるようにするには、少なくとも一方のポートが NAT を介して転送される必要があります。

トラッカーの応答のポートは、ピアが要求で報告したものである必要があります。

トラッカー レスポンスのコード化された dict はソートされていません。キー complete, incomplete, interval, min interval, peersの順序は生の文字列としてソートする必要があります。
そうでない場合、一部のクライアントで問題が発生する可能性があります。

もう 1 つのことは、BEP3 で指定されたトラッカーの応答は、まだ正しいものの、compact=1応答によって廃止されたことです。最新のクライアントはすべて「コンパクト」をサポートしています。従来の方法のサポートを中止したクライアントを私は認識していませんが、一部のトラッカーはサポートを中止しています。
Bram Cohen は次のように述べています。ポスト #5

BitTorrent プロトコルに関する優れたリソースは、https: //wiki.theory.org/BitTorrentSpecification です。

この回答は、最初にコメントとして投稿されたものの編集版です。

于 2016-12-08T11:12:55.983 に答える