6月iOS設(shè)備性能榜：M2穩(wěn)居榜首 A系列只能等一手3nm來救
沒有新品發(fā)布，自然iOS設(shè)備性能榜的上榜設(shè)備就沒有什么更替，僅僅只有跑分變化而產(chǎn)生的排名變動(dòng)，畢竟蘋果新品的發(fā)布節(jié)奏就是這樣的，一年下來也就幾個(gè)移動(dòng)端新品，不會(huì)像安卓廠商，一
消息隊(duì)列就是Message Queue，本質(zhì)就是一個(gè)保存消息的隊(duì)列。
如下圖所示：
圖片
消息隊(duì)列通常由一個(gè)中間件組件提供，它作為消息的中轉(zhuǎn)站，負(fù)責(zé)接收、存儲(chǔ)和轉(zhuǎn)發(fā)消息。發(fā)送者將消息發(fā)送到消息隊(duì)列中，接收者則從隊(duì)列中獲取消息進(jìn)行處理。
消息隊(duì)列的應(yīng)用場(chǎng)景，主要包含：異步、解耦、削峰等，如下圖所示：
圖片
發(fā)送方和接收方不需要直接進(jìn)行實(shí)時(shí)的通信，而是通過消息隊(duì)列中間件進(jìn)行異步的消息傳遞
消息隊(duì)列可以將發(fā)送方和接收方解耦，使得它們可以獨(dú)立地進(jìn)行開發(fā)、部署和維護(hù)
圖片
主要會(huì)包含：生產(chǎn)者、Broker、消費(fèi)者...等。
生產(chǎn)者，主要負(fù)責(zé)發(fā)送消息，生產(chǎn)者將消息發(fā)送到消息隊(duì)列。
生產(chǎn)者根據(jù)業(yè)務(wù)邏輯生成消息，這些消息包含各種數(shù)據(jù)，例如：用戶請(qǐng)求、系統(tǒng)事件、日志記錄...等。
消費(fèi)的類型：消息可以是文本、JSON、XML、或其他格式的......數(shù)據(jù)。
Broker：主要負(fù)責(zé)接收、存儲(chǔ)和轉(zhuǎn)發(fā)消息，通常具有持久化機(jī)制，確保消息不丟失。
Broker還將消息分發(fā)給合適的消費(fèi)者，可以通過輪詢、負(fù)載均衡...等方式進(jìn)行調(diào)度。
以及，Broker需要等待消費(fèi)者確認(rèn)消息已被成功處理，然后才會(huì)將該消息從隊(duì)列中移除，確保消息不被丟失。
消費(fèi)者是消息的接收者和處理者，它從消息隊(duì)列中讀取消息，并執(zhí)行相應(yīng)的業(yè)務(wù)邏輯。
消費(fèi)者從Broker中讀取消息，可以是主動(dòng)拉取（Pull）、或被動(dòng)推送（Push）模式。
處理完成后，消費(fèi)者需要向Broker發(fā)送確認(rèn)信息，通知Broker該消息已被成功處理。
如果沒有確認(rèn)，消息可以重新投遞，確保處理的可靠性。
消息隊(duì)列主要包含兩種：一個(gè)是點(diǎn)對(duì)點(diǎn)，一個(gè)是發(fā)布訂閱模型。
圖片
點(diǎn)對(duì)點(diǎn)的特點(diǎn)：每個(gè)消息只有一個(gè)消費(fèi)者（Consumer），即一旦被消費(fèi)，消息就不再在消息隊(duì)列中。
發(fā)布訂閱模型包含三個(gè)角色：主題（Topic）、發(fā)布者（Publisher）、訂閱者（Subscriber）。
如下圖所示：
圖片
消息協(xié)議是消息隊(duì)列中間件的重要組成部分，決定了消息的格式、傳輸方式、和通信規(guī)則。
Java Message Service（JMS）是Java平臺(tái)上用于消息通信的標(biāo)準(zhǔn)API，提供了一種通用的方式來創(chuàng)建、發(fā)送、接收和讀取消息。
比如：老牌的ActiveMQ，就是典型的JMS實(shí)現(xiàn)。
AMQP，全程是“Advanced Message Queuing Protocol”，是一種開放標(biāo)準(zhǔn)的應(yīng)用層協(xié)議。
特點(diǎn)是：
rabbitmq，就是典型的AMQP的實(shí)現(xiàn)。
Message Queuing Telemetry Transport（MQTT），是一種輕量級(jí)的發(fā)布/訂閱消息協(xié)議，設(shè)計(jì)用于低帶寬、高延遲、或不可靠的網(wǎng)絡(luò)環(huán)境。
常見的消息隊(duì)列有：ActiveMQ、RocketMQ、Kafka、Pulsar、RabbitMQ等等。
如下圖所示：
圖片
選型比較
ActiveMQ | JMS，多協(xié)議支持 | 成熟穩(wěn)定，功能豐富，多語言支持 | 性能有限，管理復(fù)雜 | 中小規(guī)模企業(yè)應(yīng)用，需要JMS功能支持的場(chǎng)景 |
RocketMQ | 高性能，強(qiáng)事務(wù)消息，分布式架構(gòu) | 高吞吐量低延遲，分布式，強(qiáng)一致性 | 社區(qū)支持少，運(yùn)維復(fù)雜 | 互聯(lián)網(wǎng)和金融系統(tǒng)，高吞吐量和嚴(yán)格一致性場(chǎng)景 |
Kafka | 高吞吐量，日志式存儲(chǔ)，分區(qū)和復(fù)制 | 高性能，可擴(kuò)展，生態(tài)系統(tǒng)豐富 | 延遲較高，不支持事務(wù)消息 | 大數(shù)據(jù)處理，實(shí)時(shí)流處理，需要高吞吐和擴(kuò)展性場(chǎng)景 |
Pulsar | 多租戶，分層架構(gòu)，原生流處理 | 高性能，持久化存儲(chǔ)，靈活擴(kuò)展 | 學(xué)習(xí)曲線陡，社區(qū)和生態(tài)系統(tǒng)較小 | 云環(huán)境和企業(yè)系統(tǒng)，多租戶和高性能消息傳遞場(chǎng) |
RabbitMQ | 基于AMQP，靈活路由，豐富插件 | 易于使用，功能豐富，多語言支持 | 性能有限，集群管理復(fù)雜 | 中小規(guī)模企業(yè)應(yīng)用，復(fù)雜路由和消息確認(rèn)場(chǎng)景 |
互聯(lián)網(wǎng)和金融系統(tǒng)，高吞吐量和嚴(yán)格一致性場(chǎng)景，可以選擇：RocketMQ;
中小規(guī)模企業(yè)應(yīng)用，復(fù)雜路由、和消息確認(rèn)場(chǎng)景，可以選擇：RabbitMQ;
大數(shù)據(jù)處理，實(shí)時(shí)流處理，需要高吞吐、和擴(kuò)展性場(chǎng)景，可以選擇Kafka。
本文鏈接：http://www.www897cc.com/showinfo-26-100465-0.html消息隊(duì)列中間件詳解，你學(xué)會(huì)了嗎？
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)