『壹』 鍥涚嶆秷鎮涓闂翠歡鍒嗘瀽浠嬬粛錛圓ctiveMQ銆丷abbitMQ銆丷ocketMQ銆並afka
娣卞叆鎺㈢儲錛氬洓縐嶆秷鎮涓闂翠歡鐨勫崜瓚婁箣鏃
涓銆佹秷鎮涓闂翠歡鐨勫熀鐭
娑堟伅涓闂翠歡鏄杞浠舵灦鏋勪腑鐨勫叧閿緇勪歡錛屽畠浠閫氳繃瑙ｈ︺佸紓姝ュ勭悊鍜屽墛宄扮瓥鐣ワ紝璁╃郴緇熼棿閫氫俊鏇翠負楂樻晥銆傚畠浠灝嗗簲鐢ㄧ▼搴忎箣闂寸殑鐩存帴浜や簰杞鍖栦負鍒嗗竷寮忔秷鎮浼犻掞紝瀹炵幇浠誨姟寮傛ユ墽琛岋紝闄嶄綆鐢ㄦ埛絳夊緟錛屽悓鏃跺湪楂樺嘲嫻侀噺涓嬩繚鎸佺郴緇熺殑紼沖畾榪愯屻
浜屻佹妧鏈鐗規т笌鎸戞垬
灝界℃秷鎮涓闂翠歡騫挎硾搴旂敤浜庡悇縐嶅満鏅錛屼絾瀹冧滑涔熶即闅忕潃鎸戞垬銆備竴鏂歸潰錛屽畠浠鎻愪緵浜嗗己澶х殑鐏墊椿鎬у拰鎬ц兘錛屾敮鎸丣MS1.1鍗忚鐨凙ctiveMQ鑳藉熷勭悊涓囩駭鍚炲悙閲忋傜劧鑰岋紝楂樺彲鐢ㄦу彲鑳界壓鐗蹭竴閮ㄥ垎緋葷粺鎬ц兘錛屽俁abbitMQ鐨勪綆寤惰繜鐗規э紝鍚屾椂澶嶆潅搴︽彁鍗囷紝鍙鑳藉艱嚧緇存姢鎴愭湰涓婂崌錛屼互鍙婃綔鍦ㄧ殑涓鑷存ч棶棰樸
涓夈佸洓澶ф槑鏄熶腑闂翠歡
1.
ActiveMQ - 浣滀負寮婧怞MS鐨勪唬琛錛屽畠鎻愪緵浜嗕赴瀵岀殑鍔熻兘錛屽寘鎷鍙戝竷-璁㈤槄鍜岀偣瀵圭偣閫氫俊錛屼互鍙婂氱嶆秷鎮鎸佷箙鍖栭夐」錛圝DBC銆丄MQ銆並ahaDB銆丩evelDB錛夛紝紜璁ゆ満鍒剁伒媧誨氭牱銆
2.
RabbitMQ - 鍩轟簬AMQP鐨勪紒涓氱駭瑙ｅ喅鏂規堬紝鍏禖hannel銆丳rocer鍜孋onsumer鐨勮掕壊娓呮櫚錛屾敮鎸佺畝鍗曢槦鍒椼佸伐浣滈槦鍒楃瓑澶氱嶆ā寮忥紝鐗瑰埆鏄鍏墮暅鍍忛泦緹ゆā寮忕『淇濅簡楂樺彲鐢ㄦс
3.
RockeMQ - 闃塊噷宸村反鐨勫紑婧愪駭鍝侊紝寮鴻皟楂樺悶鍚愬拰澶ф暟鎹澶勭悊錛屾敮鎸佷簨鍔″拰欏哄簭鎬э紝閫氳繃闆嗙兢鍜屽箍鎾妯″紡瀹炵幇娑堟伅浼犻掋
4.
Kafka - 嫻佸勭悊棰嗗煙鐨勭繕妤氾紝鍏跺垎鍖哄拰澶氬壇鏈璁捐′繚璇佷簡楂樺彲鐢ㄥ拰鏁版嵁鎸佷箙鎬э紝鐢熶駭鑰呭拰娑堣垂鑰呯殑澶氱嶆ā寮忕『淇濅簡娑堟伅鐨勬ｇ『娑堣垂銆
鍥涖侀儴緗蹭笌浼樺寲絳栫暐
姣忎釜涓闂翠歡鍦ㄩ儴緗叉椂閮芥湁鍏剁壒瀹氳冮噺錛屽侫ctiveMQ鐨勫崟鑺傜偣閮ㄧ講涓嶆敮鎸侀珮鍙鐢錛岃孯abbitMQ鐨勯暅鍍忛泦緹ゆā寮忔彁渚涗簡涓縐嶅鉤琛℃ц兘鍜岄珮鍙鐢ㄦх殑閫夋嫨銆俁ocketMQ鐨勫歁aster澶歋lave妯″紡鍦ㄥ勭悊澶氳妭鐐規椂闇娉ㄦ剰娑堟伅瀹炴椂鎬э紝Kafka鍒欓氳繃replica鏈哄埗澧炲己瀹歸敊鑳藉姏銆
浜斻佸叧閿鐗規т笌瀹炶返
-
閲嶅嶆秷璐逛笌騫傜瓑鎬: 娑堟伅闃熷垪濡侹afka闇娉ㄦ剰閲嶅嶆秷璐癸紝閫氳繃offset鏈哄埗鍜屽籙絳夋ц捐＄『淇濅笟鍔℃ｇ『鎬с
-
欏哄簭鎬т繚璇: ActiveMQ鍗曢槦鍒椾繚璇佹秷鎮欏哄簭錛孯abbitMQ閫氳繃鍐呭瓨闃熷垪鍜寃orker澶勭悊瀹炵幇銆
-
娑堟伅涓㈠け澶勭悊: 閫氳繃紜璁ゆ満鍒躲佹寔涔呭寲瀛樺偍鍜屾暟鎹搴撹緟鍔╄板綍錛岀『淇濇秷鎮涓嶄細涓㈠け銆
鍏銆佸︿範涓庡疄璺佃礬寰
鐞嗚В娑堟伅涓闂翠歡鐨勬牳蹇冨師鐞嗭紝鎺屾彙楂樺彲鐢ㄣ佹暟鎹涓鑷存с侀噸澶嶆秷鎮澶勭悊絳夊叧閿姒傚康錛屾槸浣跨敤瀹冧滑鎴愬姛鐨勫叧閿銆傞殢鐫鎶鏈鐨勫彂灞曪紝涓嶆柇瀛︿範鍜屼紭鍖栦綘鐨勬灦鏋勶紝浠ラ傚簲涓嶆柇鍙樺寲鐨勪笟鍔￠渶奼傘
鎬葷粨
娑堟伅涓闂翠歡鍦ㄥ疄鐜扮郴緇熻В鑰﹀拰鎬ц兘浼樺寲鏂歸潰琛ㄧ幇鍑鴻壊錛屼絾鍚屾椂涔熼渶瑕佸勭悊濂界淮鎶ゆ垚鏈銆佷竴鑷存у拰鏁版嵁涓㈠け絳夐棶棰樸傞夋嫨鍚堥傜殑涓闂翠歡錛岀粨鍚堜笟鍔″満鏅榪涜屽閥濡欑殑鏋舵瀯璁捐★紝鏄紜淇濈郴緇熺ǔ瀹氶珮鏁堣繍琛岀殑鍩虹煶銆