我正在試驗 Protobuf 和 gRPC，并且正在學習 Go 基礎教程：https ://www.grpc.io/docs/languages/go/basics/從我在有關 ClientConn 的文檔中看到的內容來看，同時使用相同的ClientConn似乎是安全的。但是我對創建的存根/客戶端一無所知......假設我通過 HTTP POST 請求接收數據，我想通過 gRPC 作為 protobuf 轉發該數據，然后響應 HTTP 請求。我應該在每次處理 HTTP 請求時都創建一個客戶端/存根，還是可以在設置 HTTP 服務器時創建客戶端/存根并在設置 HTTP 處理程序時傳入客戶端/存根？示例：我認為這沒問題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)但是這個呢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 回答
慕尼黑的夜晚無繁華
TA貢獻1864條經驗 獲得超6個贊
生成代碼參考中涵蓋了線程安全（“同時運行它是否安全”）：
線程安全：請注意，客戶端 RPC 調用和服務器端 RPC 處理程序是線程安全的，旨在并發 goroutines 上運行。但還要注意，對于單個流，傳入和傳出數據是雙向的但串行的；因此，例如，單個流不支持并發讀取或并發寫入（但讀取與寫入是安全并發的）。
所以，是的，可以同時調用struct返回的方法。pb.NewEventShipperClient(conn)
您也可以通過查看pb.NewEventShipperClient. 目前（我想這可能會改變）唯一的成員變量將是一個接口（cc grpc.ClientConnInterface- 實現*ClientConn），每個方法都使用到InvokegRPC 調用的連接。
但是請注意，您在實施時需要小心，service.Service以確保它也是線程安全的，并注意有關流的警告。
- 1 回答
- 0 關注
- 109 瀏覽
添加回答
舉報
0/150
提交
取消