柚子快報邀請碼778899分享：rabbitmq 1.MQ介紹

http://yzkb.51969.com/

MQ

消息隊列，本質(zhì)是一個隊列，先進先出，只不過隊列中存放的內(nèi)容是message而已。

為啥學習MQ

1.流量消峰

如果一個訂單系統(tǒng)最多每秒能處理一萬次訂單，正常情況下我們下單1秒后就能返回結(jié)果。但是在高峰期，如果有兩萬次下單操作，系統(tǒng)是處理不了的，只能限制訂單超過一萬后不允許用戶下單。使用消息隊列做緩沖，我們可以取消一萬筆訂單的限制，把一秒內(nèi)下的訂單分散成一段時間來處理，通過排隊逐一處理消息，這時有些用戶可能在下單十幾秒后才能收到下單成功的操作，但是比不能下單的體驗要好。

2.應用解耦

電商應用為例，應用中有訂單系統(tǒng)、庫存系統(tǒng)、物流系統(tǒng)、支付系統(tǒng)。用戶創(chuàng)建訂單后，如果耦合調(diào)用庫存系統(tǒng)、物流系統(tǒng)、支付系統(tǒng)，任何一個子系統(tǒng)出現(xiàn)了故障，都會導致下單操作異常。當轉(zhuǎn)變成基于消息隊列的方式后，系統(tǒng)間調(diào)用的問題會減少很多。比如物流系統(tǒng)發(fā)生故障，需要幾分鐘來修復。在這幾分鐘時間里，物流系統(tǒng)要處理的內(nèi)存被緩存在消息隊列中，用戶的下單操作可以正常完成。當物流系統(tǒng)恢復后，繼續(xù)處理訂單信息即可。下單用戶感受不到物流系統(tǒng)的故障，提升系統(tǒng)的可用性。

3.異步處理

?如果A調(diào)用B，B需要花很長時間執(zhí)行。但是A需要指定B什么時候執(zhí)行完。

傳統(tǒng)方式：

1.A等一段時間去調(diào)用B的查詢api接口去查詢B是否執(zhí)行完。

2.A提供一個回調(diào)api接口，B執(zhí)行完后調(diào)用A的回調(diào)api通知A服務。

使用消息隊列：

A調(diào)用B后，只需要監(jiān)聽B處理完成的消息，當B處理完成后，會發(fā)送一條消息給MQ,MQ會將此消息轉(zhuǎn)發(fā)給A服務。這樣A服務既不能循環(huán)調(diào)用B的查詢api，也不用提供回調(diào)api。A服務還能及時的到異步處理成功的消息。

MQ的分類

1.ActiveMQ

比較老，維護少，很少使用高吞吐量場景。

2.Kafka

為大數(shù)據(jù)而生的消息中間件。百萬級TPS的吞吐量。性能卓越，單機寫入TPS越百萬條/s。

Kafka是分布式的，一個數(shù)據(jù)多個副本，少數(shù)機器宕機，不會丟失數(shù)據(jù)。

Kafka Web管理界面Kafka-Manager。

在日志領(lǐng)域比較成熟。大數(shù)據(jù)領(lǐng)域?qū)崟r計算以及日志采集應用廣泛。

缺點：Kafka單機超過64個隊列/分區(qū)，Load會發(fā)生明顯的飆高現(xiàn)象，隊列越多，load越高，發(fā)送消息的響應時長變長，消費失敗不支持重試，也就是容易丟失消息。支持消息順序，但是一臺代理宕機后，就會產(chǎn)生消息亂序，社區(qū)更新較慢。

適用場景：產(chǎn)生大量數(shù)據(jù)的數(shù)據(jù)收集業(yè)務，大型公司建議使用，是日志采集功能的首選。

3.RocketMQ

阿里巴巴開源產(chǎn)品，java語言編寫，設計時候參考了Kafka,并做出自己的改進。被阿里巴巴廣泛應用于訂單、交易、充值、流計算、消息推送、日志流式處理，binglog分發(fā)等場景。

單機吞吐量十萬級，可用性非常高，分布式架構(gòu)，消息可以做到0丟失，mq功能較為完善，還是分布式的，擴展性好，支持10億級別的消息堆積，不會因為堆積導致性能下降，源碼是java可以自己閱讀的源碼，定制自己公司的MQ。

缺點：支持的客戶語言不多，目前是java和C++，其中C++不成熟。社區(qū)活躍度一般，沒有在MQ核心中去實現(xiàn)JMS等接口，有些系統(tǒng)要遷移需要修改大量代碼。

適用場景：為金融互聯(lián)網(wǎng)領(lǐng)域而生，對于可靠性要求很高的場景，尤其是電商里面的訂單扣款，在大量交易涌入時，后端可能無法及時處理的情況。在阿里雙11已經(jīng)經(jīng)歷了多次考驗。高并發(fā)場景。

4.RabbitMQ

使用AMQP高級消息隊列協(xié)議基礎上完成的，可復用的企業(yè)消息系統(tǒng)，是最主流的消息中間件之一。由于erlang語言的高并發(fā)特性，性能較好。吞吐量到萬級，功能比較完備、健壯、穩(wěn)定、易用、跨平臺、支持多種語言：Python,Ruby,.NET,java,jms,c,php,ActionScript,xmpp,stomp等。

支持ajax文檔齊全，開源提供的管理界面非常好，社區(qū)活躍度高，更新頻率高。

缺點：商業(yè)版需要收費，學習成本高。

適用場景：erlang語言本身的并發(fā)優(yōu)勢，性能好，時效性微秒級，如果數(shù)據(jù)量沒那么大，中小型公司優(yōu)選。

柚子快報邀請碼778899分享：rabbitmq 1.MQ介紹

http://yzkb.51969.com/

推薦文章