如何在Bittorrent DHT中查找具有精确info_hash的节点？

Question

在 BitTorrent 中的 DHT 协议文档中，指出了使用 get_peers 方法来查找包含所需 info_hash 的节点。如果响应包含“values”键，则查询的节点已经返回关于包含完全相同 info_hash 的节点的信息。如果节点返回“nodes”键，则返回了 K 个最接近结果的节点。我们需要递归调用返回的节点（最接近的节点）的 get_peers 方法，以达到查找具有相同 info_hash 的节点的目的吗？

- Pratik Shinde

---

可能是 如何将Kademlia节点树与种子文件的infohash关联起来？ 的重复问题。 - the8472

感谢 @the8472 的指引。所以我们需要递归执行 get_peers 操作，直到在响应中获得“values”作为键？如果在响应中使用“nodes”作为键返回相同的节点，则停止执行此操作？请指导我。 - Pratik Shinde

你试过了吗？你遇到了什么特别的问题吗？“指导”有什么必要，你只是在寻求已经在多个地方阐述过的同样的陈述。 - the8472

@PratikShinde 你看了我的答案吗？ - amirouche

Answer 1

我们是否应该递归调用返回的节点（最接近的节点）上的get_peers，以达到精确节点（具有相同info_hash）的目的？

是和不是。如果你是LISP类型的人，你可以使用递归函数。话虽如此，while循环也能完成任务。这里有一些实现FIND_VALUE算法的Python代码，并带有一些注释：

async def _get(self, key):
    """Fetch the value associated with KEY from the network"""
    uid = key
    queried = set()
    while True:
        # retrieve the k nearest peers and remove already queried peers
        peers = nearest(k, self.peers)
        # no more peer to query, the key is not found in the dht
        if not peers:
            raise KeyError(uid)
        # query selected peers
        responses = dict()
        for address in peers:
            response = self._protocol.rpc(address, "value", uid)
            responses[address] = response
        # check responses: look for the value or add peers more near KEY
        for (address, response) in responses.items():
            queried.add(address)
            if isinstance(response, Exception):
                continue
            elif response[0] == b"VALUE":
                # value is found, return it
                value = response[1]
                if hash(value) == unpack(uid):
                    # at last!
                    return value
                else:
                    log.warning(
                        "[%r] bad value returned from %r", self._uid, address
                    )
                    await self.blacklist(address)
                    continue
            elif response[0] == b"PEERS":
                # value not found but we got peers that are more near KEY
                await self._welcome_peers(response[1])

此代码基于qadom's peer.py

- amirouche