我是 GRPC 的新手，想確保我正在使用 golang 正確地進(jìn)行連接管理。我不想為每個(gè)呼叫都創(chuàng)建一個(gè)新連接，但我也不想在擴(kuò)展時(shí)造成瓶頸。我所做的是在 init 函數(shù)中創(chuàng)建一個(gè)連接：var userConn *grpc.ClientConnvar userServiceName stringfunc init() { userServiceName := os.Getenv("USER_SERVICE_URL") if userServiceName == "" { userServiceName = "localhost" } logging.LogDebug("userClient: Connecting to: "+userServiceName, "") tempConn, err := grpc.Dial(userServiceName, grpc.WithInsecure()) if err != nil { logging.LogEmergency("account_user_client.Init() Could not get the connection. "+err.Error(), "") return } userConn = tempConn}然后對(duì)于每個(gè)函數(shù)，我將使用該連接創(chuàng)建一個(gè)客戶端：c := user.NewUserClient(userConn)// Contact the server and print out its response.ctx, cancel := context.WithTimeout(context.Background(), time.Second)defer cancel()r, err := c.GetUserFromTokenID(ctx, &user.GetUserFromTokenRequest{TransactionID: transactionID, OathToken: *oathToken})//Handle Error and Response這是處理 grpc 連接的可接受方式嗎？關(guān)于更好的方法有什么建議嗎？
2 回答
繁花不似錦
TA貢獻(xiàn)1851條經(jīng)驗(yàn) 獲得超4個(gè)贊
是的，每個(gè)服務(wù)有一個(gè) GRPC 客戶端連接很好。此外，我在這里看不到任何其他選項(xiàng)。GRPC 在幕后完成所有繁重的工作：例如，您不需要編寫自己的客戶端連接池（就像您為典型的 RDBMS 所做的那樣），因?yàn)樗粫?huì)提供比單個(gè) GRPC 連接更好的結(jié)果。
但是我建議您避免使用全局變量和初始化函數(shù)，尤其是對(duì)于網(wǎng)絡(luò)設(shè)置。此外，您不需要c := user.NewUserClient(userConn)在每次向 GRPC 服務(wù)發(fā)送請(qǐng)求時(shí)都創(chuàng)建 GRPC 客戶端 ( )：這只是垃圾收集器的額外工作，您可以在應(yīng)用程序啟動(dòng)時(shí)創(chuàng)建客戶端的唯一實(shí)例。
更新
假設(shè)您正在編寫服務(wù)器應(yīng)用程序（因?yàn)樗梢詮哪{(diào)用遠(yuǎn)程 GRPC 服務(wù)的方法中看出），您可以簡單地定義一個(gè)類型，該類型將包含與整個(gè)應(yīng)用程序本身具有相同生命周期的所有對(duì)象。按照傳統(tǒng)，這些類型通常被稱為“服務(wù)器上下文”，盡管這有點(diǎn)令人困惑，因?yàn)?Gocontext在其標(biāo)準(zhǔn)庫中有一個(gè)非常重要的概念。
// this type contains state of the server
type serverContext struct {
// client to GRPC service
userClient user.UserClient
// default timeout
timeout time.Duration
// some other useful objects, like config
// or logger (to replace global logging)
// (...)
}
// constructor for server context
func newServerContext(endpoint string) (*serverContext, error) {
userConn, err := grpc.Dial(endpoint, grpc.WithInsecure())
if err != nil {
return nil, err
}
ctx := &serverContext{
userClient: user.NewUserClient(userConn),
timeout: time.Second,
}
return ctx, nil
}
type server struct {
context *serverContext
}
func (s *server) Handler(ctx context.Context, request *Request) (*Response, error) {
clientCtx, cancel := context.WithTimeout(ctx, time.Second)
defer cancel()
response, err := c.GetUserFromTokenID(
clientCtx,
&user.GetUserFromTokenRequest{
TransactionID: transactionID,
OathToken: *oathToken,
},
)
if err != nil {
return nil, err
}
// ...
}
func main() {
serverCtx, err := newServerContext(os.Getenv("USER_SERVICE_URL"))
if err != nil {
log.Fatal(err)
}
s := &server{serverCtx}
// listen and serve etc...
}
細(xì)節(jié)可能會(huì)根據(jù)您的實(shí)際工作而改變，但我只是想表明，將應(yīng)用程序的狀態(tài)封裝在不同類型的實(shí)例中比感染全局命名空間要好得多。
叮當(dāng)貓咪
TA貢獻(xiàn)1776條經(jīng)驗(yàn) 獲得超12個(gè)贊
一些事情使這個(gè)實(shí)現(xiàn)工作。
gRPC 通道（即
cfrom?c := user.NewUserClient(userConn)）由 http/2 連接支持。當(dāng)連接關(guān)閉或失效時(shí)，它會(huì)自動(dòng)重新連接或重試連接。http/2 支持在單個(gè)連接中同時(shí)發(fā)送消息?？紤]到這種場景，service Order 對(duì)service Product 一次獲取一個(gè)產(chǎn)品庫存，更新產(chǎn)品庫存，更改產(chǎn)品優(yōu)惠券。三個(gè) grpc 請(qǐng)求可以重用單個(gè) http/2 連接，grpc 將并發(fā)處理數(shù)據(jù)交換。所以只使用一個(gè)連接是可以的，而不是創(chuàng)建三個(gè)連接（比如 http/1）來實(shí)現(xiàn)這一點(diǎn)。
為避免過早優(yōu)化，一個(gè)連接應(yīng)該可以為一項(xiàng)服務(wù)啟動(dòng)。為了將來的池性能，考慮為熱點(diǎn) grpc 請(qǐng)求創(chuàng)建一個(gè)單獨(dú)的 tcp 連接（然后單獨(dú)的 http/2 連接）。
保持連接活動(dòng)可能是件好事，以防某些代理可能會(huì)終止空閑連接。
- 2 回答
- 0 關(guān)注
- 269 瀏覽
添加回答
舉報(bào)
0/150
提交
取消