rocketmq下載 - rocketmq原始碼下載

rocketmq

JAVA源碼

rocketmq-all-5.3.1

下載

Apache RocketMQ

Apache RocketMQ是一個分散式訊息和串流媒體平台，具有低延遲、高效能和可靠性、兆級容量和靈活的可擴展性。

它提供多種功能：

訊息傳遞模式包括發布/訂閱、請求/回覆和串流傳輸
金融級交易訊息
基於 DLedger Controller 的內建容錯和高可用性配置選項
內建訊息追蹤能力，也支援opentracing
多功能大數據和串流生態系統集成
按時間或偏移量追溯訊息
同一隊列中可靠的 FIFO 和嚴格有序的消息傳遞
高效率的拉推消費模式
單隊列百萬級訊息累積能力
多種訊息傳遞協議，例如 gRPC、MQTT、JMS 和 OpenMessaging
靈活的分散式橫向擴展部署架構
閃電般快速的批次訊息交換系統
SQL、Tag等多種訊息過濾機制
用於隔離測試和雲端隔離叢集的 Docker 映像
用於配置、指標和監控的功能豐富的管理儀表板
認證與授權
免費的開源連接器，適用於來源和接收器
輕量級即時運算

快速入門

本段將引導您以不同方式安裝 RocketMQ 的步驟。對於本機開發和測試，每個元件只會建立一個實例。

本地運行 RocketMQ

RocketMQ可以在所有主要作業系統上運行，並且只需要安裝Java JDK版本8或更高版本。要檢查，請運行java -version ：

$ java -version
java version " 1.8.0_121 "

對於Windows用戶，請點擊此處下載5.2.0 RocketMQ二進位版本，並將其解壓縮到本機磁碟，例如D:rocketmq 。對於 macOS 和 Linux 用戶，請執行以下命令：

 # Download release from the Apache mirror
$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip

# Unpack the release
$ unzip rocketmq-all-5.2.0-bin-release.zip

準備一個終端並切換到解壓縮的bin目錄：

$ cd rocketmq-all-5.2.0-bin-release/bin

1) 啟動名稱伺服器

NameServer 將監聽0.0.0.0:9876 ，確保本機上該連接埠沒有被其他人使用，然後執行下列操作。

對於 macOS 和 Linux 用戶：

 # ## start Name Server
$ nohup sh mqnamesrv &

# ## check whether Name Server is successfully started
$ tail -f ~ /logs/rocketmqlogs/namesrv.log
The Name Server boot success...

對於Windows用戶，需要先設定環境變數：

在桌面上，右鍵單擊計算機圖示。
從上下文選單中選擇屬性。
點擊高級系統設定連結。
按一下環境變數。
新增環境ROCKETMQ_HOME="D:rocketmq" 。

然後將目錄更改為 RocketMQ，輸入並運行：

$ mqnamesrv.cmd
The Name Server boot success...

2) 啟動經紀商

對於 macOS 和 Linux 用戶：

 # ## start Broker
$ nohup sh bin/mqbroker -n localhost:9876 &

# ## check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is broker-a
$ tail -f ~ /logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...

對於 Windows 使用者：

$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...

在 Docker 中運行 RocketMQ

您可以在自己的機器上的 Docker 容器中執行 RocketMQ， host網路將用於公開容器中的偵聽連接埠。

1) 啟動名稱伺服器

$ docker run -it --net=host apache/rocketmq ./mqnamesrv

2) 啟動經紀商

$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876

在 Kubernetes 中運行 RocketMQ

您也可以使用 RocketMQ Operator 在 Kubernetes 叢集中執行 RocketMQ 叢集。在進行操作之前，請確保您的機器上安裝了kubectl和相關的 kubeconfig 檔案。

1) 安裝 CRD

 # ## install CRDs
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy

# ## check whether CRDs is successfully installed
$ kubectl get crd | grep rocketmq.apache.org
brokers.rocketmq.apache.org                 2022-05-12T09:23:18Z
consoles.rocketmq.apache.org                2022-05-12T09:23:19Z
nameservices.rocketmq.apache.org            2022-05-12T09:23:18Z
topictransfers.rocketmq.apache.org          2022-05-12T09:23:19Z

