柚子快報(bào)邀請(qǐng)碼778899分享：rabbitmq 1.MQ介紹

http://yzkb.51969.com/

MQ

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

為啥學(xué)習(xí)MQ

1.流量消峰

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

2.應(yīng)用解耦

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

3.異步處理

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

傳統(tǒng)方式：

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

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

使用消息隊(duì)列：

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

MQ的分類

1.ActiveMQ

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

2.Kafka

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

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

Kafka Web管理界面Kafka-Manager。

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

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

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

3.RocketMQ

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

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

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

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

4.RabbitMQ

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

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

缺點(diǎn)：商業(yè)版需要收費(fèi)，學(xué)習(xí)成本高。

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

柚子快報(bào)邀請(qǐng)碼778899分享：rabbitmq 1.MQ介紹

http://yzkb.51969.com/

推薦文章