标签：妙用 Protobuf Title rpc go rsp any protobuf
文章目录
在使用 GRPC 时，常规的操作是将 message 定义好后进行数据传输，但总会遇到某些数据结构进行组合的操作，采用默认的定义 message 方式，造成代码量的激增。为了解决这个问题 protobuf 提供类型 any 解决 GRPC 中泛型的处理方式
目录结构
.
├── main.go
└── rpc
├── rsp.pb.go
└── rsp.proto
- 1
- 2
- 3
- 4
- 5
首先，我们定义我们需要传输的消息
path
project_dir/rpc/rsp.proto
采用 proto3 协议
定义 TestAny 用于测试 any 的动态传输
定义 Response 作为 GRPC 通用的消息交互
rsp.proto 内容
syntax = "proto3";
package rpc;
option go_package = ".;rpc";
import "google/protobuf/any.proto";
message TestAny {
uint64 Id = 1;
string Title = 2;
string Content = 3;
}
message Response {
uint32 Code = 1;
string Msg = 2;
google.protobuf.Any data = 3;
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
使用 protoc 编译工具，编译 rsp.proto，生成 rsp.pb.go 文件
path
project_dir/rpc/rsp.pb.go
我们并不需要关注 rsp.pb.go 内部的所有内容
仅需要关注生成的消息体
> protoc --go_out=./ rsp.proto
- 1
rsp.pb.go 内容
通过 protoc 工具，生成了两个 struct，及为我们定义在 proto 文件中的 message
type TestAny struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Id uint64 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
Title string `protobuf:"bytes,2,opt,name=Title,proto3" json:"Title,omitempty"`
Content string `protobuf:"bytes,3,opt,name=Content,proto3" json:"Content,omitempty"`
}
type Response struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Code uint32 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
Data *any.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
测试使用 any
下面我们将演示实际场景中的应用
通过ptypes.MarshalAny(marshal)将我们定义的消息进行编码
通过ptypes.UnmarshalAny(any, unmarshal)对已经编码的消息进行反编码
main.go 内容
func main() {
marshal := &rpc.TestAny{
Id: 1,
Title: "标题",
Content: "内容",
}
any, err := ptypes.MarshalAny(marshal)
fmt.Println(any, err) // [type.googleapis.com/rpc.TestAny]:{Id:1 Title:"标题" Content:"内容"} <nil>
msg := &rpc.Response{
Code: 0,
Msg: "success",
Data: any,
}
fmt.Println(msg) // Msg:"success" data:{[type.googleapis.com/rpc.TestAny]:{Id:1 Title:"标题" Content:"内容"}}
unmarshal := &rpc.TestAny{}
err = ptypes.UnmarshalAny(msg.Data, unmarshal)
fmt.Println(unmarshal, err) // Id:1 Title:"标题" Content:"内容" <nil>
}标签：妙用,Protobuf,Title,rpc,go,rsp,any,protobuf 来源： https://www.cnblogs.com/ExMan/p/13892736.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。