标签：
常规的网络编程，在消息处理上大概会采用如下方式
struct msg{ int msg_id; int msg_len;
//...msg_info };
定义如上的消息结构
接收方接收后，按如上的消息结构解析数据
struct msg * _msg = (struct msg*)data;
然后消息处理，会按msg_id，将消息分发到不同的消息处理函数
switch(_msg->msg_id){ case 1: //do anything break; default: break; }
RPC则是对这种繁琐的消息处理过程做了封装，自动生成一一对应的消息响应代码，使开发者可以专注于逻辑的处理。
典型的RPC框架有protobuf、thrift，这些RPC提供了作为网络消息定义的DSL语言，用户使用DSL语言定义需要的网络事件，RPC框架即可自动生成客户端的发送和服务端的响应代码，而用户只需要按框架的约束实现网络通信的部分，即可专注于逻辑代码的编写，而不需要处理繁琐而重复的消息响应代码。
juggle是abelkhan服务器框架中的RPC框架。
这个框架采用高度解耦的设计，对数据的打包部分做了分离，而专注于消息响应代码的生成。目前支持c++和c# 2种语言。
使用juggle的方式如下:
定义DSL脚本
module test{ void test_func(string argv1, int argv2); }
使用codegen生成代码:
juggle采用python3.5编写，使用前需要安装python3.5，然后进入juggle所在的目录
如需生成c++代码测执行gencpp.py脚本，如需生成c#代码测执行gencsharp.py脚本
生成的代码如下：
c++代码:
客户端：
/*this caller file is codegen by juggle for c++*/ #include <sstream> #include <tuple> #include <string> #include <Icaller.h> #include <Ichannel.h> #include <boost/any.hpp> #include <boost/make_shared.hpp> namespace caller { class test : public juggle::Icaller { public: test(boost::shared_ptr<juggle::Ichannel> _ch) : Icaller(_ch) { module_name = "test"; } ~test(){ } void test_func(std::string argv0,int64_t argv1){ auto v = boost::make_shared<std::vector<boost::any> >(); v->push_back("test"); v->push_back("test_func"); v->push_back(boost::make_shared<std::vector<boost::any> >()); (boost::any_cast<boost::shared_ptr<std::vector<boost::any> > >((*v)[2]))->push_back(argv0); (boost::any_cast<boost::shared_ptr<std::vector<boost::any> > >((*v)[2]))->push_back(argv1); ch->push(v); } }; }
服务器端
/*this module file is codegen by juggle for c++*/
#include <Imodule.h>
#include <boost/shared_ptr.hpp>
#include <boost/signals2.hpp>
#include <string>
namespace module
{
class test : public juggle::Imodule {
public:
test(){
module_name = "test";
protcolcall_set.insert(std::make_pair("test_func", boost::bind(&test::test_func, this, _1)));
}
~test(){
}
boost::signals2::signal<void(std::string, int64_t) > sigtest_funchandle;
void test_func(boost::shared_ptr<std::vector<boost::any> > _event){
sigtest_funchandle(
boost::any_cast<std::string>((*_event)[0]),
boost::any_cast<int64_t>((*_event)[1]));
}
};
}
使用时客户端定义caller::test对象调用test_func即可，服务器端定义module::test 将响应函数连接到sigtest_funchandle即可。
juggle地址:https://github.com/qianqians/abelkhan/tree/master/common/juggle
欢迎大家到abelkhan的相关论坛提出bug和意见:http://abelkhan.com/forum.php?mod=forumdisplay&fid=2
标签：
原文地址：http://www.cnblogs.com/qianqians/p/5653052.html
