‘壹’ 锲涚嶆秷鎭涓闂翠欢鍒嗘瀽浠嬬粛锛圆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澶勭悊瀹炵幇銆
-
娑堟伅涓㈠け澶勭悊: 阃氲繃纭璁ゆ満鍒躲佹寔涔呭寲瀛桦偍鍜屾暟鎹搴撹緟锷╄板綍锛岀‘淇濇秷鎭涓崭细涓㈠け銆
鍏銆佸︿範涓庡疄璺佃矾寰
鐞呜В娑堟伅涓闂翠欢镄勬牳蹇冨师鐞嗭纴鎺屾彙楂桦彲鐢ㄣ佹暟鎹涓镊存с侀吨澶嶆秷鎭澶勭悊绛夊叧阌姒傚康锛屾槸浣跨敤瀹冧滑鎴愬姛镄勫叧阌銆傞殢镌鎶链镄勫彂灞曪纴涓嶆柇瀛︿範鍜屼紭鍖栦綘镄勬灦鏋勶纴浠ラ傚簲涓嶆柇鍙桦寲镄勪笟锷￠渶姹伞
镐荤粨
娑堟伅涓闂翠欢鍦ㄥ疄鐜扮郴缁熻В钥﹀拰镐ц兘浼桦寲鏂归溃琛ㄧ幇鍑鸿壊锛屼絾钖屾椂涔熼渶瑕佸勭悊濂界淮鎶ゆ垚链銆佷竴镊存у拰鏁版嵁涓㈠け绛夐梾棰樸傞夋嫨钖堥傜殑涓闂翠欢锛岀粨钖堜笟锷″満鏅杩涜屽阀濡欑殑鏋舵瀯璁捐★纴鏄纭淇濈郴缁熺ǔ瀹氶珮鏁堣繍琛岀殑锘虹煶銆