一个不错的的rpc开源代码-rest_rpc

2024-04-03 28

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 一个不错的的rpc开源代码-rest_rpc

rest_rpc

c++11, high performance, cross platform, easy to use rpc framework.

It’s so easy to love RPC.

Modern C++开发的RPC库就是这么简单好用！

rest_rpc简介

rest_rpc是一个高性能、易用、跨平台、header only的c++11 rpc库，它的目标是让tcp通信变得非常简单易用，即使不懂网络通信的人也可以直接使用它。它依赖header-only的standalone asio(commit id:f70f65ae54351c209c3a24704624144bfe8e70a3)

可以快速上手，使用者只需要关注自己的业务逻辑即可。

谁在用rest_rpc

博世汽车
浙江智网科技
purecpp.org

在这里增加用户

rest_rpc的特点

易

rest_rpc为用户提供了非常简单易用的接口，几行代码就可以实现rpc通信了，来看第一个例子

一个加法的rpc服务

//服务端注册加法rpc服务

struct dummy{
  int add(rpc_conn conn, int a, int b) { return a + b; }
};

int main(){
  rpc_server server(9000, std::thread::hardware_concurrency());

  dummy d;
  server.register_handler("add", &dummy::add, &d);
  
  server.run();
}

//客户端调用加法的rpc服务
int main(){
  rpc_client client("127.0.0.1", 9000);
  client.connect();

  int result = client.call<int>("add", 1, 2);

  client.run();
}

获取一个对象的rpc服务

//服务端注册获取person的rpc服务

//1.先定义person对象
struct person {
  int id;
  std::string name;
  int age;

  MSGPACK_DEFINE(id, name, age);
};

//2.提供并服务
person get_person(rpc_conn conn) {
  return { 1, "tom", 20 };
}

int main(){
  //...
  server.register_handler("get_person", get_person);
}

//客户端调用获取person对象的rpc服务
int main(){
  rpc_client client("127.0.0.1", 9000);
  client.connect();
  
  person result = client.call<person>("get_person");
  std::cout << result.name << std::endl;
  
  client.run();
}

酷

异步？

同步？

future?

callback？

当初为了提供什么样的接口在社区群里还争论了一番，有人希望提供callback接口，有人希望提供future接口，最后我决定都提供，专治强迫症患者:)

现在想要的这些接口都给你提供了，你想用什么类型的接口就用什么类型的接口，够酷吧，让我们来看看怎么用这些接口吧：

//服务端提供echo服务
std::string echo(rpc_conn conn, const std::string& src) {
  return src;
}

server.register_handler("echo", echo);

客户端同步接口

auto result = client.call<std::string>("echo", "hello");

客户端异步回调接口

client.async_call("echo", [](asio::error_code ec, string_view data){
  auto str = as<std::string>(data);
  std::cout << "echo " << str << '\n';
});

async_call接口说明

有两个重载的async_call接口，一个是返回future的接口，一个是带超时的异步接口。

返回future的async_call接口：

std::future<std::string> future = client.async_call<CallModel::future>("echo", "purecpp");

带超时的异步回调接口：

async_call<timeout_ms>("some_rpc_service_name", callback, service_args...);

如果不显式设置超时时间的话，则会用默认的5s超时.

async_call("some_rpc_service_name", callback, args...);

client.async_call("echo", [](asio::error_code ec, string_view data) {
    if (ec) {                
        std::cout << ec.message() <<" "<< data << "\n";
        return;
    }

    auto result = as<std::string>(data);
    std::cout << result << " async\n";
}, "purecpp");

客户端异步future接口

auto future = client->async_call<FUTURE>("echo", "hello");
auto status = future.wait_for(std::chrono::seconds(2));
if (status == std::future_status::timeout) {
  std::cout << "timeout\n";
}
else if (status == std::future_status::ready) {
  auto str = future.get().as<std::string>();
  std::cout << "echo " << str << '\n';
}