我正在試驗(yàn) Protobuf 和 gRPC，并且正在學(xué)習(xí) Go 基礎(chǔ)教程：https ://www.grpc.io/docs/languages/go/basics/從我在有關(guān) ClientConn 的文檔中看到的內(nèi)容來(lái)看，同時(shí)使用相同的ClientConn似乎是安全的。但是我對(duì)創(chuàng)建的存根/客戶端一無(wú)所知......假設(shè)我通過(guò) HTTP POST 請(qǐng)求接收數(shù)據(jù)，我想通過(guò) gRPC 作為 protobuf 轉(zhuǎn)發(fā)該數(shù)據(jù)，然后響應(yīng) HTTP 請(qǐng)求。我應(yīng)該在每次處理 HTTP 請(qǐng)求時(shí)都創(chuàng)建一個(gè)客戶端/存根，還是可以在設(shè)置 HTTP 服務(wù)器時(shí)創(chuàng)建客戶端/存根并在設(shè)置 HTTP 處理程序時(shí)傳入客戶端/存根？示例：我認(rèn)為這沒(méi)問(wèn)題var opts []grpc.DialOptionconn, err := grpc.Dial("127.0.0.1:1234", opts...)if err != nil { log.Panic(err)}defer conn.Close()grpcService := service.Service{GRPC: conn}http.HandleFunc("/", util.ValidateRequest(grpcService.HandleRoot))// listen to porthttp.ListenAndServe(fmt.Sprintf("%s:%d", viper.GetString("server.address"), viper.GetInt32("server.port")), nil)但是這個(gè)呢var opts []grpc.DialOptionconn, err := grpc.Dial("127.0.0.1:1234", opts...)if err != nil { log.Panic(err)}defer conn.Close()client := pb.NewEventShipperClient(conn)grpcService := service.Service{GRPC: conn, Client: client}http.HandleFunc("/", util.ValidateRequest(grpcService.HandleRoot))// listen to porthttp.ListenAndServe(fmt.Sprintf("%s:%d", viper.GetString("server.address"), viper.GetInt32("server.port")), nil)
1 回答
慕尼黑的夜晚無(wú)繁華
TA貢獻(xiàn)1864條經(jīng)驗(yàn) 獲得超6個(gè)贊
生成代碼參考中涵蓋了線程安全（“同時(shí)運(yùn)行它是否安全”）：
線程安全：請(qǐng)注意，客戶端 RPC 調(diào)用和服務(wù)器端 RPC 處理程序是線程安全的，旨在并發(fā) goroutines 上運(yùn)行。但還要注意，對(duì)于單個(gè)流，傳入和傳出數(shù)據(jù)是雙向的但串行的；因此，例如，單個(gè)流不支持并發(fā)讀取或并發(fā)寫(xiě)入（但讀取與寫(xiě)入是安全并發(fā)的）。
所以，是的，可以同時(shí)調(diào)用struct返回的方法。pb.NewEventShipperClient(conn)
您也可以通過(guò)查看pb.NewEventShipperClient. 目前（我想這可能會(huì)改變）唯一的成員變量將是一個(gè)接口（cc grpc.ClientConnInterface- 實(shí)現(xiàn)*ClientConn），每個(gè)方法都使用到InvokegRPC 調(diào)用的連接。
但是請(qǐng)注意，您在實(shí)施時(shí)需要小心，service.Service以確保它也是線程安全的，并注意有關(guān)流的警告。
- 1 回答
- 0 關(guān)注
- 107 瀏覽
添加回答
舉報(bào)
0/150
提交
取消