diff --git a/cpp/.gitignore b/cpp/.gitignore
new file mode 100644
index 0000000..e134367
--- /dev/null
+++ b/cpp/.gitignore
@@ -0,0 +1,2 @@
+.idea/
+cmake-build-debug/
\ No newline at end of file
diff --git a/cpp/CMakeLists.txt b/cpp/CMakeLists.txt
new file mode 100644
index 0000000..0c6a4bc
--- /dev/null
+++ b/cpp/CMakeLists.txt
@@ -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)
diff --git a/cpp/README.md b/cpp/README.md
new file mode 100644
index 0000000..e69de29
diff --git a/cpp/consumer.cpp b/cpp/consumer.cpp
new file mode 100644
index 0000000..c4d9886
--- /dev/null
+++ b/cpp/consumer.cpp
@@ -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;
+}
\ No newline at end of file
diff --git a/cpp/producer.cpp b/cpp/producer.cpp
new file mode 100644
index 0000000..31edb7b
--- /dev/null
+++ b/cpp/producer.cpp
@@ -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;
+  }
+}
\ No newline at end of file