1. 官网下载地址:

下载 | RocketMQ

2. 配置环境:

    我是在/etc/profile.d 新建了一个rocketmq_env.sh

    配置了jdk, maven, 以及mq.

     mq文件下载的

        配置完之后,刷新环境source /etc/profile

3.  配置rocket mq 的jvm配置,就是两个启动脚本修改,虚拟机内存搞得1.5g 原始的配的大不够用。

     a. 配置bin/runserver.sh

    b. 配置bin/runbroker.sh

 4. chmod 777 mqnamesrv

        启动注册中心:

nohup ./mqnamesrv &

#看log
tail -f nohup.out

5. 配置conf: /opt/module/rocketmq-all-5.1.4-bin-release/conf/broker.conf

   新增如下配置

5. 启动broker:

 nohup ./mqbroker -c ../conf/broker.conf &

6.跑两步:

export NAMESRV_ADDR='localhost:9876'

# 生产者跑两步
./tools.sh  org.apache.rocketmq.example.quickstart.Producer

消费者:


# 如果不行,把生产者的那个环境命令再输入一遍export NAMESRV_ADDR='localhost:9876'
./tools.sh  org.apache.rocketmq.example.quickstart.Consumer

7. 退出mq:

# jps可以查看两个服务运行
jps

# 在mq文件/bin 路径下输入命令停止broker
./mqshutdown broker





# 停止注册中心:
 ./mqshutdown namesrv


# jps查看应该没有了
jps

更多推荐