鍘熸枃鍦板潃锛氬紩鍏RPC锛歡RPC鍙婄浉鍏充粙缁嶉」鐩湴鍧€锛歡o-grpc-example浣滀负寮€绡囷紝灏嗕粙缁嶄竴浜沢RPC鐩稿叧鐨勭煡璇嗐€傜畝鍗曟潵璇达紝gRPC鏄竴涓熀浜嶩TTP/2鍗忚璁捐鐨凴PC妗嗘灦銆傚畠浣跨敤Protobuf浣滀负IDL銆備綘鏈夋病鏈夋兂杩囧畠浠槸浠€涔堬紵鏈枃灏嗕粙缁嶄竴浜涘父鐢ㄧ殑鐭ヨ瘑鍜屾蹇碉紝骞剁粰鍑烘洿璇︾粏鐨勬墜鍐屽湴鍧€锛屼互渚挎洿娣卞叆銆備竴銆丷PC浠€涔堟槸RPCRPC锛烴o.)鍗忚绛夈€傚厑璁歌繍琛屽湪涓€鍙拌绠楁満涓婄殑绋嬪簭璋冪敤鍙︿竴鍙拌绠楁満涓婄殑瀛愮▼搴忥紝寮€鍙戣€呬笉闇€瑕侀澶栫紪鍐欒繖绉嶄氦浜掔殑瀹為檯鍦烘櫙锛氭湁涓ゅ彴鏈嶅姟鍣紝A鍜孊銆侫涓婄殑搴旂敤绋嬪簭C鎯宠皟鐢ㄦ湇鍔″櫒B涓婄殑搴旂敤绋嬪簭D锛屼粬浠彲浠ョ洿鎺ュ湪鏈湴璋冪敤鍚楋紵绛旀鏄惁瀹氱殑锛屼絾鏄娇鐢≧PC杩樻槸寰堟柟渚跨殑銆傚洜姝わ紝浜轰滑甯歌浣跨敤RPC灏卞儚鍦ㄦ湰鍦拌皟鐢ㄤ竴涓嚱鏁颁竴鏍风畝鍗曘€傚湪鎴戠湅鏉ワ紝涓€涓畬鏁寸殑RPC妗嗘灦搴旇鍖呮嫭璐熻浇鍧囪 銆佹湇鍔℃敞鍐屼笌鍙戠幇銆佹湇鍔℃不鐞嗙瓑鍔熻兘锛屽苟涓斿叿鏈夊彲鎵╁睍鎬т互鏂逛究娴侀噺鐩戞帶绯荤粺銆傚綋鐒讹紝鍦ㄦ彃鍏ヤ箣鍓嶅畠涓嶄細瀹屾垚銆備竴浜涚浉瀵圭畝鍗曠殑RPC妗嗘灦涔熷彲浠ラ€氳繃缁勫悎澶氫釜缁勪欢鏉ユ弧瓒宠繖涓爣鍑嗐€備綘鎬庝箞璁や负锛熷父鐢≧PC妗嗘灦瀵规瘮gRPCThriftRpcxDubbo\璺ㄨ瑷€澶欼DL鏈嶅姟娌荤悊娉ㄥ唽涓績鏈嶅姟绠＄悊gRPC鈭毭椕椕椕桾hrift鈭毭椕椕椕桼pcx脳鈭氣垰鈭氣垰Dubbo脳鈭氣垰鈭氣垰涓轰粈涔圧PC绠€鍗曘€侀€氱敤銆乻afe,EfficiencyRPC鍙互鍩轰簬HTTP鍚楋紵RPC鏄寚杩滅▼杩囩▼璋冪敤锛屽畠鍙互鍩轰簬HTTP鍗忚銆傛湁浜鸿偗瀹氫細璇存湁鏁堢巼浼樺娍銆傛垜鍙互鍛婅瘔浣狅紝瀹冩槸鍩轰簬HTTP/1.1鐨勩€侶TTP/2浼樺寲浜嗗緢澶氶棶棰橈紙褰撶劧涔熸湁鏂扮殑闂锛夛紝鎵€浠ヤ綘宸茬粡鐪嬪埌浜嗘湰鏂囩殑涓婚gRPC2.Protobuf绠€浠婸rotocolBuffers鏄竴绉嶇嫭绔嬩簬璇█鍜屽钩鍙般€佸彲鎵╁睍鐨勫簭鍒楀寲缁撴瀯鍖栨暟鎹殑鏂规硶锛岄€氬父鐢ㄤ簬閫氫俊鍗忚銆佹暟鎹瓨鍌ㄧ瓑銆備笌JSON鍜孹ML鐩告瘮锛屽畠鏇村皬銆佹洿蹇€佹洿绠€鍗曪紝鍥犳鏇村彈寮€鍙戣€呴潚鐫怱yntax="proto3";serviceSearchService{rpcSearch(SearchRequest)returns(SearchResponse);}messageSearchRequest{stringquery=1;int32page_number=2;int32result_per_page=3;}messageSearchResponse{...}1.绗竴琛岋紙闈炵┖锛岄潪娉ㄩ噴琛岋級澹版槑浣跨敤proto3璇硶銆傚鏋滄湭澹版槑锛屽皢榛樿浣跨敤proto2璇硶銆傚悓鏃舵垜寤鸿浣犱娇鐢╲2鎴栬€卾3锛屽苟涓斾綘搴旇澹版槑浣犱娇鐢ㄧ殑鐗堟湰銆?.瀹氫箟SearchServiceRPC鏈嶅姟锛屽叾涓寘鍚玆PC鏂规硶Search銆傝緭鍏ュ弬鏁版槸SearchRequest娑堟伅锛岃緭鍑哄弬鏁版槸SearchResponse娑堟伅銆?.瀹氫箟SearchRequest鍜孲earchResponse娑堟伅銆傚墠鑰呭畾涔変簡涓変釜瀛楁锛屾瘡涓瓧娈靛寘鍚笁涓睘鎬э細绫诲瀷銆佸瓧娈靛悕銆佸瓧娈电紪鍙?銆侾rotobuf缂栬瘧鍣ㄤ細鏍规嵁閫夋嫨鐨勮瑷€鐢熸垚鐩稿簲璇█鐨凷erviceInterfaceCode鍜孲tubs銆侳inally,hereisjustasimplegrammarintroduction,detailed鐨勮鍙虫嫄LanguageGuide(proto3)鏁版嵁绫诲瀷.protoTypeC++TypeJavaTypeGoTypePHPTypedoubledoubledoublefloat64floatfloatfloatfloatfloat32floatint32int32intint32integerint64int64longint64integer/stringuint32uint32intuint32integeruint64uint64longuint64integer/stringsint32int32intint32integersint64int64longint64integer/stringfixed32uint32intuint32integerfixed64uint64longuint64integer/stringsfixed32int32intint32integersfixed64int64longint64integer/stringboolboolbooleanboolbooleanstringstringStringstringstringbytesstringByteString[]bytestringv2鍜寁3涓昏鍖哄埆鍒犻櫎鍘熷鍊煎瓧娈靛瓨鍦ㄤ簬鎬荤紪杈戜腑鐨勫瓧娈靛垹闄equired瀛楁鍒犻櫎optional瀛楁锛岄粯璁ゆ槸鍒犻櫎default瀛楁鍜屽垹闄ゆ墿灞曠壒寰侊紝娣诲姞Any绫诲瀷鏇挎崲銆傚鍔犲垹闄ゆ湭鐭ュ瓧娈电殑鏀寔銆傛坊鍔犱簡鏂扮殑JSONMapping浠ユ敮鎸丮ap绫诲瀷銆傛灇涓剧殑鏈煡绫诲瀷琚慨澶峳epeatated榛樿浣跨敤鎵撳寘缂栫爜骞跺紩鍏ユ柊鐨勮瑷€瀹炵幇锛圕#銆丣avaScript銆丷uby銆丱bjective-C锛夈€備互涓婃槸鏃ュ父鐢熸椿涓父瑙佺殑鍔熻兘銆傚鏋滀綘鎯充簡瑙ｆ洿澶氾紝鍙互闃呰ProtobufVersion3.0.0ComparedwithProtobuf,whynotuseitXML?鏇寸畝鍗曠殑鏁版嵁鎻忚堪鏂囦欢鍙渶瑕佸師鏉ョ殑1/10鍒?/3瑙ｆ瀽閫熷害鏄師鏉ョ殑20鍒?00鍊嶏紝鍑忓皯姝т箟锛屽垱寤烘洿鏄撶敤鐨勬暟鎹闂被3.gRPC绠€浠媑RPC鏄竴绉嶉珮鎬ц兘锛屽紑婧愬拰閫氱敤鐨凴PC妗嗘灦锛屼笓涓虹Щ鍔ㄥ拰HTTP/2澶氳瑷€璁捐C++C#DartGoJavaNode.jsObjective-CPHPPythonRuby鐗圭偣1.HTTP/22,Protobuf3,clientandserverbasedonthesameIDL4.鑹ソ鐨勬敮鎸乫ormobilenetworks5.鏀寔澶氳瑷€姒傝璁茶В1.瀹㈡埛绔紙gRPCSub锛夎皟鐢ˋ鏂规硶锛屽彂璧稲PC璋冪敤2.浣跨敤Protobuf瀵硅姹備俊鎭繘琛屽璞″簭鍒楀寲鍜屽帇缂╋紙IDL锛?.鏈嶅姟绔悗(gRPCServer)鏀跺埌璇锋眰锛岃В鐮佽姹備綋锛岃繘琛屼笟鍔￠€昏緫澶勭悊骞惰繑鍥?.浣跨敤Protobuf瀵瑰搷搴旂粨鏋滆繘琛屽璞″簭鍒楀寲鍘嬬缉(IDL)5.瀹㈡埛绔帴鏀舵湇鍔″櫒鍝嶅簲锛岃В鐮佽姹備綋鍥炶皟琚皟鐢ㄧ殑A鏂规硶锛屽敜閱掔瓑寰呭搷搴旓紙闃诲锛夌殑瀹㈡埛绔皟鐢ㄥ苟杩斿洖鍝嶅簲缁撴灉绀轰緥鏈妭绠€鍗曞睍绀篻RPC瀹㈡埛绔拰鏈嶅姟绔殑绀轰緥浠ｇ爜銆傚笇鏈涘ぇ瀹舵湁涓€涓熀鏈殑鍗拌薄锛屼笅涓€绔犱細璇︾粏浠嬬粛馃鎼缓鍜屽惎鍔ㄦ湇鍔″櫒lis,err:=net.Listen("tcp",fmt.Sprintf(":%d",*port))iferr!=nil{log.Fatalf("failedtolisten:%v",err)}grpcServer:=grpc.NewServer()...pb.RegisterSearchServer(grpcServer,&SearchServer{})grpcServer.Serve(lis)1.鐩戝惉鎸囧畾鐨凾CP绔彛锛岀敤浜庢帴鍙楀鎴风璇锋眰2銆佸垱寤篻RPCServer瀹炰緥瀵硅薄3銆佹敞鍐実RPCServer鍐呴儴鏈嶅姟鍜岃矾鐢?銆丼erve()璋冪敤鏈嶅姟鍣ㄦ墽琛岄樆濉炵瓑寰咃紝鐩村埌杩涚▼缁堟鎴栬璋冪敤閫氳繃Stop()鍒涘缓涓€涓鎴风varopts[]grpc.DialOption...conn,err:=grpc.Dial(*serverAddr,opts...)iferr!=nil{log.Fatalf("鎷ㄥ彿澶辫触:%v",err)}deferconn.Close()client:=pb.NewSearchClient(conn)...1.鍒涘缓gRPCChannel涓巊RPCServer閫氫俊锛堥渶瑕佹湇鍔″櫒鍦板潃鍜岀鍙ｄ綔涓哄弬鏁帮級2.璁剧疆DialOptions鍑瘉锛堜緥濡俆LS銆丟CE鍑瘉銆丣WT鍑瘉锛?.鍒涘缓SearchClientStub4.璋冪敤鐩稿簲鐨勬湇鍔℃柟娉昑hinking闂1銆佷粈涔堝満鏅笅涓嶉€傚悎浣跨敤Protobuf锛岃€岄€傚悎浣跨敤JSON鍜孹ML锛?銆丳rotobuf閮ㄥ垎鎻愬埌鐨刾ackedencoding鏄粈涔堬紵灏忕粨鍦ㄥ紑鍦哄唴瀹逛腑锛屾垜鐢ㄥ敖鍙兘绠€鐭殑鎻忚堪锛屽悜澶у浠嬬粛浜嗗繀瑕佸拰蹇呰鐨勭煡璇嗙偣銆傚笇鏈涗綘鑳芥湁鎵€鏀惰幏銆傛渶濂藉幓鐪嬫垜缁欑殑鍙傝€冭祫鏂欐繁鍏ュ涔犮€俫RPC寮曞叆涓€绯诲垪鐩綍锛歡RPC鍙婄浉鍏充粙缁嶅紩鍏RPC锛歡RPCClient鍜孲erver寮曞叆gRPC:gRPCStreaming,ClientandServer寮曞叆gRPC:TLS璇佷功璁よ瘉寮曞叆gRPC:鍩轰簬CA鐨凾LS璇佷功璁よ瘉寮曞叆gRPC:UnaryandStream鎷︽埅鍣ㄥ紩鍏RPC:璁╀綘鐨勬湇鍔″悓鏃舵彁渚汬TTP鎺ュ彛寮曞叆gRPC:forRPCMethodtodocustomauthentication甯﹀叆gRPC:gRPCDeadlines甯﹀叆gRPC:DistributedlinktrackinggRPC+Opentracing+ZipkinReferencesProtocolBuffersgRPC
