java - 在 Java 中正确解析 BitTorrent UDP 通告响应

Question

我正在尝试解析通过 UDP 发送到 BitTorrent 服务器的 Announce 请求的响应。我取回了数据，但我认为我没有正确处理对等点的 IP 地址和端口，因为我无法与它们中的任何一个建立连接:

        Map<String, String> info = new Hashtable<String, String>();
        if (goodResponse) {
        try {
            int resAction = Utils.toInt(Utils.subArray(responseData, 0, 4));
            int resTrans = Utils.toInt(Utils.subArray(responseData, 4, 4));
            int interval = Utils.toInt(Utils.subArray(responseData, 8, 4));
            int leechers = Utils.toInt(Utils.subArray(responseData, 12, 4));
            int seeders = Utils.toInt(Utils.subArray(responseData, 16, 4));

            if (resAction != ERROR && resTrans == transactionID && resAction == ANNOUNCE) {

                info.put("udp", "tracker");
                info.put("seeders", String.valueOf(seeders));
                info.put("leechers", String.valueOf(leechers));
                info.put("interval", String.valueOf(interval));
                try {
                    for (int peer = 0; peer < leechers + seeders; peer++) {
                        InetAddress ip = Inet4Address.getByAddress(Utils.subArray(responseData, (20 + (6 * peer)), 4));
                        int port =  (int)Utils.toChar(Utils.subArray(responseData, (24 + (6 * peer)), 2));

                        if (port != 0) {
                            info.put(ip.getHostAddress(), String.valueOf(port));
                        }
                    }
                } catch (ArrayIndexOutOfBoundsException e) {
                    Log.w(TAG, "Too many peers returned, some were dropped");
                }
            } else if (resAction == ERROR) {
                error(responseData);
                info = null;
            } else {
                torrent.setErrorMessage("Unable to announce, invalid request");
                Log.i(TAG, "ANNOUNCE-E: A:" + resAction + " T: " + resTrans + " (" + transactionID + ") I: " + interval + " P: " + seeders + "/" + leechers);
                info = null;
            }
        } catch (Exception e) {
            torrent.setErrorMessage("Unable to announce with tracker " + host);
            Log.e(TAG, "ANNOUCE-EX: " + e.getClass().getSimpleName() + " - " + e.getMessage());
            info = null;
        }
    }

以下是辅助函数:

public static int toInt(final byte[] input) {
    return ByteBuffer.wrap(input).getInt();
}

public static char toChar(final byte[] input) {
    return ByteBuffer.wrap(input).getChar();
}

public static long toLong(byte[] input) {
    return ByteBuffer.wrap(input).getLong();
}

public static short toShort(byte[] input) {
    return ByteBuffer.wrap(input).getShort();
}

此代码确实吐出了 79.31.92.101:49378 和 79.168.1.215:65535 之类的主机，所以它看起来是正确的，但没有一个允许连接。我是否正在分析对等数据？

文档指出:

        Response:
        0           32-bit integer  action          1 // announce
        4           32-bit integer  transactionID
        8           32-bit integer  interval
        12          32-bit integer  leechers
        16          32-bit integer  seeders
        20 + 6 * n  32-bit integer  IP address
        24 + 6 * n  16-bit integer  TCP port (unsigned int)
        20 + 6 * N

文档链接: http://xbtt.sourceforge.net/udp_tracker_protocol.html

http://www.rasterbar.com/products/libtorrent/udp_tracker_protocol.html

Answer 1

太棒了，经过一些调整，我弄明白了。端口部分是正确的，IP 地址是关闭的。使用这一行而不是 InetAddress 行；

String ip = Utils.intToIp(Utils.toInt(Utils.subArray(responseData, (20 + (6 * peer)), 4)));

intToIP 是:

public static String intToIp(int i) {
    return ((i >> 24) & 0xFF) + "." + ((i >> 16) & 0xFF) + "." + ((i >> 8) & 0xFF) + "." + (i & 0xFF);
}