SunnyQjm/TestAddLpEncodeToJndn
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

update

Browse Source
This commit is contained in:
SunnyQjm
2020-07-24 16:14:16 +08:00
parent aca93b1b19
commit 54972f8cb1
5 changed files with 217 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cpp/.gitignore
+2
View File
@@ -0,0 +1,2 @@
.idea/
cmake-build-debug/
cpp/CMakeLists.txt
+10
View File
@@ -0,0 +1,10 @@
cmake_minimum_required(VERSION 3.5)
project(test_add_lp_encode_to_jndn)
set(CMAKE_CXX_STANDARD 14)
add_executable(producer producer.cpp)
target_link_libraries(producer pthread ndn-cxx boost_system)
add_executable(consumer consumer.cpp)
target_link_libraries(consumer pthread ndn-cxx boost_system)
cpp/README.md
View File
cpp/consumer.cpp
+91
View File
@@ -0,0 +1,91 @@
//
// Created by sunny on 2020/7/24.
//
#include <ndn-cxx/face.hpp>
#include <ndn-cxx/lp/tags.hpp>
#include <ndn-cxx/lp/lp-headers.hpp>
#include <string>
#include <iostream>
// Enclosing code in ndn simplifies coding (can also use `using namespace ndn`)
namespace ndn {
// Additional nested namespaces can be used to prevent/limit name conflicts
namespace examples {
class Consumer : noncopyable {
public:
void
run() {
Interest interest(Name("/test/hello/" + std::to_string(1)));
// 如果需要传递参数，可以通过一下方式传递
std::string param = "{\"code\": 1, \"msg\": \"balabala\"}";
interest.setApplicationParameters(reinterpret_cast<const uint8_t *>(param.data()), param.size());
// 设置兴趣包的生存期，超过这个生存期没有收到对应的数据包，兴趣包就会触发超时
interest.setInterestLifetime(2_s); // 2 seconds
// 设置如果强制刷新，则不会命中途中路由器的缓存
interest.setMustBeFresh(true);
interest.setTag(make_shared<lp::CongestionMarkTag>(1));
interest.setTag(make_shared<lp::PktTypeTag>(2));
auto srcTag = make_shared<lp::SrcAddrTag>(lp::SrcAddrHeader(Name("/testSrcAddr")));
interest.setTag(srcTag);
srcTag->get().getMyPrefix()->wireEncode();
interest.setTag(make_shared<lp::DstAddrTag>(lp::DstAddrHeader(Name("/testDstAddr"))));
interest.setTag(make_shared<lp::BackupNameTag>(lp::BackupNameHeader(Name("/testBackupName"))));
auto cachePolicy = lp::CachePolicy();
cachePolicy.setPolicy(lp::CachePolicyType::NO_CACHE);
interest.setTag(make_shared<lp::CachePolicyTag>(cachePolicy));
// 发送兴趣包
m_face.expressInterest(interest,
bind(&Consumer::onData, this, _1, _2),
bind(&Consumer::onNack, this, _1, _2),
bind(&Consumer::onTimeout, this, _1));
std::cout << "Sending " << interest << std::endl;
// 需要调用processEvents处理NDN事件，这样才能处理收到的数据包，要不然程序就直接退出了
// 这个操作会一直阻塞，直到处理完所有的NDN事件
// processEvents will block until the requested data received or timeout occurs
m_face.processEvents();
}
private:
void
onData(const Interest &interest, const Data &data) {
std::cout << data << std::endl;
}
void
onNack(const Interest &interest, const lp::Nack &nack) {
std::cout << "received Nack with reason " << nack.getReason()
<< " for interest " << interest << std::endl;
}
void
onTimeout(const Interest &interest) {
std::cout << "Timeout " << interest << std::endl;
}
private:
Face m_face;
};
} // namespace examples
} // namespace ndn
int
main(int argc, char **argv) {
ndn::examples::Consumer consumer;
try {
consumer.run();
}
catch (const std::exception &e) {
std::cerr << "ERROR: " << e.what() << std::endl;
}
return 0;
}
cpp/producer.cpp
+114
View File
@@ -0,0 +1,114 @@
#include <ndn-cxx/face.hpp>
#include <ndn-cxx/security/key-chain.hpp>
#include <ndn-cxx/security/signing-helpers.hpp>
#include <ndn-cxx/lp/tags.hpp>
#include <ndn-cxx/lp/lp-headers.hpp>
#include <iostream>
using namespace std;
// Enclosing code in ndn simplifies coding (can also use `using namespace ndn`)
namespace ndn {
// Additional nested namespaces should be used to prevent/limit name conflicts
namespace examples {
class Producer {
public:
Producer() {}
void
run() {
cout << "before setInterestFilter" << endl;
// 向NFD注册一个名称前缀 /example/testApp
// 如果成功，NFD会在接收到以这个前缀开头的兴趣包转发给本程序，Producer::onInterest回调会被调用
m_face.setInterestFilter("/test",
bind(&Producer::onInterest, this, _1, _2),
nullptr, // RegisterPrefixSuccessCallback is optional
bind(&Producer::onRegisterFailed, this, _1, _2));
cout << "before processEvents" << endl;
// 处理NDN事件，Producer::onInterest回调是有这个函数里面调用的
// 意味着Producer::onInterest回调会在调用 face.processEvents 的线程运行
// 这个函数是一个阻塞函数，调用这个函数会期望处理所有相关的事件，如果向上面那样注册了前缀监听，则会一直处理事件
m_face.processEvents();
cout << "after processEvents" << endl;
}
private:
void
onInterest(const InterestFilter &, const Interest &interest) {
std::cout << ">> I: " << interest << std::endl;
// // 这边可以提取出来请求的参数
// std::string s(reinterpret_cast<const char *>(interest.getApplicationParameters().value()),
// interest.getApplicationParameters().value_size());
//
// std::cout << "收到的参数： " << s << std::endl;
cout << "CongestionMark: " << interest.getTag<lp::CongestionMarkTag>()->get() << endl;
assert(interest.getTag<lp::CongestionMarkTag>()->get() == 1);
cout << "PktType: " << interest.getTag<lp::PktTypeTag>()->get() << endl;
assert(interest.getTag<lp::PktTypeTag>()->get() == 2);
cout << "SrcAddr: " << interest.getTag<lp::SrcAddrTag>()->get().getMyPrefix()->toUri() << endl;
assert(interest.getTag<lp::SrcAddrTag>()->get().getMyPrefix()->toUri() == "/testSrcAddr");
cout << "DstAddr: " << interest.getTag<lp::DstAddrTag>()->get().getMyPrefix()->toUri() << endl;
assert(interest.getTag<lp::DstAddrTag>()->get().getMyPrefix()->toUri() == "/testDstAddr");
cout << "BackupName: " << interest.getTag<lp::BackupNameTag>()->get().getMyPrefix()->toUri() << endl;
assert(interest.getTag<lp::BackupNameTag>()->get().getMyPrefix()->toUri() == "/testBackupName");
cout << "CachePolicy: " << interest.getTag<lp::CachePolicyTag>()->get().getPolicy() << endl;
assert(interest.getTag<lp::CachePolicyTag>()->get().getPolicy() == lp::CachePolicyType::NO_CACHE);
static const std::string content("Hello, world!");
// Create Data packet
auto data = make_shared<Data>(interest.getName());
data->setFreshnessPeriod(10_s);
data->setContent(reinterpret_cast<const uint8_t *>(content.data()), content.size());
data->setTag(make_shared<lp::CongestionMarkTag>(1));
data->setTag(make_shared<lp::PktTypeTag>(2));
data->setTag(make_shared<lp::SrcAddrTag>(lp::SrcAddrHeader(Name("/testSrcAddr"))));
data->setTag(make_shared<lp::DstAddrTag>(lp::DstAddrHeader(Name("/testDstAddr"))));
data->setTag(make_shared<lp::BackupNameTag>(lp::BackupNameHeader(Name("/testBackupName"))));
auto cachePolicy = lp::CachePolicy();
cachePolicy.setPolicy(lp::CachePolicyType::NO_CACHE);
data->setTag(make_shared<lp::CachePolicyTag>(cachePolicy));
// Sign Data packet with default identity
m_keyChain.sign(*data);
// m_keyChain.sign(*data, signingByIdentity(<identityName>));
// m_keyChain.sign(*data, signingByKey(<keyName>));
// m_keyChain.sign(*data, signingByCertificate(<certName>));
// m_keyChain.sign(*data, signingWithSha256());
// Return Data packet to the requester
std::cout << "<< D: " << *data << std::endl;
m_face.put(*data);
}
void
onRegisterFailed(const Name &prefix, const std::string &reason) {
std::cerr << "ERROR: Failed to register prefix '" << prefix
<< "' with the local forwarder (" << reason << ")" << std::endl;
m_face.shutdown();
}
private:
Face m_face;
KeyChain m_keyChain;
};
} // namespace examples
} // namespace ndn
int
main(int argc, char **argv) {
try {
ndn::examples::Producer producer;
producer.run();
return 0;
}
catch (const std::exception &e) {
std::cerr << "ERROR: " << e.what() << std::endl;
return 1;
}
}