rocketmq

wget http://mirrors.hust.edu.cn/apache/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip

1

vim runserver.sh:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:PermSize=32m -XX:MaxPermSize=64m"

vim runbroker.sh:
JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"

1
2
3
4
5

nohup sh ./mqnamesrv > ./rocketmq.log 2>&1 &

1

nohup sh ./mqbroker -n 192.168.1.129:9876 autoCreateTopicEnable=true > ./rocketmq-broker.log 2>&1 &

1

export NAMESRV_ADDR=192.168.1.129:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

1
2

sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

1

https://gitee.com/ahxiao/rocketmq-externals/tree/master/rocketmq-console

1

java -jar rocketmq-console-ng-1.0.1.jar --server.port=12581

1

Ben

Choose mode

rocketmq

# 下载

# 解压到/data目录

# 修改配置

# 启动nameserver

# 启动broker(单个broker)

# 启动生产者

# 启动消费者

# 启动控制台