澶у濂斤紝鎴戞槸灏忚彍銆備竴涓笇鏈涙垚涓哄惞鐗沊鐨勭敺浜猴紝璋堝缓绛戯紒濡傛灉浣犱篃鎯虫垚涓烘垜鎯虫垚涓虹殑浜猴紝鎴栬€呰窡鐫€鎴戝仛浼达紝璁╁皬鑿滀笉鍐嶅鍗曪紒鏈枃涓昏浠嬬粛RabbitMQ鐨勬秷鎭涪澶遍棶棰樸€傚鏋滈渶瑕侊紝鍙互鍙傝€冦€傛槸鐨勶紝缁堜簬鏄疪abbitMQ浜嗭紒闈㈣瘯涓父瑙佺殑RabbitMQ闈㈣瘯棰樻湁寰堝锛屽父瑙佺殑濡備笅锛氭秷鎭彲闈犳€ч棶棰橈細濡備綍淇濊瘉鍙戦€佺殑娑堟伅鑷冲皯琚秷璐逛竴娆★紵寤惰繜娑堟伅闂锛氬浣曞疄鐜版秷鎭殑寤惰繜浼犻€掞紵楂樺彲鐢ㄩ棶棰橈細濡備綍閬垮厤鍗曠偣MQ鏁呴殰瀵艰嚧鐨勪笉鍙敤闂锛熸秷鎭爢绉棶棰橈細濡備綍瑙ｅ喅鐧句竾鏉℃秷鎭爢绉笉鑳藉強鏃舵秷璐圭殑闂锛熻繖鍑犱釜闂浼氳浣犵殑鑴戣鐤间竴闃靛瓙銆備綘鏄笉鏄湪缃戜笂鐪嬩簡寰堝浠嬬粛杩欐柟闈㈣В鍐虫柟妗堢殑鍗氭枃锛屼絾鏄湅瀹屽氨蹇樿浜嗭紵鍏跺疄鏄洜涓虹己涔忓疄闄呮搷浣溿€傛湰娆″皬鑿滃氨閲嶇偣璇磋RabbitMQ鏄浣曡В鍐虫秷鎭涪澶遍棶棰樼殑~1.娑堟伅鍙潬鎬ч棶棰樻秷鎭彲闈犳€ч棶棰樻垜浠彲浠ョ悊瑙ｄ负濡備綍闃叉娑堟伅涓㈠け锛熼偅涔堜负浠€涔堟秷鎭細涓㈠け鍛紵鎴戜滑鍙互鍏堢湅娑堟伅浼犻€掔殑鍏ㄨ繃绋嬶細鎴戜滑鍙互浠庡浘涓殑涓変釜闃舵鏉ュ垎鏋愬彲鑳界殑娑堟伅涓㈠け锛歱ublisher鍙戦€佹秷鎭埌exchange浜ゆ崲锛屽垎鍙戝埌queuequeue锛宒elivery鍒癱ustomer鐜板湪鐭ラ亾鍝簺闃舵鍙兘浼氬鑷存暟鎹涪澶辨崯澶憋紝閭ｆ垜浠氨鍙互浠庢簮澶翠笂鏉滅粷瀹冪殑鍙戠敓~锛侀」鐩粨鏋勯」鐩粨鏋勫緢绠€鍗曪紝灏辨槸涓€涓畝鍗曠殑SpringBoot椤圭洰锛屾湁娑堣垂鑰呭拰鐢熶骇鑰呬袱涓ā鍧?.鐢熶骇鑰呭彂閫佷涪澶盧abbitMQ鎻愪緵浜嗕竴涓彂甯冭€呯‘璁ゆ満鍒讹紝閬垮厤鍦ㄥ悜MQ鍙戦€佹秷鎭殑杩囩▼涓涪澶辨秷鎭棶棰樸€傛秷鎭彂閫佸埌MQ鍚庯紝浼氳繑鍥炰竴涓‘璁ょ粨鏋滅粰鐢熶骇鑰咃紝琛ㄧず娑堟伅鏄惁纭鎴愬姛銆傝繖涓‘璁ょ粨鏋滅殑璇锋眰鏈変袱绉嶏細publisher-confirm杩欑鏄彂閫佹柟鐨勭‘璁わ紝鏈変袱绉嶆儏鍐碉紝娑堟伅鎴愬姛鎶曢€掑埌浜ゆ崲鏈猴紝杩斿洖鐨刟ck娑堟伅娌℃湁鎶曢€掑埌浜ゆ崲鏈猴紝nackpublisher-returntype鏄彂閫佽€呯殑鍥炴墽锛屾湁涓ょ鎯呭喌娑堟伅鎶曢€掑埌浜ゆ崲鏈猴紝骞舵垚鍔熷垎鍙戝埌闃熷垪锛岃繑鍥炵殑ack娑堟伅鎶曢€掑埌浜ゆ崲鏈猴紝浣嗘病鏈夋垚鍔熷垎鍙戝埌闃熷垪锛屼互鍙妑eturnsnack娉ㄦ剰锛氱‘璁ゆ満鍒跺湪鍙戦€佹秷鎭椂锛岄渶瑕佷负姣忔潯娑堟伅璁剧疆涓€涓叏灞€鍞竴鐨処D锛屼互鍖哄垎涓嶅悓鐨勬秷鎭紝閬垮厤ack鍐茬獊鎺ヤ笅鏉ユ垜浠敤浠ｇ爜鏉ヨ鏄庡叿浣撶殑鎿嶄綔鏂规硶1锛夐厤缃枃浠跺厛鏉ョ湅鐪嬪湪鐢熶骇鑰呯殑閰嶇疆鏂囦欢涓€俁abbitMQ鐨勮繛鎺ヤ俊鎭墠闈㈠嚑椤归厤缃病浠€涔堝ソ璇寸殑銆備笅闈㈢湅鍑犱釜姣旇緝闄岀敓鐨刾ublisher-confirm-type鐨勯厤缃紝寮€鍚彂閫佺‘璁ゃ€傝繖閲屽彲浠ユ敮鎸佷袱绉峴imple锛氬悓姝ョ瓑寰卌onfirm缁撴灉鐩村埌瓒呮椂鐩稿叧锛氬紓姝ュ洖璋冿紝瀹氫箟ConfirmCallback锛孧Q鍦ㄨ繑鍥炵粨鏋滅殑鏃跺€欎細鍥炶皟杩欎釜ConfirmCallback銆俻ublisher-returns鍚敤public-return锛屽悓鏍锋槸鍩轰簬CallBack鏈哄埗锛屼絾鏄畾涔変簡ReturnCallbacktemplate.mandatory鏉ュ畾涔夎矾鐢卞け璐ユ椂鐨勭瓥鐣ャ€倀rue:璋冪敤ReturnCallbackfalse:鐩存帴涓㈠純娑堟伅2)瀹氫箟鍥炶皟浜嬩欢姣忎釜RabbitTemplate鍙兘閰嶇疆涓€涓猂eturnCallback3)鍦ㄥ彂閫佹秷鎭拰鎵ц鍙戦€佷唬鐮佷箣鍓嶏紝鎴戜滑纭繚瀹冨凡缁忚鍒涘缓锛坉irect-exchangedirect-exchange锛屼竴涓槦鍒梔irect-queue锛屽苟涓旂粦瀹氱殑key鏄痙irect锛屼竴鑸儏鍐典笅锛屾垜浠墽琛屼唬鐮侊紝鑲畾鏄彂閫佹垚鍔熶簡锛屽彲浠ョ湅鍒版帶鍒跺彴缁胯壊杈撳嚭锛屾垜浠凡缁忔垚鍔熸帴鏀跺埌娑堟伅闃熷垪涓殑娑堟伅浜嗭細鑷虫娌℃湁闂锛岄偅鎴戜滑灏遍渶瑕佹墜鍔ㄧ粰瀹冨埗閫犱竴浜涢棶棰樹簡~鎴戜滑鍙互淇敼寮€鍏崇殑鍚嶅瓧锛岃繖鏃跺€欏彂閫佹秷鎭殑鏃跺€欏鏋滄病鏈夋壘鍒板紑鍏筹紝寮€鍏宠偗瀹氫細杩斿洖nack锛岀劧鍚庢垜浠氨鍙互鍒ゆ柇瀹冩槸鍚﹁兘杩涘叆鎴戜滑鐨勪唬鐮侊細铏界劧浠ｇ爜鎵ц鏄豢鑹茬殑锛屼絾鏄洜涓簉abbitMQ鎵句笉鍒版纭殑寮€鍏筹紝瀵艰嚧娑堟伅鍙戦€佸け璐ワ紝涔熷氨鏄笅鍥句腑鐨勬祦绋嬶細杩欎釜鏄け璐ョ殑publish->exchange锛屾垜浠姄鍙栨垚鍔熶簡锛岄偅涔坋xchange->queue鐨勫け璐ワ紝鎴戜滑鍙互姝ｅ父鎶撳彇鍚楋紵鎴戜滑鍙互淇敼routingkey锛岃浜ゆ崲鏈轰笉璺敱鍒板搴旂殑queue銆傛垜浠彲浠ュ彂鐜板綋switch娌℃湁璺敱鍒板搴旂殑queue鏃讹紝鎴戜滑鑷畾涔夌殑鍥炶皟鍑芥暟涔熸垚鍔熻Е鍙戜簡锛屽啀鐪媟abbitMQ鎺у埗鍙般€傚彲浠ュ彂鐜拌繖閲屾秷鎭凡缁忔垚鍔熸姇閫掑埌浜ゆ崲鏈轰簡銆傞€氳繃涓ゆ绠€鍗曠殑閿欒妯℃嫙锛岀▼搴忓氨鍙互椤哄埄杩涘叆鎴戜滑棰勫畾涔夌殑鍥炶皟銆傝嚜瀹氫箟娑堟伅閲嶄紶鏈哄埗锛屾渶澶х▼搴﹂伩鍏嶆秷鎭涪澶辩殑闂4锛夌患涓婃墍杩帮紝鎴戜滑鍙互浣跨敤publisher-confirm鍜宲ublisher-return涓ょ閿欒鎹曡幏鏈哄埗锛岄伩鍏峱roducer->exchange->queuemessages濡傛灉涓㈠けpublisher-confirm娑堟伅鎴愬姛鍙戦€佺粰exchange锛宺eturnack娑堟伅鏈垚鍔熷彂閫佺粰exchange锛宺eturnnack娑堟伅鍦ㄥ彂閫佽繃绋嬩腑寮傚父锛屾病鏈夋敹鍒皉eceipt锛屽垯杩涘叆failureCallback鍥炶皟銆俻ublisher-return娑堟伅鎴愬姛鍙戦€佸埌exchange锛屼絾鏄病鏈夎矾鐢卞埌闃熷垪锛岃皟鐢ㄨ嚜瀹氫箟鍥炶皟鍑芥暟returnCallback2銆傛秷鎭瓨鍌ㄤ涪澶辨槸浠€涔堟剰鎬濓紵鍏跺疄灏辨槸鎸佷箙鍖栫殑姒傚康锛屽綋娑堟伅宸茬粡鎴愬姛鍙戦€佸埌queue锛屽鏋滄鏃禼onsumer娌℃湁鍙婃椂娑堣垂锛岃€宺abbitMQ鍒氬叧鏈洪噸鍚紝閭ｄ箞姝ゆ椂浣犱細鍙戠幇娑堟伅涓㈠け浜嗐€傝繖鏄洜涓篗Q榛樿灏嗘秷鎭瓨鍌ㄥ湪鍐呭瓨涓€傛垜浠彲浠ラ€氳繃寮€鍚寔涔呭寲鍔熻兘鏉ヤ繚璇丮Q涓殑娑堟伅涓嶄涪澶便€傚叾瀹炴垜浠湪閫氳繃RabbitMQ鎻愪緵鐨凣UI鍒涘缓浜ゆ崲鏈烘垨鑰呴槦鍒楃殑鏃跺€欙紝鍙互鍙戠幇鏈変竴涓寔涔呭寲鐨勯€夐」銆傚鏋滃皢鎸佷箙鍖栬缃负durable锛屾垜浠彲浠ュ彂鐜版棤璁烘€庝箞閲嶅惎MQ锛岄噸鍚悗鐨剆witch鍜宷ueue浠嶇劧瀛樺湪銆備絾鏄緢澶氭椂鍊欐垜浠垱寤哄紑鍏冲拰闃熷垪骞朵笉鏄湪GUI涓婂垱寤虹殑锛岃€屾槸閫氳繃搴旂敤浠ｇ爜鏉ュ垱寤哄紑鍏砅ersistentqueuesPersistenceofmessagesPersistence榛樿鎯呭喌涓嬶紝AMQP鍙戦€佺殑娑堟伅鏄寔涔呭寲鐨勶紝涓嶉渶瑕佹寚瀹?1銆傛秷璐硅€呮秷璐逛涪澶盧abbitMQ閲囩敤鐨勬満鍒舵槸褰撶‘璁ゆ秷鎭娑堣垂鑰呮秷璐瑰悗锛岀珛鍗冲垹闄わ紝閭ｄ箞濡備綍纭娑堟伅宸茬粡琚秷璐硅€呮秷璐逛簡鍛紵閭ｄ綘灏卞緱闈犳敹鎹潵纭浜嗐€傛秷璐硅€呮敹鍒版秷鎭悗锛岄渶瑕佸悜RabbitMQ鍙戦€佷竴涓猘ckreceipt锛岃〃绀鸿嚜宸卞凡缁忓鐞嗕簡娑堟伅銆傚叾涓璦ck鍦ˋMQP涓湁涓夌纭鏂瑰紡锛歮anual锛氭墜鍔╝ck锛岄渶瑕佸湪涓氬姟浠ｇ爜缁撴潫鍚庤皟鐢╝pi鍙戦€乤ckauto锛氳嚜鍔╝ck锛岃spring鐩戝惉鐩戝惉浠ｇ爜鏄惁寮傚父锛屽鏋滄湁鍒欒繑鍥瀉ck娌℃湁寮傚父锛屽惁鍒欒繑鍥瀗acknone锛歝loseack锛孧Q浼氬湪娑堟伅鎶曢€掑悗绔嬪嵆鍒犻櫎娑堟伅銆備互涓婁笁绉嶆柟寮忛兘鏄€氳繃淇敼閰嶇疆鏂囦欢瀹炵幇鐨勶細1锛夋墜鍔ㄨ繖绉嶆柟寮忛渶瑕佺敤鎴锋墜鍔ㄧ‘璁わ紝姣旇緝鐏垫椿銆傚鏋滄鏃舵墽琛岄€昏緫姝ｅ父锛岄偅涔圧abbitMQ涓婄殑娑堟伅浼氳鍒犻櫎锛屼絾鏄鏋滄墽琛岄€昏緫鎶涘嚭寮傚父锛屾病鏈夎繘鍏ユ墜鍔ㄧ‘璁ょ幆鑺傦紝RabbitMQ浼氫繚鐣欐秷鎭細2)auto杩欎釜鏂规硶浼氳嚜鍔ㄧ‘璁ゆ病鏈夊紓甯稿彂鐢熸椂鐨勬秷鎭€傚湪閰嶇疆鏂囦欢涓紝灏嗙‘璁ゆ柟寮忔敼涓篴uto杩涜娴嬭瘯锛氭甯告儏鍐典笅锛屾帴鏀舵秷鎭槸娌℃湁闂鐨勶紝鎵€浠ユ垜浠篃鍒堕€犱簡涓€浜涘紓甯告儏鍐碉細鎴戜滑鎵嬪姩鍒堕€犱簡涓€浜涘紓甯革紝鍙戠幇娑堟伅骞舵病鏈夎RabbitMQ鍒犻櫎锛岃€屾帶鍒剁珯涓€鐩存姤閿欙紝娌″畬娌′簡鍦拌瘯鍥鹃噸鏂版秷璐广€傝繖瑕佹槸鏀惧湪绾夸笂鐜涓嬶紝闅惧厤浼氭湁浜涙尗璐ユ劅銆傚綋娑堣垂鑰呭嚭鐜板紓甯告椂锛屾秷鎭細涓嶆柇閲嶆柊鍏ラ槦锛坮equeue锛夊埌闃熷垪涓紝鐒跺悗閲嶆柊鍙戦€佺粰娑堣垂鑰咃紝鐒跺悗鍐嶆寮傚父锛屽啀娆￠噸鏂板叆闃燂紝姝诲惊鐜紝浼氬鑷碝Q娑堟伅澶勭悊閲忕寷澧炲嚭鐜拌繖绉嶆儏鍐靛師鍥犳槸鍥犱负RabbitMQ鐨勬秷鎭け璐ラ噸璇曟満鍒讹紝浣嗘槸寰堝鏃跺€欐垜浠彲鑳戒笉鎯充竴鐩撮噸璇曪紝鎴戜滑鍙渶瑕佺粡鍘嗗嚑娆″皾璇曪紝澶辫触浜嗗氨鏀惧純澶勭悊銆傝繖鏃跺€欐垜浠渶瑕佸湪閰嶇疆鏂囦欢涓厤缃け璐ラ噸璇曟満鍒讹細鍚敤璇ラ厤缃悗锛屾垜浠噸鍚」鐩繘琛岃瀵熴€傞€氳繃鎺у埗鍙版垜浠彲浠ョ湅鍒帮紝閲嶈瘯3娆″悗锛孲pringAMQP浼氭姏鍑哄紓甯窤mqpRejectAndDontRequeueException锛岃鏄庢湰鍦伴噸璇曟満鍒跺凡缁忕敓鏁堛€傝€屾垜浠洖鍒癛abbitMQ鎺у埗鍙帮紝鍙互鐪嬪埌瀵瑰簲鐨勬秷鎭凡缁忚鍒犻櫎浜嗭紝涔熷氨鏄SpringAMQP鏈€缁堣繑鍥炰簡ack锛屽鑷存秷鎭MQ鍒犻櫎锛屼絾鏄繖绉嶅鐞嗘柟寮忓苟涓嶄紭闆呫€傞噸璇曞悗鐩存帴鍒犻櫎娑堟伅澶毚鍔涗簡锛岃闂湁浠€涔堟洿濂界殑澶勭悊鏂规硶鍚楋紵绛旀鏄偗瀹氱殑锛佹垜浠彲浠ヤ娇鐢ˋMQP鎻愪緵鐨凪essageRecovery鎺ュ彛锛屽畠鏈変笁绉嶄笉鍚岀殑瀹炵幇鏂瑰紡锛歊ejectAndDontRequeueRecoverer锛氶噸璇曟鏁拌€楀敖鍚庯紝鐩存帴鎷掔粷骞朵涪澶辨秷鎭€傞粯璁ゆ柟娉曪紝涓婇潰鏄柟娉旾mmediateRequeueMessageRecoverer:閲嶈瘯娆℃暟鑰楀敖鍚庯紝杩斿洖nack锛屾秷鎭噸鏂板叆闃烺epublishMessageRecoverer:閲嶈瘯娆℃暟鑰楀敖鍚庯紝灏嗗け璐ョ殑娑堟伅鎶曢€掑埌鎸囧畾鐨剆witch鍙互閲囩敤涓夌鏂规硶涓嶅悓鐨勫満鏅紝鍒嗘瀽涔嬪悗涓嶉毦鍙戠幇锛岀涓夌RepublishMessageRecoverer鏇村姞浼橀泤~褰撻噸璇曞け璐ユ椂锛屼細灏嗘秷鎭姇閫掑埌鎸囧畾瀛樻斁寮傚父娑堟伅鐨勯槦鍒椾腑锛屽悗闈㈠啀鎵嬪姩澶勭悊锛佸叿浣撲娇鐢ㄦ柟娉曞涓嬶細鑷畾涔夊紓甯稿鐞嗗悗锛屾垜浠噸鍚」鐩煡鐪嬫帶鍒跺彴锛氬彲浠ュ彂鐜伴噸璇?娆″悗锛屾垜浠殑寮傚父娑堟伅宸茬粡杩涘叆浜嗘垜浠嚜瀹氫箟鐨勫紓甯搁槦鍒?)none杩欎釜鏂规硶娌′粈涔堝ソ璇寸殑~涓嶇娑堟伅鏈夋病鏈夊紓甯革紝MQ閮戒細鍒犻櫎锛?.灏忕粨濡傛灉姝ゆ椂闈㈣瘯鍐嶉棶浣狅紝濡備綍淇濊瘉RabbitMQ娑堟伅鐨勫彲闈犳€э紵閭ｄ綘寰楀ソ濂借亰澶┿€傚浣曚繚璇佹秷鎭笉涓㈠け锛?锛夊厛鍒嗘瀽鍝簺涓㈠け鐨勫満鏅紵鍙戦€佹椂鍙兘浼氬嚭鐜版秷鎭涪澶憋紙娌℃湁鎶曢€掑埌exchange/娌℃湁璺敱鍒伴槦鍒楋級锛屾秷鎭病鏈夋寔涔呭寲锛孧Q瀹曟満锛屾秷璐硅€呮敹鍒版秷鎭紝鏈兘姝ｇ‘娑堣垂2锛夐偅鎬庝箞鍔為槻姝roducer寮€鍚‘璁ゆ満鍒讹紝淇濊瘉production娑堟伅鍒拌揪闃熷垪鐨勭‘璁ゆ満鍒讹紝鍖呮嫭publisher-confirm鍜宲ublisher-return銆傚綋娌℃湁涓嬪彂缁欎氦鎹㈡満鏃讹紝鎴戜滑鍙互閫氳繃publisher-confirm杩斿洖鐨刟ck鍜宯ack鏉ョ‘璁ゃ€傚綋switch娌℃湁鎴愬姛璺敱鍒伴槦鍒楁椂锛屾垜浠彲浠ヨ嚜瀹氫箟閫氳繃publisher-return鍥炶皟鍑芥暟鏉ョ‘璁わ紝姣忎釜RabbitTemplate鍙兘閰嶇疆涓€涓猂eturnCallback鏉ュ紑鍚寔涔呭寲鍔熻兘锛屼繚璇佹秷鎭湪娑堣垂鍓嶄笉浼氫涪澶卞湪闃熷垪涓?鎸佷箙鍖栧姛鑳藉垎涓轰氦鎹㈡満鎸佷箙鍖栥€侀槦鍒楁寔涔呭寲鍜屾秷鎭寔涔呭寲銆傛垜浠兘闇€瑕佸皢durable璁剧疆涓簍rue浠ュ惎鐢ㄦ秷璐硅€呯‘璁ゆ満鍒躲€傛渶浣庣骇鍒槸鑷姩銆傛秷璐硅€呯‘璁ゆ満鍒跺垎涓轰笁绉嶏細manual锛堟墜鍔ㄧ‘璁わ級銆乤uto锛堣嚜鍔ㄧ‘璁わ級銆乶one锛坈loseack锛夊け璐ラ噸璇曟満鍒躲€傛垜浠墜鍔ㄨ缃甅essageResoverer涓篟epublishMessageRecoverer锛屽皢鎶曢€掑け璐ョ殑娑堟伅杞Щ鍒板紓甯搁槦鍒椾腑锛岃瀹冪敱浜哄伐澶勭悊搴旂瓟銆傞潰璇曞畼蹇呴』榛橀粯鎵胯浣犳湁涓滆タ锛熷綋鐒惰繖鍙槸RabbitMQ鐨勯棶棰樹箣涓€锛屾垜浠笅涓€绡囩户缁В鍐冲叾浠栧嚑涓棶棰榽涓嶈绌鸿瘽锛屼笉鍋锋噿锛屽拰灏忚彍鍋氫釜鍚瑰槝X鏋舵瀯鐨勭▼搴忕尶鍚鍏虫敞鎴戝仛浼达紝璁╁皬鑿滀笉鍐嶅鍗曪紝璁╂垜浠湪涓嬮潰瑙侊紒浠婂ぉ浣犲姫鍔涗竴鐐癸紝鏄庡ぉ姹備汉鐨勫彛姘斿氨灏戜竴鐐癸紒鎴戞槸灏忚彍锛屼竴涓拰浣犱竴璧峰彉寮虹殑鐢蜂汉銆傪煉嬪井淇″叕浼楀彿宸插紑閫氾紝灏忚彍涓ら泦锛岃繕娌℃湁鍏虫敞鐨勫悓瀛﹁寰楀叧娉ㄥ摝锛?/p>
