1万行代码，单机50万QPS，今年最值得学习的开源RPC框架！

Posted 2021-12-20 58沈剑

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了1万行代码，单机50万QPS，今年最值得学习的开源RPC框架！相关的知识，希望对你有一定的参考价值。

又发现一个不错的，工业级的，高性能RPC框架srpc，分享给大家。

（1）RPC简介；

（2）行业常见RPC框架；

（3）srpc特点；

（4）srpc上手指南，demo示例；

（5）srpc架构设计；

（6）srpc相关资料与资源；

文章较长，建议提前收藏。

什么是RPC？

Remote Procedure Call，远程过程调用。

什么是“远程”，为什么“远”？

先来看下什么是“近”，即“本地函数调用”。

当我们写下：

int result = Add(1, 2);

这行代码的时候，到底发生了什么？

（1）传递两个入参；

（2）调用了本地代码段中的函数，执行运算逻辑；

（3）返回一个出参；

这三个动作，都发生在同一个进程空间里，这是本地函数调用。

那有没有办法，调用一个跨进程的函数呢？

典型的，这个进程部署在另一台服务器上。

最容易想到的，两个进程约定一个协议格式，使用Socket通信，来传输：

（1）入参；

（2）调用哪个函数；

（3）出参；

如果能够实现，那这就是“远程”过程调用。

为什么需要RPC框架呢？

如果没有统一的RPC框架，各个团队的服务提供方就需要各自实现一套序列化、反序列化、网络框架、连接池、收发线程、超时处理、状态机等“业务之外”的重复技术劳动，造成整体的低效。

RPC框架的职责，就是要屏蔽各种复杂性：

（1）调用方client感觉就像调用本地函数一样，来调用服务；

（2）提供方server感觉就像实现一个本地函数一样，来实现服务；

有哪些常见的，出圈的RPC框架呢？

（1）gRPC，Google出品，支持多语言；

（2）Thrift，Facebook出品，支持多语言；

（3）Dubbo，阿里开源的，支持Java；

（4）bRPC，百度开源的，支持C++，Java；

（5）tRPC，腾讯RPC框架，支持多语言；

（6）...

画外音：还有哪些？

今天和大家分享的srpc，作者是搜狗的媛架构师liyingxin，基于WF，代码量1W左右：

（1）非常适合用来学习RPC的架构设计；

（2）又是一个工业级的产品，QPS可以到50W，应该是行业能目前性能最好的RPC框架了吧，有不少超高并发的线上应用都使用它。

画外音：不服？来战！

什么是srpc？

基于WF的轻量级，超高性能，工业级RPC框架，兼容多协议，例如百度bRPC，腾讯tRPC，Google的gRPC，以及FB的thrift协议。

srpc有些什么特点？

（1）支持多种IDL格式，包括Protobuf，Thrift等，对于这类项目，可以一键迁移；

（2）支持多种序列化方式，包括Protobuf，Thrift，json等；

（3）支持多压缩方法，对应用透明，包括gzip，zlib，lz4，snappy等；

（4）支持多协议，对应用透明，包括http，https，ssl，tcp等；

（5）高性能；

不同客户端线程压力下的性能表现非常稳定，QPS在50W左右，优于同等压测配置的bRPC与thrift。

（6）轻量级，低门槛，1W行左右代码，只需引入一个静态库；

如何快速上手，体验这个帅气的RPC框架呢？

简单来说，只需要三个步骤。

第一步：定义IDL描述文件。

syntax = "proto3";// proto2 or proto3

message EchoRequest

   string message = 1;

   string name = 2;

;

message EchoResponse

   string message = 1;

;

service Example

   rpc Echo(EchoRequest) returns (EchoResponse);

;

第二步：生成代码，并实现ServiceIMPL，server端就搞定了。

class ExampleServiceImpl : public Example::Service

public:

   void Echo(EchoRequest *request,

        EchoResponse *response,

        RPCContext *ctx) override



       response->set_message("Hi, " + request->name());



;

make一把，一气呵成。

第三步：自己定义一个请求客户端，向服务端发送echo请求。

int main()

   Example::SRPCClient client("127.0.0.1", 1412);

   EchoRequest req;

   req.set_message("Hello, srpc!");

   req.set_name("zhangsan");

   client.Echo(&req,

        [](EchoResponse *response, RPCContext *ctx));

   return 0;