|
通信方式
rpc Login(LoginRequest) returns (LoginResponse) {}rpc Login(LoginRequest) returns (stream LoginResponse) {}3.多个请求对象,一个返回结果
rpc Login(stream LoginRequest) returns (LoginResponse) {}4.多个请求对象,服务器返回多个结果
rpc Login(stream LoginRequest) returns (stream LoginResponse) {}关键字 stream 表示多个值
Protobuf定义
- syntax="proto3";
文件的第一行指定了你使用的是proto3的语法:如果你不指定,protocol buffer 编译器就会认为你使用的是proto2的语法。这个语句必须出现在.proto文件的非空非注释的第一行。
编译完成之后,包名为user
service UserService {
rpc Login(LoginRequest) returns (LoginResponse);
}
message LoginRequest {
string username=1;
string password=2;
}数据类型
- strings 默认值是空字符串
- int32 默认是0(编译之后为go语言中的int类型)
- int64 默认是0 (编译之后为go语言中的int64)
- float 默认为0.0 (编译之后为go语言中的 float32)
- double 默认为0.0 (编译之后为go语言中的 float64)
- uint32 (编译之后为go语言中的 uint32)
- uint64 (编译之后为go语言中的 uint64)
- bytes 默认值是空bytes
- bool 默认值是false
- enum 默认值是第一个枚举值(value必须为0)
字段修饰符
- repeated:用来定义数组,一个字段可以重复出现一定次数(包括零次)
- required:值不可为空 (proto3中已删除)
- optional:可选字段 (proto3中已删除)
- singular:符合语法规则的消息包含零个或者一个这样的字段 (proto3中已删除)
- 默认值: string code=2 [default=200]; (proto3中已删除)
- 预留字段:reserved 6 to 8;
其他类型
//枚举类型,必须从0开始,序号可跨越。同一包下不能重名,所以加前缀来区别
enum Role {
Role_Admin=0;
Role_Guest=1;
Role_User=2;
Role_Other=9;
}map<key_type, value_type> map_field = N; 其中key_type可以是任意Integer或者string类型(所以,除了floating和bytes的任意标量类型都是可以的)value_type可以是任意类型。
例如,如果你希望创建一个project的映射,每个Projecct使用一个string作为key
map<string, Project> projects = 3;示例
syntax=&#34;proto3&#34;;
package user;
service UserService{
// 注册
rpc Signup(SignupRequest) returns (SignupResponse);
}
// 定义错误枚举,必须从0开始
enum LoginError {
//密码错误
Error_Password=0;
//用户名错误
Error_UserName=1;
//内部服务器错误
Error_Server=9;
}
message ID {
int32 id=1;
}
// 注册请求体
message SignupRequest {
string username=1;
string password=2;
int32 code=3;
// 数组
repeated string hobby=4;
// map
map<string,string> maps = 5;
}
//注册响应体
message SignupResponse {
ID id=1;
int32 code=2 [default=200];
string msg=3;
}数据校验
插件地址及文档:https://github.com/envoyproxy/protoc-gen-validate
流的使用
rpc GetStatus (GetReq) return (stream GetResp);service实现
func (HelloService) GetStatus(req *pb.GetReq,stream pb.HelloService_GetStatusServer) err {
for i:=0;i<10;i++{
stream.Send(&pb.GetResp{
Status: i,
})
if err:=stream.Context().Err();err!=nil {
fmt.Println(&#34;客户端关闭流...&#34;)
return err
}
}
return nil
}
使用grpc-web访问流: 文档:https://github.com/grpc/grpc-web
var helloService= new proto.mypackage.HelloServiceClient(&#39;http://localhost:8080&#39;);
var getReq= new proto.mypackage.GetReq();
getReq.setMessage(msg);
var metadata = {&#39;custom-header-1&#39;: &#39;value1&#39;};
var stream = helloService.getStatus(getReq, metadata);
stream.on(&#39;data&#39;, function(response) {
console.log(response.getStatus());
});
stream.on(&#39;status&#39;, function(status) {
console.log(status.code);
console.log(status.details);
console.log(status.metadata);
});
stream.on(&#39;end&#39;, function(end) {
// stream end signal
});
欢迎关注我微信公众号,一起学习编程 |
本帖子中包含更多资源
您需要 登录 才可以下载或查看,没有账号?立即注册
×
|