鏈枃涓昏鍏虫敞浠ヤ笅鍑犱釜闂锛?.濡備綍淇濊瘉娑堟伅闃熷垪鐨勯珮鍙敤锛烺abbitMQ鐨勯珮鍙敤RabbitMQ姣旇緝鏈変唬琛ㄦ€э紝鍥犱负瀹冩槸鍩轰簬master-slave锛堥潪鍒嗗竷寮忥級鏉ュ疄鐜伴珮鍙敤鐨勶紝鎴戜滑灏嗕互RabbitMQ涓轰緥鏉ヨ鏄庣涓€涓狹Q鏄浣曞疄鐜伴珮鍙敤鐨勩€俁abbitMQ鏈変笁绉嶆ā寮忥細鍗曟満妯″紡銆佹櫘閫氶泦缇ゆā寮忓拰闀滃儚闆嗙兢妯″紡銆傚崟鏈烘ā寮忓崟鏈烘ā寮忔槸Demo绾у埆銆備竴鑸兘鏄湰鍦板惎鍔ㄧ帺鐜煒勶紝娌℃湁浜虹敤鍗曟満妯″紡鏉ョ敓浜с€傛櫘閫氶泦缇ゆā寮忥紙鏃犻珮鍙敤锛夋櫘閫氶泦缇ゆā寮忔槸鎸囧湪澶氬彴鏈哄櫒涓婂惎鍔ㄥ涓猂abbitMQ瀹炰緥锛屾瘡鍙版満鍣ㄤ竴涓€備綘鍒涘缓鐨勯槦鍒楀彧浼氭斁鍦ㄤ竴涓猂abbitMQ瀹炰緥涓婏紝浣嗘槸姣忎釜瀹炰緥閮戒細鍚屾闃熷垪鐨勫厓鏁版嵁锛堝厓鏁版嵁鍙互璁や负鏄槦鍒楃殑涓€浜涢厤缃俊鎭紝閫氳繃鍏冩暟鎹彲浠ユ壘鍒伴槦鍒楁墍鍦ㄧ殑瀹炰緥).褰撲綘娑堣垂鐨勬椂鍊欙紝鍏跺疄濡傛灉浣犺繛鎺ョ殑鏄彟涓€涓疄渚嬶紝閭ｄ箞閭ｄ釜瀹炰緥浼氫粠闃熷垪鎵€鍦ㄧ殑瀹炰緥涓媺鍙栨暟鎹€傝繖绉嶆柟娉曠‘瀹炲緢楹荤儲锛屼篃涓嶆槸寰堝ソ銆傚畠娌℃湁瀹炵幇鎵€璋撶殑鍒嗗竷寮忥紝瀹冨彧鏄竴涓櫘閫氱殑闆嗙兢銆傚洜涓鸿繖浼氬鑷存秷璐硅€呰涔堟瘡娆￠殢鏈鸿繛鎺ヤ竴涓疄渚嬬劧鍚庢媺鍙栨暟鎹紝瑕佷箞姘镐箙杩炴帴闃熷垪鎵€鍦ㄧ殑瀹炰緥娑堣垂鏁版嵁銆傚墠鑰呮湁鏁版嵁鎷夊彇鐨勫紑閿€锛屽悗鑰呭鑷村崟瀹炰緥鎬ц兘鐡堕銆傚苟涓斿鏋滄斁缃槦鍒楃殑瀹炰緥瀹曟満锛屽叾浠栧疄渚嬪皢鏃犳硶浠庤瀹炰緥涓媺鍙栥€傚鏋滃紑鍚秷鎭寔涔呭寲锛岃RabbitMQ灏嗘秷鎭瓨鍌ㄥ湪鍦伴潰涓婏紝娑堟伅鍙兘涓嶄細涓㈠け銆備綘寰楃瓑杩欎釜瀹炰緥鎭㈠鍚庯紝鎵嶈兘缁х画浠庤繖涓槦鍒椾腑鎷夊彇鏁版嵁銆傞偅涔堣繖涓簨鎯呭氨姣旇緝灏村艾浜嗭紝娌℃湁鎵€璋撶殑楂樺彲鐢紝杩欎釜鏂规涓昏鏄负浜嗘彁楂樺悶鍚愰噺锛屼篃灏辨槸璇磋闆嗙兢涓殑澶氫釜鑺傜偣鏈嶅姟浜庢煇涓槦鍒楃殑璇诲啓鎿嶄綔銆傞暅鍍忛泦缇ゆā寮忥紙楂樺彲鐢級涔熷氨鏄墍璋撶殑RabbitMQ鐨勯珮鍙敤妯″紡銆備笌鏅€氶泦缇ゆā寮忎笉鍚岀殑鏄紝鍦ㄩ暅鍍忛泦缇ゆā寮忎笅锛屼綘鍒涘缓鐨勯槦鍒楋紝鏃犺鏄厓鏁版嵁杩樻槸闃熷垪涓殑娑堟伅锛岄兘浼氬瓨鍦ㄤ簬澶氫釜瀹炰緥涓婏紝涔熷氨鏄姣忎釜RabbitMQ鑺傜偣閮芥湁涓€浠藉畬鏁寸殑闃熷垪鍓湰闀滃儚锛屽寘鎷槦鍒楃殑鎵€鏈夋暟鎹€傜劧鍚庢瘡娆″悜闃熷垪鍐欏叆娑堟伅锛屾秷鎭兘浼氳嚜鍔ㄥ悓姝ュ埌澶氫釜瀹炰緥鐨勯槦鍒椾腑銆傞偅涔堝浣曞惎鐢ㄨ繖绉嶉暅鍍忛泦缇ゆā寮忓憿锛熷叾瀹炲緢绠€鍗曘€俁abbitMQ鏈変竴涓緢濂界殑绠＄悊鎺у埗鍙帮紝灏辨槸鍦ㄥ悗鍙版坊鍔犱竴涓猵olicy銆傝绛栫暐涓洪暅鍍忛泦缇ゆā寮忕殑绛栫暐銆傛寚瀹氭椂锛屽彲浠ヨ姹傛暟鎹悓姝ュ埌鎵€鏈夎妭鐐癸紝涔熷彲浠ヨ姹傚悓姝ュ埌鎸囧畾鏁伴噺鐨勮妭鐐癸紝褰撹妭鐐瑰啀娆″垱寤洪槦鍒楁椂锛屽簲鐢ㄨ绛栫暐浼氳嚜鍔ㄥ皢鏁版嵁鍚屾鍒板叾浠栬妭鐐广€傝繖鏍风殑璇濓紝濂藉鏄鏋滀綘鏈変换浣曚竴鍙版満鍣ㄥ畷鏈轰簡锛屾病鍏崇郴锛屽叾浠栨満鍣紙鑺傜偣锛変篃鍖呭惈杩欎釜闃熷垪鐨勫畬鏁存暟鎹紝鍏朵粬娑堣垂鑰呭彲浠ュ幓鍏朵粬鑺傜偣娑堣垂鏁版嵁銆傜己鐐规槸锛岀涓€锛屾€ц兘寮€閿€澶珮銆傛秷鎭渶瑕佸悓姝ュ埌鎵€鏈夋満鍣紝鍘嬪姏澶э紝缃戠粶甯﹀娑堣€楀ぇ锛佺浜岋紝杩欑鐜╂硶涓嶆槸鍒嗗竷寮忕殑锛屽畬鍏ㄦ病鏈夊彲鎵╁睍鎬с€傚鏋滀竴涓槦鍒楄礋杞藉緢閲嶏紝浣犲鍔犳満鍣紝鏂板鍔犵殑鏈哄櫒涔熷寘鍚簡杩欎釜闃熷垪鐨勬墍鏈夋暟鎹紝娌℃湁鍔炴硶绾挎€ф墿灞曘€備綘鐨勯槦鍒椼€備綘鎯筹紝濡傛灉杩欎釜闃熷垪鐨勬暟鎹噺澶у埌鏈満鐨勫閲忔棤娉曞绾筹紝杩欐椂鍊欐€庝箞鍔炲憿锛烱afka鐨勯珮鍙敤Kafka鏈€鍩烘湰鐨勬灦鏋勭悊瑙ｏ細鐢卞涓猙roker缁勬垚锛屾瘡涓猙roker鏄竴涓妭鐐癸紱浣犲垱寤轰竴涓猼opic锛宼opic鍙互鍒嗕负澶氫釜partition锛屾瘡涓猵artition鍙互瀛樺湪浜庝笉鍚岀殑broker涓娿€傛瘡涓垎鍖烘斁涓€閮ㄥ垎鏁版嵁銆傝繖鏄竴涓ぉ鐒剁殑鍒嗗竷寮忔秷鎭槦鍒楋紝涔熷氨鏄涓€涓猼opic鐨勬暟鎹槸鍒嗘暎鍦ㄥ鍙版満鍣ㄤ笂鐨勶紝姣忓彴鏈哄櫒鏀句竴閮ㄥ垎鏁版嵁銆傚叾瀹濺abbmitMQ涔嬬被鐨勯兘涓嶆槸鍒嗗竷寮忔秷鎭槦鍒椼€傚畠浠槸浼犵粺鐨勬秷鎭槦鍒椼€傚畠浠彧鏄彁渚涗簡涓€浜涢泦缇ゅ拰HA锛圚ighAvailability锛岄珮鍙敤鎬э級鏈哄埗锛屽洜涓烘棤璁烘€庝箞鐜╋紝RabbitMQ閮芥槸涓€涓槦鍒楋紝鏁版嵁瀛樺偍鍦ㄤ竴涓妭鐐逛笂銆傚湪闀滃儚闆嗙兢涓嬶紝姣忎釜鑺傜偣涔熷瓨鍌ㄤ簡闃熷垪鐨勫畬鏁存暟鎹€侹afka0.8涔嬪墠鏄病鏈塇A鏈哄埗鐨勶紝灏辨槸浠讳綍涓€涓猙roker鎸備簡锛岄偅涓猙roker涓婄殑partition灏变細琚簾鎺夛紝鏃犳硶璇诲啓锛屾病鏈夐珮鍙敤鍙█銆傛瘮濡傛垜浠亣璁惧垱寤轰簡涓€涓猼opic锛屾寚瀹歱artition鐨勪釜鏁颁负3锛屽垎鍒湪涓夊彴鏈哄櫒涓娿€備絾鏄紝濡傛灉绗簩鍙版満鍣ㄥ畷鏈猴紝topic鐨?/3鐨勬暟鎹氨浼氫涪澶憋紝杩欐牱灏辨棤娉曞仛鍒伴珮鍙敤浜嗐€侹afka0.8涔嬪悗锛屾彁渚涗簡HA鏈哄埗锛屼篃灏辨槸鍓湰锛坮eplica锛夊鍒舵満鍒躲€傛瘡涓垎鍖虹殑鏁版嵁閮戒細鍚屾鍒板叾浠栨満鍣ㄤ笂锛屽舰鎴愯嚜宸辩殑澶氫釜replica鍓湰銆傛墍鏈夌殑replica閮戒細閫夊嚭涓€涓猯eader锛岀劧鍚庣敓浜у拰娑堣垂閮戒細璺熻繖涓猯eader鎵撲氦閬擄紝鐒跺悗鍏朵粬鐨剅eplica閮芥槸follower銆傚啓鐨勬椂鍊檒eader浼氳礋璐ｆ妸鏁版嵁鍚屾缁欐墍鏈夌殑follower锛岃鐨勬椂鍊欑洿鎺ヨ鍙杔eader涓婄殑鏁版嵁鍗冲彲銆傚彧鑳借鍐檒eader锛熻繖寰堢畝鍗曘€傚鏋滀綘鍙互闅忔剰璇诲啓姣忎釜follower锛屼綘灏卞緱娉ㄦ剰鏁版嵁鐨勪竴鑷存€с€傜郴缁熷鏉傚害澶珮锛屽鏄撳嚭閿欍€侹afka浼氬皢涓€涓猵artition鐨勬墍鏈塺eplicas骞冲潎鍒嗗竷鍦ㄤ笉鍚岀殑鏈哄櫒涓婏紝浠庤€屾彁楂樺閿欒兘鍔涖€傝繖鏍峰氨鏈夋墍璋撶殑楂樺彲鐢ㄤ簡锛屽洜涓哄鏋滄煇涓猙roker瀹曟満浜嗭紝娌″叧绯伙紝閭ｄ釜broker涓婄殑partition鍦ㄥ叾浠栨満鍣ㄤ笂鏈夊壇鏈€傚鏋渄ownbroker涓婃湁partitionleader锛岄偅涔堟鏃朵細浠巉ollowers涓噸鏂伴€変妇鍑烘柊鐨刲eader锛屽ぇ瀹跺彲浠ョ户缁鍐欐柊鐨刲eader銆傝繖绉颁负楂樺彲鐢ㄦ€с€傚啓鍏ユ暟鎹椂锛宲roducer鍐欏叆leader锛岀劧鍚巐eader灏嗘暟鎹啓鍏ユ湰鍦扮鐩橈紝鐒跺悗鍏朵粬follower涓诲姩浠巐eader鎷夊彇鏁版嵁銆備竴鏃︽墍鏈夌殑follower閮藉悓姝ヤ簡鏁版嵁锛屽氨浼氬悜leader鍙戦€乤ck銆俵eader鏀跺埌鎵€鏈塮ollower鐨刟ck鍚庯紝浼氬悜producer杩斿洖鍐欏叆鎴愬姛鐨勪俊鎭€傦紙褰撶劧锛岃繖鍙槸鍏朵腑涓€绉嶆ā寮忥紝杩欎釜琛屼负鍙互閫傚綋璋冩暣銆傦級娑堣垂鏃讹紝鍙細浠巐eader涓鍙栵紝浣嗗彧鏈夊綋涓€鏉℃秷鎭凡缁忚鎵€鏈塮ollower鍚屾鎴愬姛杩斿洖ack鏃讹紝灏嗛槄璇绘娑堟伅銆傛秷璐硅€呴槄璇汇€?/p>
