将 ptypes/struct 值转换为 BSON
来源:Golang技术栈
时间:2023-04-27 08:27:24 111浏览 收藏
怎么入门Golang编程?需要学习哪些知识点?这是新手们刚接触编程时常见的问题;下面golang学习网就来给大家整理分享一些知识点,希望能够给初学者一些帮助。本篇文章就来介绍《将 ptypes/struct 值转换为 BSON》,涉及到golang,有需要的可以收藏一下
问题内容
要求
两项服务:
- 服务器 - 用于向 MongoDB 写博客文章
- 客户端 - 向第一个服务发送请求
博客文章title
的类型为string
,并且content
是动态类型 - 可以是任何 JSON 值。
原型缓冲区
syntax = "proto3"; package blog; option go_package = "blogpb"; import "google/protobuf/struct.proto"; message Blog { string id = 1; string title = 2; google.protobuf.Value content = 3; } message CreateBlogRequest { Blog blog = 1; } message CreateBlogResponse { Blog blog = 1; } service BlogService { rpc CreateBlog (CreateBlogRequest) returns (CreateBlogResponse); }
让我们从 protobuf 消息开始,它满足要求 - string
fortitle
和任何 JSON 值content
。
客户
package main import (...) func main() { cc, _ := grpc.Dial("localhost:50051", grpc.WithInsecure()) defer cc.Close() c := blogpb.NewBlogServiceClient(cc) var blog blogpb.Blog json.Unmarshal([]byte(`{"title": "First example", "content": "string"}`), &blog) c.CreateBlog(context.Background(), &blogpb.CreateBlogRequest{Blog: &blog}) json.Unmarshal([]byte(`{"title": "Second example", "content": {"foo": "bar"}}`), &blog) c.CreateBlog(context.Background(), &blogpb.CreateBlogRequest{Blog: &blog}) }
客户端向服务器发送两个请求 - 一个content
具有string
类型,另一个具有object
. 这里没有错误。
服务器
package main import (...) var collection *mongo.Collection type server struct { } type blogItem struct { ID primitive.ObjectID `bson:"_id,omitempty"` Title string `bson:"title"` Content *_struct.Value `bson:"content"` } func (*server) CreateBlog(ctx context.Context, req *blogpb.CreateBlogRequest) (*blogpb.CreateBlogResponse, error) { blog := req.GetBlog() data := blogItem{ Title: blog.GetTitle(), Content: blog.GetContent(), } // TODO: convert "data" or "data.Content" to something that could be BSON encoded.. res, err := collection.InsertOne(context.Background(), data) if err != nil { log.Fatal(err) } oid, _ := res.InsertedID.(primitive.ObjectID) return &blogpb.CreateBlogResponse{ Blog: &blogpb.Blog{ Id: oid.Hex(), Title: blog.GetTitle(), Content: blog.GetContent(), }, }, nil } func main() { client, _ := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017")) client.Connect(context.TODO()) collection = client.Database("mydb").Collection("blog") lis, _ := net.Listen("tcp", "0.0.0.0:50051") s := grpc.NewServer([]grpc.ServerOption{}...) blogpb.RegisterBlogServiceServer(s, &server{}) reflection.Register(s) go func() { s.Serve(lis) }() ch := make(chan os.Signal, 1) signal.Notify(ch, os.Interrupt)在这里我得到:
无法将 main.blogItem 类型转换为 BSON 文档:未找到 structpb.isValue_Kind 的编码器
我期待什么?要查看 MongoDB 中内容的确切值,如下所示:
{ "_id" : ObjectId("5e5f6f75d2679d058eb9ef79"), "title" : "Second example", "content": "string" } { "_id" : ObjectId("5e5f6f75d2679d058eb9ef78"), "title" : "First example", "content": { "foo": "bar" } }我想我需要
data.Content
在添加的行中进行转换TODO:
...如果有帮助的话,我可以用这个例子创建 github repo。
正确答案
因此,正如@nguyenhoai890 在评论中所建议的那样,我设法使用
jsonpb
lib 修复它 - 首先转换为MarshalToString
BSON支持的structpb
转换string(json)
,然后json.Unmarshal
转换string(json)
为interface{}
BSON 支持的转换。我还必须修复一个客户端以正确地从字符串解组到 protobuf。客户
func main() { cc, _ := grpc.Dial("localhost:50051", grpc.WithInsecure()) defer cc.Close() c := blogpb.NewBlogServiceClient(cc) var blog blogpb.Blog jsonpb.UnmarshalString(`{"title": "Second example", "content": {"foo": "bar"}}`, &blog) c.CreateBlog(context.Background(), &blogpb.CreateBlogRequest{Blog: &blog}) jsonpb.UnmarshalString(`{"title": "Second example", "content": "stirngas"}`, &blog) c.CreateBlog(context.Background(), &blogpb.CreateBlogRequest{Blog: &blog}) }服务器
type blogItem struct { ID primitive.ObjectID `bson:"_id,omitempty"` Title string `bson:"title"` Content interface{} `bson:"content"` } func (*server) CreateBlog(ctx context.Context, req *blogpb.CreateBlogRequest) (*blogpb.CreateBlogResponse, error) { blog := req.GetBlog() contentString, err := new(jsonpb.Marshaler).MarshalToString(blog.GetContent()) if err != nil { log.Fatal(err) } var contentInterface interface{} json.Unmarshal([]byte(contentString), &contentInterface) data := blogItem{ Title: blog.GetTitle(), Content: contentInterface, } res, err := collection.InsertOne(context.Background(), data) if err != nil { log.Fatal(err) } oid, _ := res.InsertedID.(primitive.ObjectID) return &blogpb.CreateBlogResponse{ Blog: &blogpb.Blog{ Id: oid.Hex(), Title: blog.GetTitle(), Content: blog.GetContent(), }, }, nil }到这里,我们也就讲完了《将 ptypes/struct 值转换为 BSON》的内容了。个人认为,基础知识的学习和巩固,是为了更好的将其运用到项目中,欢迎关注golang学习网公众号,带你了解更多关于golang的知识点!
-
439 收藏
-
262 收藏
-
193 收藏
-
188 收藏
-
500 收藏
-
139 收藏
-
204 收藏
-
325 收藏
-
477 收藏
-
486 收藏
-
439 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习
-
- 从容的可乐
- 这篇技术文章真是及时雨啊,很详细,受益颇多,收藏了,关注作者大大了!希望作者大大能多写Golang相关的文章。
- 2023-06-08 10:37:09
-
- 慈祥的狗
- 太细致了,已收藏,感谢博主的这篇博文,我会继续支持!
- 2023-06-07 17:02:09
-
- 明理的犀牛
- 这篇博文真及时,作者加油!
- 2023-05-25 14:46:09
-
- 有魅力的树叶
- 这篇技术贴真是及时雨啊,细节满满,感谢大佬分享,码起来,关注作者大大了!希望作者大大能多写Golang相关的文章。
- 2023-05-09 05:18:21
-
- 甜蜜的水壶
- 很好,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,看完之后很有帮助,总算是懂了,感谢up主分享技术贴!
- 2023-05-05 09:01:57
-
- 美好的发夹
- 好细啊,mark,感谢博主的这篇技术贴,我会继续支持!
- 2023-04-30 01:11:23
-
- 和谐的小蝴蝶
- 很好,一直没懂这个问题,但其实工作中常常有遇到...不过今天到这,看完之后很有帮助,总算是懂了,感谢博主分享文章内容!
- 2023-04-28 00:36:55