---

程序員的公眾號：源1024，獲取更多資料，無加密無套路！

最近整理了一波電子書籍資料，包含《Effective Java中文版 第2版》《深入JAVA虛擬機》，《重構(gòu)改善既有代碼設(shè)計》，《MySQL高性能-第3版》，《Java并發(fā)編程實戰(zhàn)》等等
獲取方式: 關(guān)注公眾號并回復(fù) 電子書 領(lǐng)取，更多內(nèi)容持續(xù)奉上

---

RocketMQ是阿里開源的一款非常優(yōu)秀的消息中間件，支持事務(wù)消息、順序消息、批量消息、定時消息、消息回溯等，天然的支持集群模型、負(fù)載均衡、水平擴展能力，億級別的消息堆積能力。

RocketMQ主要由 Producer、Broker、Consumer 三部分組成，其中Producer 負(fù)責(zé)生產(chǎn)消息，Consumer 負(fù)責(zé)消費消息，Broker 負(fù)責(zé)存儲消息。

使用場景：

• 異步通信：RocketMQ 可以在不同的應(yīng)用程序之間進行異步通信，從而提高系統(tǒng)的可伸縮性和響應(yīng)速度，減少多個模塊之間的依賴性。

• 延時消息：比如處理訂單超時關(guān)閉功能，30分鐘還沒支付的訂單就自動關(guān)閉。

• 數(shù)據(jù)分發(fā)：A系統(tǒng)將消息發(fā)送到RocketMQ隊列，其他系統(tǒng)如果有需要就去消費。

• 應(yīng)用解耦：通過RocketMQ作為中介，生產(chǎn)方與消費方通過消息進行交互，減少模塊之間的耦合性。

• 削峰填谷：RocketMQ 可以用于平滑處理流量峰值，將高并發(fā)請求緩沖并逐漸處理，以防止系統(tǒng)過載。例如，雙11活動，秒殺活動、搶紅包等，通過RocketMQ的削峰填谷能力，平穩(wěn)流量峰值，避免系統(tǒng)壓力過大。

• 順序消息：適用于需要保證多條消息順序處理的場景，例如證券交易、訂單創(chuàng)建、支付、退款等流程，消息有序只限定在同一個queue中。

• 日志收集：統(tǒng)一收集業(yè)務(wù)日志，消息隊列作為日志數(shù)據(jù)的中轉(zhuǎn)站。并且，RocketMQ 的流式計算框架非常適合與大數(shù)據(jù)框架集成，如 Apache Hadoop 和 Flink 等，用于構(gòu)建實時數(shù)據(jù)流處理。

?系列文章索引

MyBatis的插件能在哪些地方進行攔截？

了解MyBatis的緩存機制嗎

面試官：談?wù)剬olatile的理解

Spring中用到了哪些設(shè)計模式

面試官：說一下SQL的執(zhí)行過程

線程池的工作原理