鍘熸枃鍦板潃锛氬紩鍏RPC锛歡RPCDeadlines椤圭洰鍦板潃锛歨ttps://github.com/EDDYCJY/go...鍓嶈█鍦ㄥ墠闈㈢殑绔犺妭涓紝宸茬粡浠嬬粛浜唃RPC鐨勫熀鏈敤娉曘€傞偅浣犳兂鎯筹紝灏辫繖鏍疯瀹冭８濂旂湡鐨勬病闂鍚楋紵閭ｄ箞锛屼竴瀹氭湁闂銆備粖澶╁氨鏉ヤ粙缁嶄竴涓嬪繀澶囨妧鑳絞RPCDeadlines鐨勭敤娉曘€傚唴瀹逛篃姣旇緝绠€鍗曘€侱eadlinesDeadlines琛ㄧず鎴鏃ユ湡銆傚湪gRPC涓紝寮鸿皟浜員L;DR锛堝お闀匡紝璇峰嬁闃呰锛夛紝寤鸿濮嬬粓璁剧疆鎴鏃ユ湡銆備负浠€涔堬紵涓轰粈涔堣璁剧疆锛熷綋娌℃湁璁剧疆Deadlines鏃讹紝浼氫娇鐢ㄩ粯璁ょ殑DEADLINE_EXCEEDED锛堣繖涓椂闂撮潪甯稿ぇ锛夈€傚鏋滃彂鐢熼樆濉炵瓑寰咃紝澶ч噺姝ｅ湪杩涜鐨勮姹傚皢琚繚鐣欙紝鎵€鏈夎姹傞兘鍙兘杈惧埌鏈€澶ц秴鏃舵椂闂淬€傝繖灏嗕娇鏈嶅姟杩愯鏈夎€楀敖璧勬簮鐨勯闄╋紝渚嬪鍐呭瓨锛岃繖浼氬鍔犳湇鍔＄殑寤惰繜锛屾垨鑰呭湪鏈€鍧忕殑鎯呭喌涓嬪彲鑳戒細瀵艰嚧鏁翠釜杩涚▼宕╂簝gRPCClientfuncmain(){...ctx,cancel:=context.WithDeadline(context.Background(),time.Now().Add(time.Duration(5*time.Second)))defercancel()client:=pb.NewSearchServiceClient(conn)resp,err:=client.Search(ctx,&pb.SearchRequest{Request:"gRPC",})iferr!=nil{statusErr,ok:=status.FromError(err)ifok{ifstatusErr.Code()==codes.DeadlineExceeded{log.Fatalln("client.Searcherr:deadline")}}log.Fatalf("client.Searcherr:%v",err)}log.Printf("resp:%s",resp.GetResponse())}context.WithDeadline:灏嗚繑鍥炴渶缁堢殑涓婁笅鏂囨埅姝㈡椂闂淬€傜涓€涓弬鏁版槸鐖朵笂涓嬫枃锛岀浜屼釜鍙傛暟鏄皟鏁村悗鐨勬埅姝㈡棩鏈熴€傚鏋滅埗鏃堕棿鏃╀簬瀛愭椂闂达紝鍒欎互鐖舵椂闂翠负鍑嗭紝鍚﹀垯浠ュ瓙鏃堕棿涓烘渶缁堟埅姝㈡椂闂磃uncWithDeadline(parentContext,dtime.Time)(Context,CancelFunc){ifcur,ok:=parent銆傛渶鍚庢湡闄愶紙锛?ok&&cur.Before(d){//褰撳墠鎴鏃ユ湡宸茬粡姣旀柊鎴鏃ユ湡鏃╀簡銆俽eturnWithCancel(parent)}c:=&timerCtx{cancelCtx:newCancelCtx(parent),deadline:d,}propagateCancel(parent,c)dur:=time.Until(d)濡傛灉dur<=0{c.cancel(true,DeadlineExceeded)//鎴鏃ユ湡宸茬粡杩囧幓returnc,func(){c.cancel(true,Canceled)}}c.mu.Lock()deferc.mu.Unlock()ifc.err==nil{c.timer=time.AfterFunc(dur,func(){c.cancel(true,DeadlineExceeded)})}returnc,func(){c.cancel(true,Canceled)}}context.WithTimeout锛氬彟涓€涓潪甯稿父瑙佺殑鏂规硶鏄搷浣滄柟渚裤€傚叾瀹炲氨鏄WithDeadline鐨勫皝瑁協uncWithTimeout(parentContext,timeouttime.Duration)(Context,CancelFunc){returnWithDeadline(parent,time.Now().Add(timeout))}status.FromError:杩斿洖鍏蜂綋鐨凣RPCStatus浠ｇ爜閿欒锛屽鏋滀笉鍚堟硶鍒欑洿鎺ヨ繑鍥炰唬鐮併€俇nknownServertypeSearchServicestruct{}func(s*SearchService)Search(ctxcontext.Context,r*pb.SearchRequest)(*pb.SearchResponse,error){for鎴戯細=0锛涙垜<5;i++{濡傛灉ctx.Err()==context.Canceled{returnnil,status.Errorf(codes.Canceled,"SearchService.Searchcanceled")}time.Sleep(1*time.Second)}return&pb.SearchResponse{Response:r.GetRequest()+"Server"},nil}funcmain(){...}鍦ㄦ湇鍔″櫒绔紝鎴鏃ユ湡宸茬敱瀹㈡埛绔缃€傛湇鍔＄涓€瀹氳妫€娴嬪埌锛屽惁鍒欏鏋滃鎴风宸茬粡缁撴潫浜嗭紝鏈嶅姟绔繕浼氬偦鍌荤殑鎵ц鍦ㄩ偅閲岋紝瀵硅祫婧愮殑鏋佸ぇ娴垂锛屾墍浠ヨ繖閲岄渶瑕佷娇鐢╟tx.Err()==context.Canceled鏉ュ垽鏂紝涓轰簡涓轰簡妯℃嫙鍦烘櫙锛屾垜浠坊鍔犱簡涓€涓惊鐜拰鐫＄湢馃楠岃瘉骞堕噸鍚痵erver.go鍜宑lient.go锛屽緱鍒扮粨鏋滐細$gorunclient.go2018/10/0617:45:55client.Searcherr:deadlineexitstatus1鎬荤粨鏈珷姣旇緝绠€鍗曪紝浣犻渶瑕佷簡瑙ｄ互涓嬬煡璇嗙偣锛氬浣曡缃瓺eadlines涓轰粈涔堣璁剧疆Deadlines浣犲繀椤绘竻妤氬湴璁よ瘑鍒癵RPCDeadlines闈炲父閲嶈锛屽惁鍒欒繖涓皬鍔熻兘鐐逛細鎵兼潃浣犵殑鐢熶骇馃か鍙傝€冧功绀轰緥浠ｇ爜绯诲垪go-grpc-example绯诲垪鐩綍杩涘叆gRPC锛歡RPC鍙婄浉鍏充粙缁嶈繘鍏RPC锛歡RPCClientandServer杩涘叆gRPC锛歡RPCStreaming锛孋lientandServer杩涘叆gRPC锛歍LScertificateauthenticationintogRPC:CA-basedBringTLS璇佷功韬唤楠岃瘉鍒癵RPC锛歎nary鍜孲tream鎷︽埅鍣ㄥ紩鍏RPC锛氳浣犵殑鏈嶅姟鍚屾椂鎻愪緵HTTP鎺ュ彛寮曞叆gRPC锛氬RPC鏂规硶鍋氳嚜瀹氫箟璁よ瘉寮曞叆gRPC锛歡RPCDeadlines淇℃伅gRPC鍜孌eadlines