# ## check whether operator is running
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj   1/1     Running   0          93s

2）建立叢集實例

 # ## create RocketMQ cluster resource
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml

# ## check whether cluster resources is running
$ kubectl get sts
NAME                 READY   AGE
broker-0-master      1/1     107m
broker-0-replica-1   1/1     107m
name-service         1/1     107m

Apache RocketMQ 社區

RocketMQ Streams：基於Apache RocketMQ的輕量級流運算引擎。
RocketMQ Flink：Apache Flink 的 Apache RocketMQ 連接器，支援資料流和表格中的來源連接器和接收器連接器。
RocketMQ API：RocketMQ protobuf 協定。
RocketMQ 用戶端：基於 gRPC/protobuf 的 RocketMQ 用戶端。
基於 RocketMQ 遠端處理的客戶端
- RocketMQ客戶端CPP
- RocketMQ客戶端Go
- RocketMQ 用戶端 Python
- RocketMQ 用戶端 Nodejs
RocketMQ Spring：幫助開發者快速將 Apache RocketMQ 與 Spring Boot 整合的專案。
RocketMQ Exporter：Prometheus 的 Apache RocketMQ 導出器。
RocketMQ Operator：提供一種在 Kubernetes 上執行 Apache RocketMQ 叢集的方法。
RocketMQ Docker：Apache RocketMQ 的 Docker 映像的 Git 儲存庫。
RocketMQ Dashboard：Apache RocketMQ的維運控制台。
RocketMQ Connect：一種用於在 Apache RocketMQ 和其他系統之間可擴展且可靠地傳輸資料的工具。
RocketMQ MQTT：全新的MQTT協定架構模型，基於此模型Apache RocketMQ可以更好地支援來自物聯網設備、手機APP等終端機的訊息。
RocketMQ EventBridge：EventBridge讓建立事件驅動的應用程式變得更加容易。
RocketMQ孵化社群計畫：Apache RocketMQ的孵化社群項目，包括logappender、rocketmq-ansible、rocketmq-beats-integration、rocketmq-cloudevents-binding等。
RocketMQ 網站：Apache RocketMQ 網站的儲存庫。
RocketMQ E2E：用於測試Apache RocketMQ的項目，包括端到端、效能、相容性測試。

了解並聯絡我們

電子郵件清單：https://rocketmq.apache.org/about/contact/
首頁：https://rocketmq.apache.org
文件：https://rocketmq.apache.org/docs/quick-start/
問題：https://github.com/apache/rocketmq/issues
撕裂：https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal
詢問：https://stackoverflow.com/questions/tagged/rocketmq
鬆弛：https://rocketmq-invite-automation.herokuapp.com/

貢獻

我們始終歡迎新的貢獻，無論是瑣碎的清理、重大的新功能或其他物質獎勵，更多詳細資訊請參閱此處。

執照

出口管制通知

該發行版包括加密軟體。您目前居住的國家/地區可能對加密軟體的進口、擁有、使用和/或再出口到其他國家/地區有限制。在使用任何加密軟體之前，請檢查您所在國家/地區有關進口、擁有或使用以及再出口加密軟體的法律、法規和政策，以了解是否允許這樣做。請參閱 http://www.wassenaar.org/ 以了解更多資訊。

美國政府商務部工業與安全局 (BIS) 已將此軟體分類為出口商品控制編號 (ECCN) 5D002.C.1，其中包括使用非對稱演算法或執行加密功能的資訊安全軟體。此 Apache Software Foundation 發行版的形式和方式使其符合目標代碼和原始代碼的許可證例外 ENC 技術軟體無限制 (TSU) 例外（請參閱 BIS 出口管理條例第 740.13 節）的出口資格。

以下提供了有關所含加密軟體的更多詳細資訊：

該軟體使用 Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) 支援身份驗證以及服務之間透過網路發送的資料的加密和解密。

展開

附加信息