需要一个使用 dht_put_item 和 libtorrent 的示例答案

【问题标题】：Need an example using dht_put_item with libtorrent需要一个使用 dht_put_item 和 libtorrent 的示例
【发布时间】：2019-02-20 06:50:35
【问题描述】：

我正在尝试使用 dht 来通过 libtorrent 保存可变数据。据我了解，正确的方法是使用 session 中的 dht_put_item 方法。问题是我需要传递一个回调函数，我不知道我做错了什么......我的代码如下所示

namespace lt = libtorrent;

//The callback function
void cb(lt::entry& cdentry, boost::array<char,64>& cbarray, boost::uint64_t& cbint, std::string const& cbstring){
    //My stuff here
}

void main(){
    //The session
    lt::session ses;
    //The data I want to insert into DHT
    std::string cadenaStr = "519d818411de49652b4aaf34850321de28bb2dce";        

    //Now I create the keys
    unsigned char seed[32];
    unsigned char public_key[32];
    unsigned char private_key[64];
    unsigned char signature[32];
    ed25519_create_seed(seed);
    ed25519_create_keypair(public_key, private_key, seed);
    ed25519_sign(signature, cadenaStr.c_str(), sizeof(cadenaStr.c_str()), public_key, private_key);

    //How can I use this?, where is the data supposed to go? :|
    ses.dht_put_item(public_key, cb, false);
}

在 libtorrent/session_handler.hpp 这个方法被定义为

void dht_put_item(boost::array<char, 32> key
    , boost::function<void(entry&, boost::array<char,64>&
    , boost::uint64_t&, std::string const&)> cb
    , std::string salt = std::string());

谁能告诉我我做错了什么。

谢谢！

【问题讨论】：

标签： c++ dht libtorrent

【解决方案1】：

在我用于测试的 libtorrent 存储库中有一个示例。它可以生成密钥、放置和获取可变和不可变项。

https://github.com/arvidn/libtorrent/blob/master/tools/dht_put.cpp

我该如何使用它？，数据应该去哪里？ :|

您在被调用的回调中提供数据。使用这种 API 的原因是，在某些用例中，您希望改变数据，然后您需要首先知道该键下是否已经存储了某些内容，以及它是什么。

【讨论】：

谢谢，绑定工作得很好。我要提出另一个问题，因为我还有另一个问题，我认为其他帖子会让其他用户的答案更清楚。 :)

【解决方案2】：

您缺少会话的设置包。

lt::settings_pack settings;
settings.set_bool(settings_pack::enable_dht, false);
settings.set_int(settings_pack::alert_mask, 0xffffffff);
ses.apply_settings(settings);
settings.set_bool(settings_pack::enable_dht, true);
ses.apply_settings(settings);

然后你需要通过等待警报等到收到 boostrap 消息。

wait_for_alert(ses, dht_bootstrap_alert::alert_type);

最后，你的 dht_put_item 调用：

char const* cadenaStr = "519d818411de49652b4aaf34850321de28bb2dce"; 
dht_put_item(public_key, std::bind(&put_string, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4, public_key, private_key, cadenaStr));

您将需要这些功能：

static alert* wait_for_alert(session* ses, int alert_type)
{
    alert* ret = nullptr;
    bool found = false;
    while (!found)
    {
        ses->wait_for_alert(seconds(5));
        std::vector<alert*> alerts;
        ses->pop_alerts(&alerts);
        for (std::vector<alert*>::iterator i = alerts.begin()
            , end(alerts.end()); i != end; ++i)
        {
            if ((*i)->type() != alert_type)
            {
                continue;
            }
            ret = *i;
            found = true;
        }
    }
    return ret;
}

static void put_string(
    entry& e
    ,boost::array<char, 64>& sig
    ,boost::int64_t& seq
    ,std::string const& salt
    ,boost::array<char, 32> const& pk
    ,boost::array<char, 64> const& sk
    ,char const* str)
{
    using dht::sign_mutable_item;
    if (str != NULL) {
        e = std::string(str);
        std::vector<char> buf;
        bencode(std::back_inserter(buf), e);
        dht::signature sign;
        seq++;
        sign = sign_mutable_item(buf, salt, dht::sequence_number(seq)
            , dht::public_key(pk.data())
            , dht::secret_key(sk.data()));
        sig = sign.bytes;
    }
}

【讨论】：