摘要：
本文將講解如何在IDEA中導入 RocketMQ 源碼，并運行 Broker 和 NameServer，編寫一個消息發送與消息消費的示例。 一. 源碼導入及調試 1.1 導入源碼 RocketMQ 原先是阿里巴巴集團內部的消息中間件，于2016年提交至Apache基金會孵化，并最終成為Apache頂 閱讀全文
posted @ 2023-12-02 10:39
聽到微笑
閱讀(113)
評論(0)
推薦(0)
摘要：
一. 主從同步概述 主從同步這個概念相信大家在平時的工作中，多少都會聽到。其目的主要是用于做一備份類操作，以及一些讀寫分離場景。比如我們常用的關系型數據庫mysql，就有主從同步功能在。 主從同步，就是將主服務器上的數據同步到從服務器上，也就是相當于新增了一個副本。 而具體的主從同步的實現也各有千秋 閱讀全文
posted @ 2023-12-02 10:18
聽到微笑
閱讀(112)
評論(0)
推薦(0)
摘要：
RocketMQ提供了事務消息的功能，采用2PC(兩階段協議)+補償機制（事務回查）的分布式事務功能，通過這種方式能達到分布式事務的最終一致。 一. 概述 半事務消息：指的是發送至broker但是還沒被commit的消息，在半事務消息被確認之前都是無法被消費者消費的。消息回查：由于網絡閃斷、生產者應 閱讀全文
posted @ 2023-12-02 10:07
聽到微笑
閱讀(422)
評論(0)
推薦(0)
摘要：
#RocketMQ提供了2種消息過濾的方式： TAG 過濾 SQL92 過濾 SQL過濾默認是沒有打開的，如果想要支持，必須在broker的配置文件中設置：enablePropertyFilter = true 一. 示例代碼 1.1 producer 代碼 public class Produce 閱讀全文
posted @ 2023-12-02 09:55
聽到微笑
閱讀(280)
評論(0)
推薦(0)
浙公網安備 33010602011771號