0

我正在尝试/pk使用 Rust 和rust-libp2p向 IFPS DHT 插入一个简单的记录

这是我的代码（Rust 1.55，libp2p-rust 0.39.1）：

let mut key = "/pk/".bytes().collect::<Vec<_>>();
key.append(&mut local_key.public().into_peer_id().to_bytes());
let key = Key::from(key);
let mut value = local_key.public().into_protobuf_encoding();

kademlia_swarm.behaviour_mut().put_record(Record{
    key,
    value,
    publisher: None,
    expires: None
}, Quorum::One).expect("call put_record");

此代码成功找到 20 多个节点来插入记录，但插入总是失败。当我使用 运行我的代码时RUST_LOG=debug，我看到每个对等方在插入期间都终止了与 EOF 的连接。打电话kademlia::bootstrap()也没用。

仅供参考，当我使用 Go 和go-libp2p运行非常相似的东西时，它按预期工作：

publicKeyBytes, _ := localKey.GetPublic().Bytes()
pid, _ := peer.IDFromPublicKey(localKey.GetPublic())
key := "/pk/" + string(pid)
err = kademlia.PutValue(ctx, key, publicKeyBytes)

编辑：奖励赏金，用于简单演示如何使用 Rust 和 rust-libp2p 将记录添加到 IPFS DHT

4

1 回答 1

1

有趣的故事——我在问题中提出的例子是正确的——但是 rust-libp2p 中有一个错误，它破坏了与 go-libp2p 的互操作性。详见https://github.com/libp2p/rust-libp2p/pull/2309 _

于 2021-10-25T23:14:55.593 回答