Kafka(一)

一:簡介

解決高吞吐量項目的需求

是一款為大數據而生的消息中間件,具有百億級tps的吞吐量,在數據采集、傳輸、存儲的過程中發揮著作用

二:為什么要使用消息隊列

一個普通訪問量的接口和一個大并發的接口,它們背后的設計邏輯是不同的

同步的通信方式:

-系統開銷(響應時間)較大

-在同步的過程中要保證每個服務都順利執行完,整個鏈路才執行完,因為網絡等問題,整個鏈路成功執行的成功率會受影響

同步的通信方式存在性能和穩定性的問題

異步的通信方式:

-明顯提升系統的吞吐量

-即使有服務失敗,也可以通過分布式事務解決方案來保證最終的成功

相對于同步的通信方式,異步,可以讓上游快速成功,極大提高系統的吞吐量。在分布式系統中,通過下游多個服務的分布式事務的保障,也能保障業務執行之后的最終一致性

消息隊列解決的就是通信的問題

三、消息隊列的流派

消息隊列的中間件選型有很多種:

  • rabbitMQ:內部的可玩性(功能性)是非常強的

  • rocketMQ: 阿里內部一個大神,根據kafka的內部執行原理,手寫的一個消息隊列中間 件。性能是與Kafka相比肩,除此之外,在功能上封裝了更多的功能。

  • kafka:全球消息處理性能最快的一款MQ

  • zeroMQ

它們之間的區別

1. 有broker

重topic:Kafka、RocketMQ、ActiveMQ 整個broker,依據topic來進行消息的中轉。在重topic的消息隊列里必然需要topic的存在

輕topic:RabbitMQ topic只是一種中轉模式。

2.無broker

在生產者和消費者之間沒有使用broker,例如zeroMQ,直接使用socket進行通信。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/168009.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/168009.shtml
英文地址,請注明出處:http://en.pswp.cn/news/168009.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

C/C++---------------LeetCode第1512. 好數對的數目

好數對的數目 題目及要求暴力算法哈希算法在main內使用 題目及要求 給你一個整數數組 nums 。 如果一組數字 (i,j) 滿足 nums[i] nums[j] 且 i < j &#xff0c;就可以認為這是一組 好數對 。 返回好數對的數目。 示例 1&#xff1a; 輸入&#xff1a;nums [1,2,3,1,…

376.擺動序列

原題鏈接&#xff1a;376.擺動序列 全代碼&#xff1a; class Solution { public:int wiggleMaxLength(vector<int>& nums) {if (nums.size() < 1) return nums.size();int curDiff 0; // 當前一對差值int preDiff 0; // 前一對差值int result 1; // 記錄峰…

Android骨架圖

用法&#xff1a;在圖片上實現動畫效果 <FrameLayoutandroid:id"id/image_container"android:layout_width"match_parent"android:layout_height"wrap_content"><ImageViewandroid:id"id/ivBlank"android:layout_width"…

PostgreSQL Patroni 3.0 新功能規劃 2023年 紐約PG 大會 (音譯)

開頭還是介紹一下群&#xff0c;如果感興趣PolarDB ,MongoDB ,MySQL ,PostgreSQL ,Redis, Oceanbase, Sql Server等有問題&#xff0c;有需求都可以加群群內有各大數據庫行業大咖&#xff0c;CTO&#xff0c;可以解決你的問題。加群請聯系 liuaustin3 &#xff0c;&#xff08;…

React Hooks函數之useRef

useRef 是 React 中常用的 Hook 之一&#xff0c;它返回一個可變的 ref 對象&#xff0c;其 .current 屬性被初始化為傳入的參數&#xff08;initialValue&#xff09;。返回的 ref 對象在組件的整個生命周期內保持不變。 以下是一些使用 useRef 的場景和示例&#xff1a; 1、…

Mathorcup數學建模競賽第一屆-【媽媽杯】B題:圖像識別

目錄 知識儲備 傳統圖像處理方法進行瑕疵檢測 傳統算法方向的選擇 瑕疵檢測關注的兩個問題 瑕疵的標注

【技術分享】RK3399 Ubuntu通過Python實現錄音和播放功能

?本文基于IDO-SBC3968 Ubuntu 系統通過Python腳本實現錄音和播放功能。 IDO-SBC3968采用RK3399國產六核64位CPU高性能處理器&#xff0c;支持4K HDMI2.0顯示&#xff0c;接口豐富&#xff0c;擁有千兆以太網&#xff0c;全協議TypeC接口&#xff0c;USB3.0 &#xff0c;eDP 和…

Redis高并發緩存架構

前言&#xff1a; 針對緩存我們并不陌生&#xff0c;而今天所講的是使用redis作為緩存工具進行緩存數據。redis緩存是將數據保存在內存中的&#xff0c;而內存的珍貴性是不可否認的。所以在緩存之前&#xff0c;我們需要明確緩存的對象&#xff0c;是否有必要緩存&#xff0c;怎…

ElasticSearch之配置

