鈥旀渶杩戝叕鍙告湁涓渶姹傘€備竴椤筍MS鏈嶅姟宸叉敹鍒板涓涓夋柟渚涘簲鍟嗐€傞儴鍒嗕笟鍔￠渶瑕佹煡鐪嬬涓夋柟渚涘簲鍟嗙殑鐭俊鍖呭墿浣欐暟閲忥紝閫夋嫨鍓╀綑鏁伴噺鏈€澶氱殑娓犻亾杩涜鎵归噺鍙戦€併€傛湁浜涙湇鍔℃寚瀹氫簡鏌愪釜鐭俊鎻愪緵鑰咃紝鏈変簺鍦烘櫙闇€瑕佹牴鎹湇鍔＄殑浠峰€煎姩鎬佸喅瀹氫娇鐢ㄥ摢涓彁渚涜€呫€傚満鏅潪甯稿鏉傦紝鍙樺寲棰戠箒銆備互鍓嶇殑浠ｇ爜鐪熺殑寰堢碂绯曘€傞€夋嫨鍓╀綑閲戦鏈€澶氱殑棰戦亾涓€涓€妫€鏌ワ紝鐒跺悗寰楀嚭缁撴灉杩涜姣旇緝銆傝嚦浜庢寚瀹氫緵搴斿晢鍜屾牴鎹笟鍔′环鍊煎垽鏂拰閫夋嫨渚涘簲鍟嗭紝澶ч噺鐨刬felse琚敤鏉ュ祵濂楀悇绉嶅垽鏂€傛瘡娆＄湅鍒拌繖涓€鍫嗕唬鐮侊紝鐪熺殑瑙夊緱澶矖绯欎簡銆傚叧閿槸鏈変簺渚涘簲鍟嗚繕鍦ㄩ绻佹洿鎹紝鏂扮殑渚涘簲鍟嗛渶瑕佹浛鎹㈡棫鐨勪緵搴斿晢锛屽姞鍏ュ埌杩欎竴澶у爢浠ｇ爜涓€傚晢涓氬垽鏂潯浠朵篃浼氫笉鏃跺彂鐢熷彉鍖栥€傚嚑娆￠棶棰樺悗锛岄瀵肩湅涓嶄笅鍘讳簡锛岃鎴戞兂鍔炴硶浼樺寲涓€涓嬨€傛垜鐞嗛『浜嗛€昏緫锛屾暣涓叧绯诲浘搴旇鏄繖鏍风殑锛屽叾涓垜鎶婇€愭潯妫€鏌ユ敼鎴愪簡骞惰妫€鏌ワ紝涓轰簡鐪佸幓涓茶妫€鏌ョ殑IO鑰楁椂闂銆傛湁涓€浜涘鏉傜殑鏁版嵁搴撴煡璇㈤€昏緫锛屾垜鍘绘帀鍒ゆ柇骞傜瓑鎬х殑姝ラ銆備粎閫夋嫨骞剁粯鍒跺叧閿楠ゃ€傚彨鎴戦噸鏋勮繖涓紝鎱㈡參鍐欙紝浣嗗叧閿槸姣忎竴姝ュ拰鍒ゆ柇閫昏緫杩樻槸涓嶆椂鍙樺寲鐨勩€傝繖瑕佹眰鎴戠殑浠ｇ爜闈炲父鐏垫椿銆傛墍浠ュ湪璁捐鐨勬椂鍊欙紝涓€鐩村緢鑻︽伡鎬庝箞璁捐銆備簩鏄粍閲屽紑浜ゆ祦浼氱殑鏃跺€欙紝鎴戝拰鍏朵粬缁勭殑鏈嬪弸寮€鍙戜簡涓€涓紑婧愭鏋垛€斺€擫iteFlow銆傜爺绌朵簡杩欎釜寮€婧愭鏋讹紝鍙戠幇LiteFlow鏄浗浜х殑瑙勫垯寮曟搸锛屽彲浠ョ紪鎺掍换鎰忓鏉傜殑娴佺▼锛岃繕鏀寔鐑埛鏂般€傝繖鍩烘湰涓婂畬鍏ㄧ鍚堟垜鐨勯渶姹傦紒鏂囨。寰堣缁嗕篃寰圢ICE锛屽叏閮ㄥ瀹屽ぇ姒傞渶瑕佸崐澶╂椂闂淬€傚彂鐜版柊鐗圠iteFlow鐨勮鍒欐槸鐢‥L琛ㄨ揪寮忓啓鐨勩€傝娉曟€绘暟澶х害10涓紝闈炲父瀹规槗鐞嗚В銆傛瘮濡傝繖绉嶅浘锛氬湪LiteFlow涓敤rule琛ㄧず鏄細THEN(a,WHEN(b,THEN(c,d)),e)鍏朵腑THEN浠ｈ〃serial,WHEN浠ｈ〃骞惰鎵ц銆傝繖绉嶈娉曚竴鐩簡鐒躲€傚啀鐪嬭繖寮犲浘锛氬湪LiteFlow涓紝瑙勫垯琛ㄧず鏄細THEN(a,WHEN(b,SWITCH(c).to(d,e)),f)鍏朵腑SWITCH鏄叧閿繖涓瘝鐨勬剰鎬濇槸涓撳睘缃戝叧銆俢缁勪欢鏄竴涓猨ava绫汇€傛牴鎹墽琛岀粨鏋滐紝閫夋嫨鎵цd杩樻槸e銆傛墍浠ュ儚杩欐牱宓屽澶氬眰搴旇鏄病鏈夐棶棰樼殑銆傚湪LiteFlow鐨勬枃妗ｄ腑锛屼綔鑰呯粰鍑轰簡闈炲父璇︾粏鐨勪緥瀛愶紝杩樻湁涓€浜涘鏉傜殑渚嬪瓙锛屾瘮濡傦細杩欎釜澶嶆潅鐨勪緥瀛愬彲浠ュ啓鎴怢iteFlow琛ㄨ揪寮忥細THEN(A,WHEN(THEN(B,C),THEN(D,E,F),THEN(SWITCH(G).to(THEN(H,I,WHEN(J,K)).id("t1"),THEN(L,M).id("t2")),N)),Z)鍏惰〃杈惧紡杩樺彲浠ュ畾涔夊瓙鍙橀噺锛屼笂闈㈢殑琛ㄨ揪寮忓彲浠ュ啓鎴愶細item1=THEN(B,C);item2=THEN(D,E,F);item3_1=THEN(H,I,WHEN(J,K)).id("t1");item3_2=THEN(L,M).id("t2");item3=THEN(SWITCH(G).to(item3_1,item3_2),N);THEN(A,WHEN(item1,item2,item3),Z);鍏跺疄瀵规瘮鍥撅紝浠旂粏鐪嬶紝浣犱細瑙夊緱杩欎釜琛ㄨ揪杩樻槸寰堟竻鏅扮殑銆傚簲鐢ㄤ簬鎴戠殑鐭俊绯荤粺缁扮话鏈変綑銆備笁鎴戠爺绌跺苟鑺变簡10鍒嗛挓涓烘垜鐨勮繃绋嬬紪鍐欒〃杈惧紡瑙勫垯锛??xmlversion="1.0"encoding="UTF-8"?>selectBestChannel=THEN(WHEN(,channel2Query,channel3Query,channel4Query,channel5Query,channel6Query),channelSelector).id("branch1");selectBizChannel=THEN(biz1,SWITCH(SWITCH4,ITCHchannel.if_3).to(channel5,channel6).id("s3")).id("s2")).id("branch2");鐒跺悗锛堝寘鏁版嵁,SWITCH(if_1).to(channel1,channel2,selectBestChannel,selectBizChannel),batchSender);鎴戞槸鐢ㄦ枃妗ｄ腑鎻愬埌鐨勫瓙鍙橀噺鏉ュ啓鐨勶紝杩欐牱鍐欐洿娓呮櫚鍏跺疄鎴戞€荤粨浜嗕竴涓皬鎶€宸э細涓嶇澶氬鏉傜殑鍥撅紝閮藉彲浠ユ媶鍒嗘垚閮ㄥ垎鏁翠綋銆傞鍏堢‘瀹氬眬閮ㄥ皬鍙橀噺锛岀劧鍚庡湪涓昏繘绋嬩腑寮曞叆杩欎簺灞€閮ㄥ彉閲忋€傛棤璁哄浣曪紝鎴戣姳浜嗗ぇ绾?0鍒嗛挓鏉ュ啓杩欏紶鐓х墖銆傝嚦浜庢瘡涓€涓皬缁勪欢銆傛垜鍙槸鎸夌収鏂囨。锛屾妸鍘熸潵鐨勫ぇ閫昏緫锛屼竴涓竴涓殑鏀规垚浜嗗皬閫昏緫銆傚皝瑁呭湪涓嶅悓鐨勭粍浠朵腑锛岀粰鍑虹浉搴旂殑Id鍗冲彲銆傛渶鍚庯紝瀹冨彲浠ョ敱LiteflowExecutor瑙﹀彂銆侺iteflowResponseresponse=flowExecutor.execute2Resp("channelSenderChain",null,BatchMessageResultContext.class);BatchMessageResultContextcontext=response.getFirstContextBean();if(response.isSuccess()){log.info("鎵ц鎴愬姛锛屾渶缁堥€夋嫨鐨勯€氶亾涓簕}",context.getFinalResultChannel());}else{log.error("鎵ц澶辫触",response.getCause());}寰堢畝鍗曪紒锛侊紒鑰屼笖闈炲父浼橀泤锛侊紒锛佷笁鎴戞敼鎴愪笂闈㈢殑褰㈠紡鍚庯紝鍚勪釜灏忛€昏緫鍧楀氨瀹屽叏瑙ｈ€︿簡銆傛暟鎹殑杩炴帴瀹屽叏鐢变笂涓嬫枃杩炴帴銆傜爺绌朵簡LiteFlow鐨勬蹇碉紝鍙戠幇杩欎釜姒傚康闈炲父濂姐€傜洿鎺ユ媶鍒嗗師浠ｇ爜锛屽己鑰﹀悎銆傜幇鍦ㄥ鏋滀笟鍔″彂鐢熷彉鍖栵紝鎴戝彧闇€瑕侀噸鍐欏叾涓竴涓粍浠跺嵆鍙€傚苟涓旂粍浠跺彲浠ラ噸澶嶄娇鐢ㄣ€傚畠浠箣闂寸殑椤哄簭涔熷彲浠ラ殢鎰忓垏鎹€傝繖涓€鍒囷紝鍙渶瑕佹洿鏀硅鍒欐枃浠跺嵆鍙€備唬鐮佸畬鍏ㄦ病鏈夊姩杩囥€傛垜浠旂粏闃呰浜嗘枃妗ｃ€傝妗嗘灦杩樻敮鎸佸畬鍏ㄦ棤缂濈殑鐑埛鏂般€傝櫧鐒舵垜鐨勪唬鐮佹病鏈夌敤鍒拌繖涓壒鎬э紝浣嗘槸鐪嬭捣鏉ョ‘瀹炲緢寮哄ぇ銆傛洿鏀硅鍒欐帓鍒楃敋鑷充笉闇€瑕侀噸鏂板惎鍔ㄥ簲鐢ㄧ▼搴忥紒锛侊紒浣嗗嵆浣挎垜琚潃浜嗭紝鎴戜篃涓嶄細浣跨敤杩欎釜鍔熻兘銆傞瀵艰鎴戞崲涓氬姟锛屾垜瑕佸鎶ュ伐鏃躲€傚鏋滆繖涓笂绾匡紝鎴戝皢鏃犳硶鎶ュ憡鏇村鐨勬椂闂淬€?.馃LiteFlow杩樻湁寰堝楂樼骇鐗规€э紝姣斿闅愬紡娴佺▼銆佷簨浠跺洖璋冦€佸０鏄庡紡缁勪欢銆佺粍浠跺垏闈€佹楠や俊鎭€佺嚎绋嬫睜瀹氬埗銆佺鏈変紶閫掋€佺畝鍗曠洃鎺с€傝繖涓浗浜ц鍒欏紩鎿庤鐜╁嚭鏉ヤ簡锛屽己澶э紒閲嶇偣璇磋LiteFlow鐨勮剼鏈粍浠剁殑鍔熻兘銆傝繖涓姛鑳芥槸鎴戝啓浠ｇ爜鍚庢墠鍙戠幇鐨勩€傛垜鍙戠幇浣跨敤鑴氭湰缁勪欢鏇寸伒娲汇€侺iteFlow铏界劧鏀寔鐑埛鏂帮紝浣嗕粎闄愪簬瑙勫垯鏂囦欢鐨勫彉鍖栥€傛偍鐨凧ava浠ｇ爜鏇存敼锛屾偍蹇呴』閲嶆柊鍚姩銆傜劧鑰岋紝LiteFlow鐨勮剼鏈粍浠剁敋鑷充负鎮ㄧ獊鐮翠簡杩欎竴灞傘€傛偍鍙互瀹氫箟鑴氭湰锛屼篃鏀寔groovy鑴氭湰銆傜幇鍦紝鎮ㄧ敋鑷充笉闇€瑕侀噸鏂板惎鍔ㄥ簲鐢ㄧ▼搴忔潵鏇存敼閫昏緫銆?鐢变簬鎴戜笂闈㈢殑绉佸績锛岃繖涓姛鑳芥垜涔熶笉浼氳窡棰嗗璇寸殑馃槉銆傚洓鎴戦噸鏋勪簡杩欎釜椤圭洰鍚庯紝鍙戠幇LiteFlow妗嗘灦鏈夊緢澶氬彲鐜╃殑鍦版柟銆傝櫧鐒跺畼鏂瑰绉版槸瑙勫垯寮曟搸锛屼絾閫傜敤浜庣郴缁熻В鑰﹀拰缁勪欢缂栨帓銆備絾鏄垜鍙戠幇鐢ㄥ畠鏉ュ仛涓€浜涚畝鍗曠殑寮傛绾跨▼涔熷緢涓嶉敊銆傛垜鑷繁瀵瑰绾跨▼涓嶆槸寰堢簿閫氾紝鎵€浠ョ敤杩欎釜鍐欒捣鏉ュ緢鏂逛究銆傞櫎浜嗚鍒欐枃浠讹紝LiteFlow杩樻敮鎸佷唬鐮佸舰寮忕殑閾惧紡姹囩紪瑙勫垯銆傝繖涓壒鎬ф濂界敤鏉ュ啓澶氱嚎绋嬨€傛瘮濡傛垜鎯冲啓杩欐牱涓€涓绾跨▼鐨勪緥瀛愶細鎴戠湡鐨勪笉鐭ラ亾鐢–ompletableFuture鎬庝箞鍐欍€備絾鏄偍浣跨敤LiteFlow闈炲父瀹规槗銆傚湪LiteFlow涓紝鎮ㄤ笉闇€瑕佸畾涔夌嚎绋嬨€傝妗嗘灦灏嗕负鎮ㄥ垱寤虹嚎绋嬨€備綘鍙渶瑕佸皢绾跨▼涓殑浠ｇ爜鍙樻垚缁勪欢锛岀劧鍚庝娇鐢ㄤ唬鐮佸畾涔夎鍒欍€傚啓娉曞涓嬶細Stringel="THEN("+"main1,"+"WHEN("+"THEN(c1,c2,WHEN(c3,c4)),"+"THEN(c5,c6)"+"),"+"main2"+")";LiteFlowChainELBuilder.createChain().setChainName("testChain").setEL(el).build();LiteflowResponseresponse=flowExecutor.execute2Resp("testChain",澶勭悊鍒濆鍙傛暟,浣犵殑涓婁笅鏂?class);杩欐牱锛岃繖涓湅浼煎鏉傜殑绾跨▼鎺掑垪灏卞畬鎴愪簡銆傝繖涓鏋跺浜庝笉浼氬啓澶氱嚎绋嬬殑灏忕櫧鏉ヨ绠€鐩村氨鏄闊炽€傜埍锛岀埍锛岀埍銆備簲锛屽浜嗭紝瀹樼綉鐨勬枃绔犺秴绾ц缁嗐€傜ぞ鍖虹兢涔熷緢娲昏穬銆備负浜嗘柟渚跨悊瑙ｏ紝鎴戠壒鍦癿ock浜嗕竴涓嬫垜鐭俊鐨勪緥瀛愶紝骞舵帹閫佸埌浜唃ithub浠撳簱銆傚彲浠ユ媺涓嬫潵鑷繁鐜┿€俬ttps://github.com/bryan31/me...椤轰究璁颁笅LiteFlow鐨凣itee鐨勪粨搴撳湴鍧€锛屽ぇ瀹跺彲浠ュ叧娉ㄤ竴涓嬭繖涓浗鍐呯殑瑙勫垯寮曟搸https://gitee.com/dromara/lit...
