RocketMQ 03

??今天是2025/04/14?21:58 day 20

總路線請移步主頁Java大綱相關文章

今天進行RocketMQ 6,7,8 個模塊的歸納

最近在忙畢設，更新有點慢，見諒

首先是RocketMQ 的相關內容概括的思維導圖

核心功能
- 權限分級：通過用戶（User）和密鑰（AccessKey/SecretKey）實現身份驗證，支持細粒度權限控制（如發布、訂閱、管理權限）。
- 資源隔離：可針對 Topic、Consumer Group 等資源設置訪問權限（白名單/黑名單）。
- IP 白名單：限制 Broker 或客戶端的訪問 IP，防止未授權節點接入。

配置示例

# Broker 開啟 ACL
aclEnable=true
# 配置 ACL 規則文件路徑
aclFile=/path/to/acl.yml

TLS/SSL 加密
- 通信加密：支持客戶端與 Broker 之間、Broker 主從節點之間的 TLS 加密傳輸。
- 證書管理：需配置 CA 證書、服務端證書和私鑰，防止中間人攻擊。
配置步驟
1. 生成證書（使用 OpenSSL 或購買商業證書）。
2. Broker 配置 TLS：
```
# 啟用 TLS
tlsEnable=true
tlsServerCertPath=/path/to/server.crt
tlsServerKeyPath=/path/to/server.key
```
3. 客戶端配置 TLS：在 Producer/Consumer 代碼中加載信任證書鏈。

場景說明
- 解決跨數據庫、跨服務的分布式事務問題（如銀行轉賬：A 賬戶扣款成功后，B 賬戶需同步到賬）。
RocketMQ 方案
- 事務消息機制：
  1. 發送 Half 消息（預提交）。
  2. 執行本地事務（如更新數據庫）。
  3. 根據本地事務結果提交或回滾消息。
- 事務回查：若 Producer 未及時提交狀態，Broker 主動回查事務結果，確保數據一致性。

場景說明
- 將業務系統數據實時同步到大數據平臺（如 Flink、Hadoop、Elasticsearch）。
技術實現
- RocketMQ Connect：內置多種數據源插件（MySQL、Kafka、HBase），實現低代碼數據同步。
- 與 Flink 集成：通過 RocketMQ-Flink Connector 實現流式計算。

核心依賴

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.2.3</version>
</dependency>

關鍵配置

rocketmq:name-server: 127.0.0.1:9876producer:group: my-producer-groupconsumer:group: my-consumer-group

注解驅動開發
- @RocketMQMessageListener：快速定義 Consumer。
- RocketMQTemplate：簡化消息發送（支持同步/異步/事務消息）。

功能定位
- 實現 RocketMQ 與異構系統（數據庫、文件系統、其他消息隊列）的數據雙向同步。
核心組件
- Source Connector：從外部系統拉取數據寫入 RocketMQ。
- Sink Connector：從 RocketMQ 消費數據寫入外部系統。
使用場景
- MySQL Binlog 實時同步到 Elasticsearch。
- Kafka 數據遷移到 RocketMQ。

輕量級流處理引擎

與 Flink 對比：

特性	RocketMQ Streams	Apache Flink
部署復雜度	輕量級，內嵌于 RocketMQ	需獨立集群，運維成本高
功能范圍	基礎流處理（適合簡單 ETL）	完整流批一體計算（復雜場景）

示例：統計訂單金額

SELECT order_id, SUM(amount) 
FROM orders 
GROUP BY TUMBLE(proctime, INTERVAL '1' MINUTE), order_id

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

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