鑳屾櫙鐢变簬鍏徃鍐呴儴鎵€鏈夋湇鍔￠兘杩愯鍦ㄩ樋閲屼簯k8s涓婏紝鎵€浠ubboprovider榛樿涓婃姤缁欐敞鍐屼腑蹇冪殑IP鏄疨odIP锛屼篃灏辨槸璇村湪k8s闆嗙兢澶栫殑缃戠粶鐜鏃犳硶璋冪敤dubbo鏈嶅姟銆傚鏋滄湰鍦板紑鍙戦渶瑕佽闂甼8s涓殑dubboprovider鏈嶅姟锛岄渶瑕佹墜鍔ㄥ皢鏈嶅姟鏆撮湶鍒板缃戙€傛垜浠殑鍋氭硶鏄负姣忎釜provider鏈嶅姟鏆撮湶涓€涓猄LBIP+鑷畾涔夌鍙ｏ紝閫氳繃dubbo鎻愪緵鐨凞UBBO_IP_TO_REGISTRY鍜孌UBBO_PORT_TO_REGISTRY鐜鍙橀噺灏嗗搴旂殑SLBIP+鑷畾涔夌鍙ｆ敞鍐屽埌娉ㄥ唽涓績锛屼粠鑰屽疄鐜版湰鍦扮綉缁滀箣闂寸殑杩炴帴杩樻湁k8s鐨刣ubbo鏈嶅姟锛屼絾鏄繖绉嶆柟寮忕鐞嗚捣鏉ュ緢楹荤儲锛屾瘡涓湇鍔￠兘瑕佽嚜瀹氫箟涓€涓鍙ｏ紝姣忎釜鏈嶅姟鐨勭鍙ｄ笉鑳藉啿绐併€傚綋鏈嶅姟杈冨鏃讹紝绠＄悊璧锋潵灏遍潪甯稿洶闅俱€傛墍浠ユ兂鑳戒笉鑳藉疄鐜颁竴涓竷灞備唬鐞?铏氭嫙鍩熷悕锛屽儚nginxingress涓€鏍峰鐢ㄤ竴涓鍙ｏ紝閫氳繃鐩爣dubboprovider鐨刟pplication.name鍋氱浉搴旂殑杞彂锛岃繖鏍锋墍鏈夌殑鏈嶅姟鍙渶瑕佹敞鍐屽悓涓€涓猄LBIP+绔彛灏卞浜嗭紝澶уぇ鎻愰珮浜嗕究鍒╂€с€備竴鏂圭爺绌跺彂鐜板彲琛屽悗锛屽氨浼氭帹鍑猴紒椤圭洰宸茬粡寮€婧愶細https://github.com/monkeyWie/dubbo-ingress-controller鎶€鏈鐮旀€濊矾棣栧厛dubboRPC璋冪敤榛樿浣跨敤dubbo鍗忚锛屾墍浠ラ渶瑕佺湅鐪嬫湁娌℃湁浠讳綍鍙互鐢ㄤ簬杞彂鐨勫崗璁秷鎭俊鎭兘鏄鎵剧被浼间簬HTTP鍗忚鐨凥ost璇锋眰澶淬€傚鏋滄湁锛屽彲浠ユ牴鎹繖浜涗俊鎭仛鍙嶅悜浠ｇ悊鍜岃櫄鎷熷煙鍚嶈浆鍙戯紝鍦ㄦ鍩虹涓婂彲浠ュ疄鐜扮被浼糿ginx鐨刣ubbo缃戝叧銆傜浜屾锛屽疄鐜癲ubboingresscontroller锛岄€氳繃k8singresswatcher鏈哄埗鍔ㄦ€佹洿鏂癲ubbogateway鐨勮櫄鎷熷煙鍚嶈浆鍙戦厤缃紝鐒跺悗鎵€鏈塸rovider鏈嶅姟閮界敱杩欎釜鏈嶅姟杞彂锛屼笂鎶ョ粰娉ㄥ唽涓績鐨勫湴鍧€涓轰篃缁熶竴涓鸿繖涓湇鍔＄殑鍦板潃銆傛灦鏋勫浘dubbo鍗忚鍏堟潵涓€寮犲畼鏂圭殑鍗忚鍥撅細鍙互鐪嬪埌dubbo鍗忚鐨刪eader鏄浐瀹氱殑16瀛楄妭锛屽苟娌℃湁绫讳技HTTPHeader鐨勫彲鎵╁睍瀛楁锛屼篃娌℃湁鎼哄甫application.nametargetprovider鐨勫瓧娈碉紝鎵€浠ユ垜鍚戝畼鏂规彁鍑轰簡涓€涓棶棰樸€傚畼鏂圭殑鍥炵瓟鏄€氳繃consumer-definedFilter鎶婄洰鏍噋rovider鐨刟pplication.name鏀惧湪闄勪欢涓€傝繖閲屼笉寰椾笉鍚愭Ы涓€涓媎ubbo鍗忚銆傛墿灞曞瓧娈靛疄闄呬笂鏀惧湪姝ｆ枃涓紝濡傛灉瑕佸疄鐜拌浆鍙戯紝闇€瑕佽В鏋愭墍鏈夌殑璇锋眰鎶ユ枃锛屾墠鑳藉緱鍒版兂瑕佺殑鎶ユ枃锛屼笉杩囬棶棰樹笉澶э紝鍥犱负涓昏鐢ㄤ簬寮€鍙戠幆澧冿紝杩欎竴姝ュ媺寮哄彲浠ュ疄鐜般€俴8singressk8singress鏄负HTTP鑰岀敓鐨勶紝涓嶈繃閲岄潰鐨勫瓧娈靛凡缁忚冻澶熶簡锛屾垜浠潵鐪嬩竴涓猧ngress閰嶇疆锛歛piVersion:extensions/v1beta1kind:Ingressmetadata:name:user-rpc-dubboannotations:kubernetes.io/ingress.class:"dubbo"spec:rules:-host:user-rpchttp:paths:-backend:serviceName:user-rpcservicePort:20880path:/鍍廻ttp涓€鏍烽€氳繃host閰嶇疆杞彂瑙勫垯锛屼絾鏄痟ost閰嶇疆浜嗙洰鏍囨彁渚涜€卆pplication.name锛屽悗绔湇鍔℃槸鐩爣鎻愪緵鑰呭搴旂殑鏈嶅姟銆傝繖鏄竴涓娇鐢╧ubernetes.io/ingress.class娉ㄨВ鐨勭壒娈婃敞瑙ｃ€傝繖涓敞瑙ｅ彲浠ユ寚瀹氳繖涓猧ngress鍦ㄥ摢涓猧ngresscontroller涓婄敓鏁堛€備箣鍚庯紝鎴戜滑鐨刣ubboingresscontroller鍙細瑙ｆ瀽娉ㄨВ鍊间负dubbo鐨刬ngress閰嶇疆銆傚紑鍙戝墠鐨勬妧鏈鐮旇繘灞曢『鍒╋紝闅忓悗杩涘叆寮€鍙戦樁娈点€傛秷璐硅€呰嚜瀹氫箟Filter鍓嶉潰鎻愬埌锛屽鏋滆姹備腑闇€瑕佹惡甯︾洰鏍囨彁渚涜€呯殑application.name锛岄偅涔堟秷璐硅€呴渶瑕佽嚜瀹氫箟Filter銆備唬鐮佸涓嬶細@Activate(group=CONSUMER)publicclassAddTargetFilterimplementsFilter{@OverridepublicResultinvoke(Invokerinvoker,Invocationinvocation)throwsRpcException{StringtargetApplication=StringUtils.isBlank(invoker.getUrl().鑾峰彇杩滅▼搴旂敤绋嬪簭锛堬級锛夛紵invoker.getUrl().getGroup():invoker.getUrl().getRemoteApplication();//灏嗙洰鏍囨彁渚涜€呯殑application.name鏀惧叆闄勪欢涓璱nvocation.setAttachment("target-application",targetApplication);杩斿洖璋冪敤鑰呫€傝皟鐢紙璋冪敤锛夛紱杩欓噷杩樻湁涓€涓姳鎬紝dubbo娑堣垂鑰呭湪绗竴娆¤闂椂浼氬彂璧蜂竴涓幏鍙栧厓鏁版嵁鐨勮姹傦紝杩欎釜璇锋眰鏃犳硶閫氳繃invoker.getUrl().getRemoteApplication()鑾峰彇鍊硷紝浣嗘槸鍙互閫氳繃invoker.getUrl().getGroup().dubbo缃戝叧杩欓噷闇€瑕佸紑鍙戜竴涓被浼糿ginx鐨刣ubbo缃戝叧锛屽疄鐜颁竷灞備唬鐞嗗拰铏氭嫙鍩熷悕杞彂銆傜紪绋嬭瑷€鐩存帴閫夋嫨go銆傞鍏堬紝go瀵逛簬缃戠粶寮€鍙戠殑绮剧璐熸媴寰堜綆銆傝繕鏈変竴涓猟ubbo-go椤圭洰鍙互鐩存帴浣跨敤銆傞噷闈㈢殑瑙ｇ爜鍣紝鍜実o閮芥湁鍘熺敓鐨刱8ssdk鏀寔锛屽畬缇庯紒鎬濊矾鏄紑鍚竴涓猅CPServer锛岀劧鍚庤В鏋恉ubbo璇锋眰鎶ユ枃锛岃幏鍙栭檮浠朵腑鐨則arget-application灞炴€э紝鐒跺悗鍙嶅悜浠ｇ悊鍒扮湡姝ｇ殑dubboprovider鏈嶅姟銆傛牳蹇冧唬鐮佸涓嬶細routingTable:=map[string]string{"user-rpc":"user-rpc:20880","pay-rpc":"pay-rpc:20880",}listener,err:=net.Listen("tcp",":20880")iferr!=nil{returnerr}for{clientConn,err:=listener.Accept()iferr!=nil{logger.Errorf("鎺ュ彈閿欒:%v",err)continue}gofunc(){deferclientConn.Close()varproxyConnnet.Conndeferfunc(){ifproxyConn!=nil{proxyConn.Close()}}()scanner:=bufio.NewScanner(clientConn)scanner.Split(split)//瑙ｆ瀽璇锋眰娑堟伅锛岃幏鍙栦竴涓畬鏁寸殑璇锋眰scanner.Scan(){data:=scanner.Bytes()//閫氳繃dubbo-go鎻愪緵鐨勫簱灏哰]byte鍙嶅簭鍒楀寲涓篸ubbo璇锋眰缁撴瀯buf:=bytes.NewBuffer(data)pkg:=impl.NewDubboPackage(buf)pkg.Unmarshal()鍖卍y:=pkg.Body.(map[string]interface{})attachments:=body["attachments"].(map[string]interface{})//浠庨檮浠朵腑鑾峰彇鐩爣鎻愪緵鑰呯殑application.name鐩爣锛?attachments["target-application"].(string)ifproxyConn==nil{//鍙嶅悜浠ｇ悊鍒扮湡姝ｇ殑鍚庣鏈嶅姟host:=routingTable[target]proxyConn,_=net.Dial("tcp",host)gofunc(){//鍘熷杞彂io.Copy(clientConn,proxyConn)}()}//灏嗗師濮嬫秷鎭啓鍏ョ湡瀹炲悗绔湇鍔★紝鐒跺悗鍐嶅幓鍘熷杞彂proxyConn.Write(data)}}()}funcsplit(data[]byte,atEOFbool)(advanceint,token[]byte,errerror){濡傛灉atEOF&&len(data)==0{return0,nil,nil}buf:=bytes.NewBuffer(data)pkg:=impl.NewDubboPackage(buf)err=pkg.ReadHeader()iferr!=nil{iferrors.Is(err,hessian.ErrHeaderNotEnough)||}errors.Is(err,hessian.ErrBodyNotEnough){杩斿洖0,nil,nil}return0,nil,err}if!pkg.IsRequest(){return0,nil,errors.New("notrequest")}requestLen:=impl.HEADER_LENGTH+pkg.Header.BodyLen濡傛灉len(data)
