CentOS 7 安装RocketMQ

    科技2026-03-14  5

    1. RocketMQ入门

    RocketMQ是阿里巴巴开源的分布式消息中间件,现在是Apache的一个顶级项目。在阿里内部使用非常广泛,已经经过了"双11"这种万亿级的消息流转。

    2. RocketMQ环境搭建

    接下来我们先在linux平台下安装一个RocketMQ的服务

    2.1 环境准备下载RocketMQ

    http://rocketmq.apache.org/release_notes/release-notes-4.7.1/

    2.2 安装RocketMQ

    2.2.1 上传文件到/opt/software 2.2.2 解压到安装目录/opt/module

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

    2.3 启动RocketMQ

    2.3.1 切换到安装目录 2.3.2 启动NameServer

    [root@origin rocketmq-4.7.1]# nohup ./bin/mqnamesrv & [1] 1467 # 只要进程不报错,就应该是启动成功了,可以查看一下日志 [root@heima rocketmq]# tail -f /root/logs/rocketmqlogs/namesrv.log

    2.3.3 启动Broker

    # 编辑bin/runbroker.sh 和 bin/runserver.sh文件,修改里面的 # JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g" # 为JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m" [root@origin rocketmq-4.7.1]# nohup bin/mqbroker -n localhost:9876 & [root@origin rocketmq-4.7.1]# tail -f /root/logs/rocketmqlogs/broker.log

    3. 测试RocketMQ

    3.1 测试消息发送

    [root@origin rocketmq-4.7.1]# export NAMESRV_ADDR=localhost:9876 [root@origin rocketmq-4.7.1]# bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

    2 测试消息接收

    [root@origin rocketmq-4.7.1]# export NAMESRV_ADDR=localhost:9876 [root@origin rocketmq-4.7.1]# bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

    7.2.1.5 关闭RocketMQ

    [root@origin rocketmq-4.7.1]# bin/mqshutdown broker [root@origin rocketmq-4.7.1]# bin/mqshutdown namesrv
    Processed: 0.015, SQL: 9