前置條件

假定安裝了以下軟體:

1. 推薦64bit OS, Linux/Unix/Mac系統;
2. 64bit JDK 1.8+;
3. Maven 3.2.x
4. Git

從釋出版下載並構建

點選 這裡 下載4.2.0發行版原始碼. 你也可以點選 這裡下載二進位制發行版.

現在執行以下命令來解壓4.2.0源版本並構建.

  > unzip rocketmq-all-4.2.0-source-release.zip
  > cd rocketmq-all-4.2.0/
  > mvn -Prelease-all -DskipTests clean install -U
  > cd 
 
distribution/target/apache-rocketmq

啟動 Name Server服務

  > nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

啟動Broker

  > nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...
 

傳送和接收訊息

在傳送/接收訊息之前，我們需要告訴客戶端伺服器的位置。 RocketMQ提供了多種方式來實現這一點。 為了簡單起見，我們使用環境變數NAMESRV_ADDR

 > export NAMESRV_ADDR=localhost:9876
 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
 SendResult [sendStatus=SEND_OK, msgId= ...

 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 ConsumeMessageThread_%d Receive New Messages: [
 
MessageExt...

關閉服務

> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK

> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK