小男孩‘自慰网亚洲一区二区,亚洲一级在线播放毛片,亚洲中文字幕av每天更新,黄aⅴ永久免费无码,91成人午夜在线精品,色网站免费在线观看,亚洲欧洲wwwww在线观看

分享

消息隊列四種應(yīng)用場景

 jackeyqing 2018-08-04

引用

博文連接,很好的一篇博客,列舉了消息隊列的使用場景和場景消息隊列的基本概念,并貼上了收集的博文資料。

消息隊列使用場景

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

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

三.流量削峰

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

四.日志處理,以Kafka為例

4.1基本概念

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

4.2使用場景

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

4.3基本介紹及特性

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

    本站是提供個人知識管理的網(wǎng)絡(luò)存儲空間,所有內(nèi)容均由用戶發(fā)布,不代表本站觀點。請注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息,謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請點擊一鍵舉報。
    轉(zhuǎn)藏 分享 獻花(0

    0條評論

    發(fā)表

    請遵守用戶 評論公約

    類似文章 更多