ubuntu安装rocketmq

### 如何在 Ubuntu 上安装 RocketMQ 消息队列

#### 准备工作
确保有足够的磁盘空间来支持 RocketMQ 的安装，单台服务器至少需要 4G+ 的硬盘空间[^2]。

#### 安装 Java JDK
由于 RocketMQ 基于 Java 开发，因此首先需确认已经安装了 Java JDK。可以通过如下命令验证是否已安装：

java -version

如果没有安装，则可通过以下方式安装 OpenJDK:

sudo apt update
sudo apt install openjdk-11-jdk

#### 下载并解压 RocketMQ
前往 GitHub 页面下载最新的稳定版本的 RocketMQ 发行版，并将其放置到合适的位置进行解压缩操作。例如，在 `/opt` 目录下创建 `rocketmq` 文件夹用于存放软件包文件[^5]:

cd /opt
wget https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip
unzip rocketmq-all-4.9.3-bin-release.zip -d rocketmq

#### 配置环境变量 (可选)
为了方便后续的操作，建议配置好相应的环境变量以便可以直接调用相关脚本。编辑用户的 `.bashrc` 或者全局的 `/etc/profile` 文件加入下面的内容(假设解压路径为 `/opt/rocketmq`) :

export ROCKETMQ_HOME=/opt/rocketmq/rocketmq-all-4.9.3-bin-release
export PATH=$ROCKETMQ_HOME/bin:$PATH
source ~/.bashrc # 刷新当前终端会话中的更改

#### 启动 Name Server 和 Broker
启动之前要保证防火墙允许访问默认端口（NameServer 默认监听 9876 端口；Broker 使用的是随机分配的一个大于 1024 的端口号）。接着按照顺序依次启动 NameServer 和 Broker 实例：

nohup sh $ROCKETMQ_HOME/bin/mqnamesrv &
nohup sh $ROCKETMQ_HOME/bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &

等待几秒钟让服务完全初始化完成之后就可以开始测试生产与消费功能了。

#### 测试消息传递流程
进入 RocketMQ 解压后的根目录运行官方提供的简单例子来进行基本的功能验证。分别打开两个新的 shell 终端窗口执行如下指令模拟消息发送方和接收方的工作过程[^3]：

**生产者**

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

**消费者**

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

此时应该可以在控制台上看到由 Producer 所发出的信息被 Consumer 成功接收到的日志记录。