[netplus]初见，Netplus快速开始之PingPong Example

继上篇 初心之让人人能写高性能服务器 已一星期，我们仍尚未谋面，我已迫不及待，是否还记得我曾经对你的承诺，我说，要让人人能编写高性能网络服务器，当然，这只是我一相情愿的告白，我不知道有没有被你看上，也不知道你是否还愿意在这条道上与我走一走，我们一起谈一谈，未来…

看起来这是一个梦啊，梦是当不得真的，但梦想还是可以做做的。

在这所有的所有的一切开始之前，我们还是不落俗套地见上一见吧，你说，自古套路得人心，而大家又总倾心于Hello World，要不，我们换一个，Ping Pong可好。

请你忘记你关于网络编程的想象，保留那么一点点CPP的印象，因为，好的忘记，是新的开始，而CPP正是我们的主角。

要懂东西的不多，我们就从最基本的问题开始吧。

---

[备注：此篇为初稿，期待你的反馈]

在开始之前，建议先阅读以下前置知识：

基本问题：什么是信息，何为传递，连接

Netplus试图解决什么问题

Netplus里的基本概念

Netplus收发消息的基本流程

c++11: std::tuple example & tutorial

c++11: lambda example & tutorial

---

PINGPONG Example

本篇，我们将演示如何实现一个完整版的PingPong服务器，以及客户端。

读完本文，你应该能用Netplus进行简单消息收发。

1. PINGPONG服务器

监听在tcp://127.0.0.1:13103端口

收到到来自远端的的连接的时候，为Channel添加一个Pong Handler

Pong Handler: 此Handler只做一个事情，当收到来自客户端的消息后，回复PONG

代码如下：

class Pong :public netp::channel_handler_abstract { public:Pong() : channel_handler_abstract(netp::CH_INBOUND_READ){}//for inboundvoid read(netp::ref_ptr<netp::channel_handler_context> const& ctx, netp::ref_ptr<netp::packet> const& income) {//reply with PONGconst std::string pong = "PONG";netp::ref_ptr<netp::packet> PONG = netp::make_ref<netp::packet>(pong.c_str(), pong.length());netp::ref_ptr<netp::promise<int>> write_promise = ctx->write(PONG);//check the reply status once the write operation is donewrite_promise->if_done([](int reply_rt) {NETP_INFO("[PONG]reply PONG, rt: %d", reply_rt );});} };

2. PINGPONG客户端

拨号到tcp://127.0.0.1:13103端口

当拨号成功之后，为Channel添加一个Ping Handler

Ping Handler: 当连接成功时，向服务器发送PING, 当成功收到回复的消息（PONG）后，继续发送PING

代码如下：

class Ping : public netp::channel_handler_abstract { public:Ping():channel_handler_abstract(netp::CH_ACTIVITY_CONNECTED|netp::CH_INBOUND_READ){}void connected(netp::ref_ptr<netp::channel_handler_context> const& ctx) {NETP_INFO("[PING]connected");//initial PINGdo_ping(ctx);}void read(netp::ref_ptr<netp::channel_handler_context> const& ctx, netp::ref_ptr<netp::packet> const& income) {NETP_INFO("[PING]reply income");do_ping(ctx);}void do_ping(netp::ref_ptr<netp::channel_handler_context> const& ctx) {const std::string ping = "PING";netp::ref_ptr<netp::packet> message_ping = netp::make_ref<netp::packet>();message_ping->write(ping.c_str(), ping.length());netp::ref_ptr<netp::promise<int>> write_p = ctx->write(message_ping);write_p->if_done([]( int rt ) {NETP_INFO("[PING]write PING, rt: %d", rt );});} };

 

3. PING PONG的总体执行逻辑

服务器监听tcp://127.0.0.1:13103

当服务器有新的channel连接进来时，为新的channel添加handler

客户端拨号到tcp://127.0.0.1:13103

客户端拨号成功后，添加handler

4. main 代码如下：

int main(int argc, char** argv) {//initialize a netplus app instancenetp::app app;std::string host = "tcp://127.0.0.1:13103";netp::ref_ptr<netp::channel_listen_promise> listenp = netp::socket::listen_on(host, [](netp::ref_ptr<netp::channel>const& ch) {ch->pipeline()->add_last( netp::make_ref<netp::handler::hlen>());ch->pipeline()->add_last( netp::make_ref<Pong>() );});int listenrt = std::get<0>(listenp->get());if (listenrt != netp::OK) {NETP_INFO("listen on host: %s failed, fail code: %d", host.c_str(), listenrt);return listenrt;}netp::ref_ptr<netp::channel_dial_promise> dialp = netp::socket::dial(host, [](netp::ref_ptr<netp::channel> const& ch ) {ch->pipeline()->add_last( netp::make_ref<netp::handler::hlen>() );ch->pipeline()->add_last( netp::make_ref<Ping>() );});int dialrt = std::get<0>(dialp->get());if (dialrt != netp::OK) {//close listen channel and returnstd::get<1>(listenp->get())->ch_close();return dialrt;}//wait for signal to exit//Ctrl+C on windows//kill -15 on linuxapp.run();//close listen channelstd::get<1>(listenp->get())->ch_close();//close dial channelstd::get<1>(dialp->get())->ch_close();return 0; }

 

5. 代码解读

5.1 netp::app

所有的netplus应用，netp::app app总是第一行代码，app实例代表着一个netplus对象，用处初始化netplus系统，设置信号处理。

app.run() 等待退出信号

5.2 Channel Handler hlen

• 这个handler用于处理格式为长度+内容的消息，内容长度占4bytes
• 发送时为消息添加消息长度，占4byte
• 接收时，先读4byte作为长度，然后按读到的长度继续读bytes, 直到读完给定的长度后，将read事件传递给下一个Handler，详细的描述，请参阅:

Netplus 之 Handler: hlen​github.com

 

5.3 ch->pipeline()->add_last( handler )

将handler添加到handler链表末尾

（此篇文章待进一步整理）

完整的工程地址如下：

Netplus 之 PINGPONG工程​github.com

 

知识库：

Netplus之WIKI​github.com

 

 

如果你喜欢我的文章，请加个关注，点个赞，谢谢。

 

写代码的冰冰

姑苏城里平江路，入夜细雨扰我心，再会。

 

想把我说给你听，，，

总结

以上是生活随笔为你收集整理的[netplus]初见，Netplus快速开始之PingPong Example的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。