rest_rpc简介

编译器版本

谁在用rest_rpc

rest_rpc的特点

易

一个加法的rpc服务

//服务端注册加法rpc服务intadd(rpc_conn conn,int a,int b) {return a + b; }intmain(){  rpc_serverserver("127.0.0.1:9004",std::thread::hardware_concurrency());  server.register_handler<add>();  server.start();}

//客户端调用加法的rpc服务intmain(){auto rpc_call = []() -> asio::awaitable<void> {    rpc_client client;auto ec =co_await client.connect("127.0.0.1:9004");if(ec) {      REST_LOG_ERROR << ec.message();co_return;    }auto r =co_await client.call<add>(1,2);if(r.ec == rpc_errc::ok) {      REST_LOG_INFO <<"call result:" << r.value;assert(r.value ==3);    }  };sync_wait(rpc_call());}

获取一个对象的rpc服务

//1.先定义person对象structperson {int id;  std::string name;int age;};//2.提供rpc服务personget_person(person p) {  p.name ="jack";return p;}intmain(){  rpc_serverserver("127.0.0.1:9004",std::thread::hardware_concurrency());  server.register_handler<get_person>();  server.start();}

//客户端调用获取person对象的rpc服务intmain(){auto rpc_call = []() -> asio::awaitable<void> {    rpc_client client;auto ec =co_await client.connect("127.0.0.1:9004");if(ec) {      REST_LOG_ERROR << ec.message();co_return;    }        person p{1,"tom",20};auto r =co_await client.call<get_person>(p);if(r.ec==rpc_errc::ok) {      REST_LOG_INFO <<"call result:" << r.value.name;assert(r.value.name =="jack");    }  };sync_wait(rpc_call());}

酷

voidpublish() {  rpc_serverserver("127.0.0.1:9004",4);  server.async_start();    REST_LOG_INFO <<"will pubish, waiting for input";auto pub = [&]() -> asio::awaitable<void> {    std::string str;while (true) {      std::cin >> str;if(str =="quit") {break;      }// 向客户端发布一个string，你也可以发布一个对象，内部会自动序列化co_await server.publish("topic1", str);    }  };sync_wait(pub());}client 端代码：```cppvoidsubscribe() {  REST_LOG_INFO <<"will subscribe, waiting for publish";auto sub = [&]() -> asio::awaitable<void> {    rpc_client client;co_await client.connect("127.0.0.1:9004");while (true) {// 订阅topic1，库会自动将结果反序列化为std::string, 如果publish是一个person对象，则subscribe参数填person，内部会自动反序列化auto [ec, result] =co_await client.subscribe<std::string>("topic1");if (ec != rpc_errc::ok) {        REST_LOG_ERROR <<"subscribe failed:" <<make_error_code(ec).message();break;      }            REST_LOG_INFO << result;    }  };sync_wait(sub());}

快

活

namespaceuser_codec {// adl lookup in user_codec namespacetemplate<typename... Args> std::stringserialize(rest_adl_tag, Args &&...args) {   msgpack::sbufferbuffer(2 *1024);ifconstexpr (sizeof...(Args) >1) {msgpack::pack(buffer,std::forward_as_tuple(std::forward<Args>(args)...));   }else {msgpack::pack(buffer, std::forward<Args>(args)...);   }returnstd::string(buffer.data(), buffer.size()); }template<typename T> Tdeserialize(rest_adl_tag, std::string_view data) {try {static msgpack::unpacked msg;msgpack::unpack(msg, data.data(), data.size());return msg.get().as<T>();   }catch (...) {return T{};   } } }// namespace user_codec

rest_rpc的更多用法

std::string_viewecho(std::string_view str) {return str;}

社区和群