引用

博文連接，很好的一篇博客，列舉了消息隊(duì)列的使用場(chǎng)景和場(chǎng)景消息隊(duì)列的基本概念，并貼上了收集的博文資料。

消息隊(duì)列使用場(chǎng)景

　　息隊(duì)列基本使用場(chǎng)景有四種，分別是異步處理、應(yīng)用解耦、流量削峰和日志處理等。
　　解耦和異步處理往往相輔相成，比如兩個(gè)系統(tǒng)之間放入消息隊(duì)列，不僅可以解耦開(kāi)，而且相應(yīng)的業(yè)務(wù)邏輯也可以實(shí)現(xiàn)異步處理，最典型的就是用戶注冊(cè)

一、二.異步處理和應(yīng)用解耦，見(jiàn)上圖

三.流量削峰

　　在秒殺或者搶購(gòu)過(guò)程中，一般都會(huì)在短時(shí)間產(chǎn)生巨大的流量，此時(shí)便可以在用戶請(qǐng)求與業(yè)務(wù)處理之間放入消息隊(duì)列，以控制請(qǐng)求人數(shù)。比如在搶紅包應(yīng)用中，消息隊(duì)列的長(zhǎng)度為紅包個(gè)數(shù)，在隊(duì)列傳入的請(qǐng)求即可視為無(wú)效。

四.日志處理,以Kafka為例

４.１基本概念

　?。保〣roker：Kafka包含一個(gè)或多個(gè)服務(wù)器，這些服務(wù)器被稱為Broker；
　　2）Topic：每條發(fā)布到Kafka上的消息都有一個(gè)類別，這個(gè)類別被稱為Topic，不同Topic的消息物理上分開(kāi)存儲(chǔ)；
　　3）Partition：物理概念，一個(gè)Topic包含多個(gè)Partition；
　　4）Producer：負(fù)責(zé)發(fā)布消息到Kafka Broker；
　　5）Consumer：消息消費(fèi)者，拉取Kafka Broker消息并處理的客戶端；
　　6）Consumer Grop：每個(gè)Consumer屬于一個(gè)特定的group，沒(méi)有指定則屬于默認(rèn)的group；

4.2使用場(chǎng)景

　　一般應(yīng)用于處理大數(shù)據(jù)級(jí)別的日志，并且對(duì)是實(shí)時(shí)性和可靠性有一定容忍度的場(chǎng)景。

4.3基本介紹及特性

　　Kafka是一種高吞吐量的分布式發(fā)布、訂閱消息系統(tǒng)，他可以處理消費(fèi)者規(guī)模的網(wǎng)站中的所有動(dòng)作流數(shù)據(jù)。Kafka的目的是通過(guò)Hadoop的并行加載機(jī)制來(lái)同一線上的和離線的消息處理，也是為了通過(guò)集群來(lái)提供濕濕的消費(fèi)。？？
　　Kafka提供持久化的磁盤結(jié)構(gòu)時(shí)間復(fù)雜度為O(1)、吞吐量高、資質(zhì)Hadoop秉性數(shù)據(jù)加載一級(jí)支持通過(guò)Kafka服務(wù)器和消費(fèi)機(jī)集群來(lái)區(qū)分消息。