CAF:c++ actor framework
C++ actor framework简单使用
简介
下载/编译/安装
下载
编译/安装
简单使用
单次调用，没有使用线程池
复杂使用
思路
main.cpp 内容如下
msgHandle.h
msgHandle.cpp
blocking_actor 类型说明
释义
函数说明
其他loop 类型
其他说明
简介
CAF 是 C++ Actor 模型框架，借鉴了 erlang 和 akka 的 actor 思想。有强 C++ 11 特性。 特点是：轻量级，分布式，简单，可适应以及无锁。
官方文档：https://actor-framework.readthedocs.io/en/latest/index.html
Github地址: https://github.com/actor-framework/actor-framework
wike地址： https://github.com/actor-framework/actor-framework/wiki
下载/编译/安装
下载
Linux – Git 下载方式
CAF GitHub 地址 ： https://github.com/actor-framework/actor-framework
Git 下载 ,下载源码 master ：
备注：还需要安装 boost 库
git clone https://github.com/actor-framework/actor-framework.git
1
下载所有的 模块和 库。
git clone --recursive https://github.com/actor-framework/actor-framework.git
1
编译/安装
在linux 系统下载好后。在当前目录下，能看到 actor-framework 文件夹。
执行如下命令：
cd actor-framework #进入caf 文件夹 ./configure #执行configure 脚本，配置对应属性，按照默认属性配置 make #编译 make install #安装命令 make uninstall #卸载命令，如需卸载，执行此命令就可以。
1
2
3
4
5
简单使用
单次调用，没有使用线程池
#include 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 编译： g++ -g main.cpp -lcaf_core -o main 1 输出如下： main.cpp string type msg is :String 类型消息 int type msg is:123456789 1 2 3 复杂使用 主要针对 ： event_based_actor 类型说明 思路 启用线程操作，根据项目的实际需求使用，定义不同的消息注释，用来接收处理。 增加了如下文件：msgHandle.cpp msgHandle.h #include 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 · Atoms / 消息体智能指针 /behavior //定义actor 智能指针 msgHandleActor extern boost::shared_ptr 1 2 3 4 5 6 7 8 9 执行类 - 详细注释不做说明。 class ActorRun{ public: ActorRun(); ~ActorRun(); static ActorRun* instance(); void startActorOne(std::string what); void startActorTwo(std::string what,int value); /** * @brief startActorDelay --延时发送处理函数 * @param type --延时类型 0：毫秒 1：秒 * @param step --延时步长 * @param what --消息内容 -- string类型值 * @param value --消息内容 -- double类型值 */ void startActorDelay(bool type,int step,std::string what,double value); private: // 内部计数值。循环次数 int _count; }; 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 消息处理函数 caf::behavior msgHandleFuntion(caf::event_based_actor *self) { return{ [=](actorOne it,std::string &what) { std::cout<<"actorOne: "< 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 atom 对应消息发送函数 void ActorRun::startActorOne(std::string what) { caf::anon_send(*msgHandelActor,actorOne::value,what); } void ActorRun::startActorTwo(std::string what,int value) { caf::anon_send(*msgHandelActor,actorTwo::value,what,value); } void ActorRun::startActorDelay(bool type,int step,std::string what,double value) { if(_count == 10) return; if(!type) caf::delayed_anon_send(*msgHandelActor,std::chrono::milliseconds(step),actorDelay::value,what,_count,value); else caf::delayed_anon_send(*msgHandelActor,std::chrono::seconds(step),actorDelay::value,what,_count,value); _count ++; } 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 编译命令 g++ -g main.cpp msgHandle.cpp -lcaf_core -o main 1 运行结果 main.cpp actorOne: output:startOne actorTwo: output:startTwo value:123 actorDelay: count:0 text:output: value:0 actorDelay: count:1 text:output: value:1.11 actorDelay: count:2 text:output: value:2.22 actorDelay: count:3 text:output: value:3.33 actorDelay: count:4 text:output: value:4.44 actorDelay: count:5 text:output: value:5.55 actorDelay: count:6 text:output: value:6.66 actorDelay: count:7 text:output: value:7.77 actorDelay: count:8 text:output: value:8.88 actorDelay: count:9 text:output: value:9.99 1 2 3 4 5 6 7 8 9 10 11 12 13 blocking_actor 类型说明 Blocking actors always run in a separate thread and are not scheduled by CAF. Unlike event-based actors, blocking actors have explicit, blocking receive functions. Further, blocking actors do not handle system messages automatically via special-purpose callbacks (see Default and System Message Handlers). This gives users full control over the behavior of blocking actors. However, blocking actors still should follow conventions of the actor system. For example, actors should unconditionally terminate after receiving an exit_msg with reason exit_reason::kill。 具体翻译不做说明，大概功能，类似与线程中，阻塞锁，在生命周期内，一直处于活动状态，直到满足特定条件，退出。 接收函数 void blockingCalculatorFuntion(caf::blocking_actor *self) { bool running = true; self->receive_while(running) ( [](actorOne it,std::string &what) { std::cout<<"Block: -- "<<"actorOne: "< 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 消息指针定义，原子消息注释定义 extern boost::shared_ptr 1 2 消息发送函数 void ActorRun::startActorLoop_One() { caf::anon_send(*msgHandelLoopActor,actorOne::value,"Running"); } //退出函数 void ActorRun::startActorLoop() { caf::anon_send(*msgHandelLoopActor,actorLoop::value,"Exit"); } 1 2 3 4 5 6 7 8 9 消息指针 spwan msgHandelLoopActor = boost::shared_ptr 1 消息发送-- main函数内部 ActorRun::instance()->startActorLoop_One(); ActorRun::instance()->startActorLoop(); ActorRun::instance()->startActorLoop_One(); 1 2 3 执行结果如下: main.cpp Block: -- actorOne: Running Block: -- Exit! 1 2 3 blocking_actor ，在退出之后，结束生命周期，处于disable状态，再次发送消息，不会响应。在生产环境中使用，看个人理解了。 其他loop 类型 主要有三种循环接收，receive_while, receive_for and do_receive。很直观，while,for,do-while 官方样例如下： while size_t received = 0; receive_while([&] { return received < 10; }) ( [&](int) { ++received; } ); 1 2 3 4 5 6 for std::vector 1 2 3 4 5 6 7 do-while size_t received = 0; do_receive ( [&](int) { ++received; } ).until([&] { return received >= 10; }); 1 2 3 4 5 6 使用哪种循环方式，根据个人需求来使用了。 其他说明 一些特性说明： https://blog.csdn.net/xzwdev/article/details/41700001 还有一些其他功能.日志输出，I/O功能。 一些相关特性：同步发送，异步发送，消息跳过没有做相关说明，可以参考官方文档。 C++
版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。
推荐文章
最近发表
