Netplus里的基本概念

 

本文为初见，Netplus快速开始之PingPong Example系列第三篇

---

1. netp::ref_ptr & netp::ref_base

C++是一门面向对象的语言，一切皆可为对象，然对象的创建与销毁，指针的传递、共享，在稍大一点的工程里面，如豆腐雕花，如履薄冰，一不小心，直接崩坏，尤其是引入多线性以及异步编程之后，更是令人心力交瘁，这种动不动就出王炸的逆天脾气，常使得开发者谈C色变。

那么对象的管理，到底有没有好一点的办法呢，netplus选择了ref_ptr&ref_base, 顾名思义，这是一种基于引用计数的对象管理机制，因篇幅关系，这里暂时只讲如何使用它。

• 在Netplus里面，绝大部分的class都继承于ref_base，ref_base作为根，提供引用计数的基本功能。
• 继承自ref_base的class，直接new/delete 的时候，编译器会报错。
• 继承netp::ref_base的class，需要配合模板netp::ref_ptr<T>进行使用。
• netp::ref_ptr<T>对象，只能通过netp::make_ref<T> 进行创建，不需要的时候，需赋值为nullptr。
• 每赋值给一次，引用计数增1，每被置nullptr一次，引用计数减1，当减到0的时候，其指向的内存将被回收，赋值是线程安全的。
• netp::ref_ptr<T>可以如指针 T* 一样用来访问其指向的对象。
• sizeof(netp::ref_ptr<T>) == sizeof(T*)。
• 更详细的知识，请参：

Netplus 之 Smart Pointer​github.com

• 下面是一个关于 ref_ptr&ref_base 的example

class ref_example: public netp::ref_base {int number;public:ref_example(int i):number(i){}int get_number() {return number;}void set_number(int i) {number=i;} };//创建，记住，不能直接new/delete, 只能借助 netp::make_ref 函数; netp::ref_ptr<ref_example> ref_example_1 = netp::make_ref<ref_example>(10);//可像裸指针一样访问对象 ref_example_1 ->set_number(10); int number_value = ref_example_1 ->get_number();//赋值，它是线程安全的 netp::ref_ptr<ref_example> ref_example_2 = ref_example_1;{ //它是容器安全的,可在各容器里面自由存储std::vector<netp::ref_ptr<ref_example>> ref_example_vector; ref_example_vector.push_back(ref_example_2); }//比较，注意，这里比较的是指向的地址 if( ref_example_2 == ref_example_1 ) { //比较两个ref_ptr对象是否指向同一个对象 }//ref_ptr对象的大小 == 机器的地址宽度，试想一下，将有何好处？ //sizeof(netp::ref_ptr<ref_example>) == sizeof(int*);//销毁， 不需要的时候，我们直接置nullptr即可 ref_example_1 = nullptr; ref_example_2 = nullptr;//借助于C++ RAII特性，局部变量，我们甚至都不用去置nullptr {netp::ref_ptr<ref_example> ref_example_3 = netp::make_ref<ref_example>(10); //离开此作用域后， ref_example_3指向的内存将自动被释放 }

是不是觉得，c++的对象管理也可以很自然，很简单，很符合直觉。^_^

2. Packet

• Packet是Netplus的一个重要Class, 继承自netp::ref_base，它提供用于读写bytes buffer的接口，是我们用来操作bytes buffer的工具。
• 网络编程中，当处理Bytes Buffer，特别是处理protocol时，我们需要读或修改头部，或直接往头部前面添加一些数据。Packet被专门设计成应对这种场景，它既可以往buffer的左边写，也可以在buffer末端往前写，于是，处理起来将变得极为方便。
• Channel将收到的bytes, 存储在Packet对象里面，然后再将此对象传递给它的第一个Handler。
• 往远端写bytes的时候，我们也是将bytes存储于一个Packet对象，然后最终传递给Channel。
• Example:

//创建一个packet对象 netp::ref_ptr<netp::packet> p = netp::make_ref<netp::packet>();//写入一个字符串 p->write("hello", netp::strlen("hello") );//将字符串读入buf //注：byte_t 实为unsigned char netp::byte_t hello_buf[10]={0}; netp::u32_t read_count = p->read(hello_buf, 10);//在packet buf的左边写入一个u32_t大小的整数 p->write_left<netp::u32_t>(103);//将刚刚写入的整数读入i103 netp::u32_t i103 = p->read<u32_t>();//销毁packet对象 p = nullptr;

3. Channel

• Channel是网络通信的主体，它即是当前的连接，它也是最终与操作系统进行交互，读写bytes，以及socket状态管理的实体。
• 每一个Channel可以添加一个多个Channel Handler，Channel Handler以单向链表的形式链接在一起，当与Channel相关的事件发生的时候，Channel负责将事件传递给第一个Channel Handler。
• 一个典型的channel read事件，按下面顺序在Handler中传递

socket read -> channel -> tail_handler -> handler1 -> handler2 -> ...

• 一个典型的channel write事件，按下面顺序在Handler中传递

head_handler -> ... -> handler2 -> handler1 -> tail_handler -> channel -> socket write

• 每一个handler在创建的时候都会包含一个tail handler, 一个head handler，用于处理缺省行为

4. Channel Handler

• Channel Handler是具体处理我们的消息的地方，处理完消息后，我们可以继续传递一个消息给下一个Handler，或直接终止当前消息的逻辑处理，甚至接关闭当前的Channel。
• Channel Handler需要继承 netp::channelhandler_abstract, 实现相应接口，用于处理网络事件，消息。
• 更多细节，请参:

Netplus 之 Concepts​

 

• 在我们的例子中，我们将用到如下Channel handler接口

void read(netp::ref_ptr<netp::channel_handler_context> const& ctx, netp::ref_ptr<netp::packet> const& income); void connected(netp::ref_ptr<netp::channel_handler_context> const& ctx);

 

下文我们聊一下在Netplus里面，实现一个服务器，客户端的基本流程

 

写代码的冰冰

 

总结

以上是生活随笔为你收集整理的Netplus里的基本概念的全部内容，希望文章能够帮你解决所遇到的问题。

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