一 准备工作1.1 环境要求64位操作系统推荐 Linux/Unix/macOS64位 JDK 1.8二 安装 RocketMQ2.1 下载解压官网下载地址官网下载链接官网访问地址官网访问地址首先在 Linux 服务器创建文件夹用于存放即将下载的 RocketMQmkdir /home/soft cd /home/soft文件夹创建好之后将下载好的压缩包上传到该目录然后解压在重命名unzip rocketmq-all-5.3.2-bin-release.zip mv rocketmq-all-5.3.2-bin-release rocketmq-5.3.2cd rocketmq-5.3.2 后目录如下bin启动脚本包括 shell 脚本和 CMD 脚本conf实例配置文件 包括 broker 配置文件、logback 配置文件等lib依赖 jar 包包括Netty、commons-lang、FastJSON等2.2 修改内存大小RocketMQ默认的虚拟机内存较大启动Broker或者NameServer可能会因为内存不足而导致失败所以需要编辑这两个地方的配置文件修改 JVM 内存大小编辑 vim bin/runserver.sh参考 JVM 参数设置-server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m编辑 vim bin/runbroker.sh参考 JVM 参数设置-server -Xms256m -Xmx256m2.3 修改 Broker 配置文件Broker需要向NameServer注册所以还需要指定NameServer的地址。因为NameServer 跟Broker 在同一台机器所以是 localhostNameServer 端口默认的是 9876。vim conf/broker.confnamesrvAddr localhost:9876brokerIP1 172.16.19.10brokerIP1 修改成自己的服务器 IP 地址MQ5以后客户端如果需要批量消费就需要开启批量消费参数enableProxytrueproxyListenPort80812.4 安装启动2.4.1 启动 NameServernohup sh bin/mqnamesrv nohup 英文全称 no hang up不挂起用于在系统后台不挂断地运行命令退出终端不会影响程序的运行。查看日志tail -f ~/logs/rocketmqlogs/namesrv.log如果能看到以下日志表示启动成功2.4.2 启动 Broker启动时指定读取上面的配置文件nohup sh bin/mqbroker -c conf/broker.conf -c指定配置文件路径-nNameServer 的地址查看日志tail -f ~/logs/rocketmqlogs/broker.log看到以下信息说明已经启动成功了。2.5 测试启动完NameServer及Broker,可以进行简单的测试。首先设置环境变量export NAMESRV_ADDRlocalhost:9876发送消息sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer接收消息sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer接收到的消息截图如下2.6 关闭 RocketMQ关闭NameServer及Broker的命令如下# 1.关闭NameServer sh bin/mqshutdown namesrv # 2.关闭Broker sh bin/mqshutdown broker三 源码搭建可视化控制台前面 NameServer 和 Broker 搭建完成之后就可以用来收发消息了但是为了更加直观可以搭建对应的服务控制台。3.1 下载下载地址地址3.2 修改配置文件下载完成后IDEA 打开刚解压的资源修改配置文件修改 localhost 为自己的 Linux 服务器公网 IP 地址。3.4 打包通过maven下载依赖然后进行打包上传到服务器指定目录3.5 启动启动我自己写了一个脚本方便操作启动命令如下java -jar rocketmq-dashboard-1.0.0.jar3.6 界面​http://localhost:8083