2. RocketMQ安装部署

╰半夏微凉° 2023-07-01 09:59 92阅读 0赞

# 下载 #

请到 [rocketmq官方地址][rocketmq] 下载最新的rocketmq。  
我这里下载的是 rocketmq-all-4.6.0-bin-release.zip 。

其他装备：JDK 1.8+；64位centos系统。

# 部署并启动服务 #

将下载的`rocketmq-all-4.6.0-bin-release.zip`上传到Linux系统进行解压`unzip rocketmq-all-4.6.0-bin-release.zip`。

## 修改java堆大小 ##

由于rocketmq默认的堆太大，如果是自己机器上搭建测试集群，很可能会由于内存不足而启动失败：

Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)

所以这里要首先去修改一下配置。

### runserver.sh java堆调小 ###

#JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

### runbroker.sh java堆调小 ###

#JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

上面参数只是为了启动测试服务。实际生产根据机器内存进行配置。

## Start Name Server ##

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

启动后可以在日志中看到启动成功日志，并且`jps`会看到`NamesrvStartup`进程。

## Start Broker ##

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

启动成功后会看到`BrokerStartup`进程。

[root@node1 bin]# jps
    1877 BrokerStartup
    2310 Jps
    1851 NamesrvStartup

# 测试发送消息 #

这里先使用官方的控制台的方式来发送消息：

> 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...

从日志中可以看到是多线程消费的，日志中打印了线程id。

# 停止服务 #

> 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

# 常用命令 #

查看集群情况： ./mqadmin clusterList -n 127.0.0.1:9876
    查看 broker 状态： ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911
    查看 topic 列表： ./mqadmin topicList -n 127.0.0.1:9876
    查看 topic 状态： ./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (换成想查询的 topic)
    查看 topic 路由： ./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic

[rocketmq]: http://rocketmq.apache.org/docs/quick-start/