Part 2. 创建一个 gRPC Server
Volo-gRPC 是一个 RPC 框架,既然是 RPC,底层就需要两大功能:
- Serialization 序列化
- Transport 传输
IDL 全称是 Interface Definition Language
,接口定义语言。
Why IDL
如果我们要进行 RPC,就需要知道对方的接口是什么,需要传什么参数,同时也需要知道返回值是什么样的,就好比两个人之间交流,需要保证在说的是同一个语言、同一件事。 这时候,就需要通过 IDL 来约定双方的协议,就像在写代码的时候需要调用某个函数,我们需要知道函数签名一样。
Protobuf IDL 是一套跨语言的全栈式 RPC 解决方案,具体的语法可以看参考 protocol-buffers/docs/proto3。
编写 IDL
为了创建一个 gRPC 项目,我们需要先编写一个 protobuf IDL。
在你的工作目录下,我们先执行以下命令:
$ mkdir volo-example
$ cd volo-example
$ mkdir idl
$ vim idl/volo_example.proto
随后,我们输入以下内容:
syntax = "proto3";
package volo.example;
message Item {
int64 id = 1;
string title = 2;
string content = 3;
map<string, string> extra = 10;
}
message GetItemRequest {
int64 id = 1;
}
message GetItemResponse {
Item item = 1;
}
service ItemService {
rpc GetItem(GetItemRequest) returns (GetItemResponse);
}
保存退出后,我们执行以下命令:
$ volo init --includes=idl volo-example idl/volo_example.proto
这里我们使用init
命令,后面跟了我们项目的名字,意思是需要生成模板代码。在末尾,需要指定一个 IDL 表示 server 使用的 IDL。
如果只需要增加一个 IDL(如 client 的 IDL)而不需要生成模板的话,如:
$ volo idl add idl/volo_example.proto
| 插播一个广告,volo 工具还支持从 git 下载 IDL 并生成代码哦,如:
$ volo idl add -g git@github.com:org/repo.git -r main /path/to/your/idl.proto
| 感兴趣可以直接输入 volo 看详细用法~ 接下来回到正题~
这时候,我们整个目录的结构如下:
.
├── Cargo.toml
├── idl
│ └── volo_example.proto
├── rust-toolchain.toml
├── src
│ ├── bin
│ │ └── server.rs
│ └── lib.rs
└── volo-gen
├── Cargo.toml
├── build.rs
├── src
│ └── lib.rs
└── volo.yml
然后,我们打开 src/lib.rs
,在 impl 块中加入方法的实现,最终的代码应该是这样的:
#![feature(impl_trait_in_assoc_type)]
pub struct S;
#[volo::async_trait]
impl volo_gen::volo::example::ItemService for S {
// 这部分是我们需要增加的代码
async fn get_item(
&self,
_req: volo_grpc::Request<volo_gen::volo::example::GetItemRequest>,
) -> core::result::Result<volo_grpc::Response<volo_gen::volo::example::GetItemResponse>, volo_grpc::Status>
{
Ok(volo_grpc::Response::new(Default::default()))
}
}
然后执行:
$ cargo update
$ cargo build
这时候,就会发现 OUT_DIR 目录下多出来一个 volo_gen.rs 的文件了。
然后执行以下命令,即可把我们的 server 端跑起来:
$ cargo run --bin server
至此,我们已经能把我们的 server 跑起来啦!
最后修改
July 3, 2023
: Update _index.md (f1d978d)