RocketMQ 单机部署

下载 rocketmq 安装包

# wget http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-bin-release.zip

配置 rocketmq

# unzip rocketmq-all-4.4.0-bin-release.zip -d /usr/local/
# cd /usr/local/rocketmq-all-4.4.0-bin-release/
// 修改 broker、namesrv、tools 的 log 存放位置
# mkdir -p /data/logs/rocketmqlogs
# sed -i 's#${user.home}/logs/#/data/logs/#g' conf/logback_broker.xml
# sed -i 's#${user.home}/logs/#/data/logs/#g' conf/logback_namesrv.xml
# sed -i 's#${user.home}/logs/#/data/logs/#g' conf/logback_tools.xml
// 修改 broker、namesrv、tools 的 jvm 大小
# vim bin/runbroker.sh
// 根据机器实际内存调整，这里演示的机器内存比较小，所以配置的值比较小
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
# vim bin/runserver.sh
// 根据机器实际内存调整，这里演示的机器内存比较小，所以配置的值比较小
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# vim bin/tools.sh
// 根据机器实际内存调整，这里演示的机器内存比较小，所以配置的值比较小
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m"

启动 namesrv、broker

# nohup sh bin/mqnamesrv > /data/logs/mqnamesrv.log 2>&1 & 
# nohup sh bin/mqbroker -n 10.3.200.101:9876 > /data/logs/mqbroker.log 2>&1 &

测试 rocketmq 生产消息和消费消息是否正常

# export NAMESRV_ADDR=10.3.200.101:9876
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

参考链接：http://rocketmq.apache.org/docs/quick-start/