ElasticSearch主要的配置文件&#xff0c;如下&#xff1a; elasticsearch.yml&#xff0c;ElasticSearch的相關參數。jvm.options&#xff0c;JVM的相關參數。log4j2.properties&#xff0c;日志的相關參數。 默認情況下&#xff0c;ElasticSearch從$ES_HOME/config目錄下讀…

1 動態規劃解不同的子序列

來源&#xff1a; LeetCode第115題 難度&#xff1a; 困難 問題描述 給定一個字符串S和一個字符串t&#xff0c;計算在S的子序列中t出現的個數。 注解&#xff1a; 字符串的一個子序列是指&#xff0c;通過刪除一些(也可以不刪除)字符且不干擾剩余字符的相對位置所組成的…

2022年03月 Scratch(三級)真題解析#中國電子學會#全國青少年軟件編程等級考試

Scratch等級考試(1~4級)全部真題?點這里 一、單選題(共25題,每題2分,共50分) 第1題 以下四個選項中,運行哪個積木塊,可能得到523這個數值? A: B: C: D: 答案:B 四個選項都遵循統一的公式:隨機數ⅹ10+3=523,因此可以得出隨

ZXing創建二維碼位圖

Android生成二維碼通常使用ZXing庫&#xff0c;其中提供了QRCodeWriter類。QRCodeWriter可將字符串編譯為位矩陣BitMatrix&#xff0c;然后我們可以將位矩陣轉為Int數組&#xff0c;通過bitmap.setPixels()方法將數組繪制于位圖上。 1. 添加依賴 //Gradle Scripts -> buil…

和數集團出席中科院上海高研院?第三十三期“高研交叉論壇”信息能源融合專場

2023年11月21日&#xff0c;中國科學院上海高等研究院第三十三期“高研交叉論壇”信息能源融合專場在上海高研院成功舉辦。本次論壇由中國科學院上海高等研究院智能信息通信技術研究與發展中心、中國科學院低碳轉化科學與工程重點實驗室、中科院和數智能區塊鏈與能源系統應用聯…

【文末送書】機器學習高級實踐

2023年初是人工智能爆發的里程碑式的重要階段&#xff0c;以OpenAI研發的GPT為代表的大模型大行其道&#xff0c;NLP領域的ChatGPT模型火爆一時&#xff0c;引發了全民熱議。而最新更新的GPT-4更是實現了大型多模態模型的飛躍式提升&#xff0c;它能夠同時接受圖像和文本的輸入…

仿 美圖 / 餓了么,店鋪詳情頁功能

前言 UI有所不同&#xff0c;但功能差不多&#xff0c;商品添加購物車功能 正在寫&#xff0c;寫完會提交倉庫。 效果圖一&#xff1a;左右RecyclerView 聯動 效果圖二&#xff1a;通過點擊 向上偏移至最大值 效果圖三&#xff1a;通過點擊 或 拖動 展開收縮公告 效果圖四&…

SpringBoot3核心原理

SpringBoot3核心原理 事件和監聽器 生命周期監聽 場景&#xff1a;監聽應用的生命周期 可以通過下面步驟自定義SpringApplicationRunListener來監聽事件。 ①、編寫SpringApplicationRunListener實現類 ②、在META-INF/spring.factories中配置org.springframework.boot.Sprin…

上市公司-股權性質數據(國企、央企)2003-2022年

上市公司-股權性質數據&#xff08;國企、央企&#xff09;是一個針對上市公司的數據集&#xff0c;主要涵蓋了A股公司股權性質的詳細信息&#xff0c;區分了公司是否為民營企業、國企或央企。這份數據集提供了每家上市公司的股權結構背景&#xff0c;對投資者、市場分析師和經…

Shell循環:for(二)

一、通過用戶列表文件創建用戶 需求&#xff1a;通過用戶列表文件創建用戶 [rootlocalhost ~]# cat user.txt qian yoa huang演示&#xff1a; [rootlocalhost ~]# vim foruser.sh #編寫腳本 #!/bin/bash for i in cat user.txt do useradd $i if [ $? -eq 0 ] thenech…

2023年亞太杯數學建模C題新能源汽車成品文章(思路模型代碼成品)

一、翻譯 新能源汽車是指采用先進的技術原理、新技術和新結構&#xff0c;以非常規車用燃料&#xff08;非常規車用燃料是指汽油和柴油以外的燃料(非常規車用燃料是指汽油和柴油以外的燃料&#xff09;&#xff0c;并集成了汽車動力控制和驅動等先進技術的汽車。新能源汽車包括…

C++入門第九篇---Stack和Queue模擬實現,優先級隊列

前言&#xff1a; 我們已經掌握了string vector list三種最基本的數據容器模板&#xff0c;而對于數據結構的內容來說&#xff0c;其余的數據結構容器基本都是這三種容器的延申和擴展&#xff0c;在他們的基礎上擴展出更多功能和用法&#xff0c;今天我們便來模擬實現一下C庫中…