|
|
### 安装文档
|
|
|
|
|
|
> https://rocketmq.apache.org/zh/docs/4.x/quickstart/01quickstart
|
|
|
>
|
|
|
|
|
|
|
|
|
|
|
|
#### 安装$JDK$
|
|
|
|
|
|
```
|
|
|
cd /usr/local
|
|
|
rz -be
|
|
|
jdk-8u421-linux-x64.tar.gz
|
|
|
tar -xvf jdk-8u421-linux-x64.tar.gz
|
|
|
rm -rf jdk-8u421-linux-x64.tar.gz
|
|
|
mv jdk1.8.0_421/ jdk
|
|
|
|
|
|
vi /etc/profile
|
|
|
|
|
|
GG到最后：
|
|
|
|
|
|
export JAVA_HOME=/usr/local/jdk
|
|
|
export CLASSPATH=$:CLASSPATH:$JAVA_HOME/lib/
|
|
|
export PATH=$PATH:$JAVA_HOME/bin
|
|
|
|
|
|
source /etc/profile
|
|
|
|
|
|
java -version
|
|
|
```
|
|
|
|
|
|
|
|
|
|
|
|
#### 安装$RocketMQ$
|
|
|
|
|
|
```shell
|
|
|
cd /usr/local
|
|
|
mkdir rocketmq
|
|
|
rz -be
|
|
|
rocketmq-all-4.9.4-bin-release.zip
|
|
|
unzip rocketmq-all-4.9.4-bin-release.zip
|
|
|
rm -rf rocketmq-all-4.9.4-bin-release.zip
|
|
|
mv rocketmq-all-4.9.4-bin-release/ rocketmq
|
|
|
cd rocketmq
|
|
|
|
|
|
### 启动namesrv
|
|
|
nohup sh bin/mqnamesrv &
|
|
|
|
|
|
### 验证namesrv是否启动成功
|
|
|
tail -f /root/logs/rocketmqlogs/namesrv.log
|
|
|
|
|
|
2024-07-31 13:48:37 INFO main - The Name Server boot success. serializeType=JSON
|
|
|
|
|
|
### 启动Broker
|
|
|
nohup sh bin/mqbroker -n localhost:9876 &
|
|
|
|
|
|
### 验证broker是否启动成功
|
|
|
tail -f /root/logs/rocketmqlogs/broker.log
|
|
|
|
|
|
main - The broker[RockyLinux, 10.10.14.210:10911] boot success. serializeType=JSON and name server is localhost:9876
|
|
|
```
|
|
|
|
|
|
|
|
|
|
|
|
#### 消息收发
|
|
|
|
|
|
```
|
|
|
export NAMESRV_ADDR=localhost:9876
|
|
|
cd /usr/local/rocketmq
|
|
|
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...
|
|
|
```
|
|
|
|
|
|
|
|
|
|
|
|
#### 关闭服务器
|
|
|
|
|
|
```shell
|
|
|
sh bin/mqshutdown broker
|
|
|
sh bin/mqshutdown namesrv
|
|
|
```
|
|
|
|
|
|
|
|
|
#### 主题维护
|
|
|
```shell
|
|
|
cd /usr/local/rocketmq/bin
|
|
|
|
|
|
# 创建主题
|
|
|
./mqadmin updateTopic -n 10.10.14.210:9876 -c DefaultCluster -t HuangHaiTest
|
|
|
# 创建或重置一个名为 TOPIC_NAME 的 topic，并将该 broker 组的读写队列数皆设为 4 个。
|
|
|
./mqadmin updateTopic -n 10.10.14.210:9876 -b 10.10.14.210:10911 -t HuangHaiTest -w 4 -r 4
|
|
|
|
|
|
|
|
|
# 查看主题
|
|
|
./mqadmin topicList -n 10.10.14.210:9876 -c
|
|
|
|
|
|
# 删除主题
|
|
|
./mqadmin deleteTopic -n 10.10.14.210:9876 -c DefaultCluster -t HuangHaiTest
|
|
|
``` |
