RocketMQ（Linux版本5.1.4）

1、停止之前的运行服务

[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# sh bin/mqshutdown namesrv
No mqnamesrv running.
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# 
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# 
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# sh bin/mqshutdown broker
No mqbroker running.
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# 
[root@tssvr1-c1 rocketmq-all-4.7.0-bin-release]# pwd
/usr/local/rocketmq-all-4.7.0-bin-release

2、删除之前的RocketMQ

rm -rf rocketmq-all-4.7.0-bin-release

unzip rocketmq-all-5.1.4-bin-release.zip 

它的目录结构：

• benchmark：这里面就是一些可以直接运行，进行测试的 sh 文件

• bean：该目录是比较常用的，里面是一些可执行文件

• conf：这里面就是一些配置文件

• lib：就是 mq 所依赖的第三方 jar 包

4、启动RocketMQ

（1）启动 NameServer 进入 bin 目录??cd bin/? 后台启动??nohup sh mqnamesrv &??或者??nohup ./mqnamesrv &?

可以查看日志，看 mq 是否启动成功： tail -f ~/logs/rocketmqlogs/namesrv.log

或者通过端口号查看

netstat -an | grep 9876?

（2）启动 Broker 在启动之前先修改两个配置 ?vim runserver.sh?

将原先注释掉，mq 默认需要的内存是比较大的，根据自己 Linux 的内存大小去设置，我这里就改成 256 256 128 了。

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

vim runbroker.sh?

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"

启动 broker ?
?

nohup ./mqbroker -n localhost:9876 &?

查看日志检测是否启动成功

tail -f ~/logs/rocketmqlogs/broker.log

又看到日志打印这个就说明启动成功了，注意：不要把它给关了。

5、测试

（1）发送消息

# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Producer

（2）接收消息

# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Consumer

成功！！！