ubuntu rocketmq

### 安装和配置 RocketMQ #### 解压下载文件并设置环境变量 对于 Ubuntu/Linux 系统，在安装 RocketMQ 的过程中，首先需要下载 RocketMQ 并将其解压缩到指定路径[^1]。完成解压之后，为了方便通过命令行工具管理 RocketMQ 实例，应当在系统的 Path 变量中加入 RocketMQ bin 目录的位置。 ```bash export PATH=$PATH:/path/to/rocketmq/bin ``` 上述命令需替换 `/path/to/rocketmq` 为实际的 RocketMQ 安装路径，并可考虑将此行添加至用户的 shell 配置文件（如 `.bashrc` 或者 `.zshrc`），以便每次登录时自动加载该环境变量。 #### 启动 Name Server 和 Broker 服务 启动之前确认已经正确设置了 JAVA_HOME 环境变量指向已安装的 JDK 版本。接着可以分别使用如下命令来启动 NameServer 和 Broker： ```bash nohup sh mqnamesrv & nohup sh mqbroker -n localhost:9876 & ``` 这里假设 NameServer 运行在同一台机器上的默认端口 `9876` 上；如果是在分布式环境中部署，则 `-n` 参数后面应该填写真实的 NameServer 地址列表。 #### 日志查看与服务控制 日志会被记录于特定目录下，例如根用户下的 `/root/logs/rocketmqlogs` 文件夹内[^2]。当不再需要运行 RocketMQ 服务的时候，可以通过执行以下指令安全地停止各个组件的服务进程： ```bash mqshutdown broker mqshutdown namesrv pkill -f rocketmq-dashboard ``` 这些操作能够确保所有关联的任务都被妥善处理完毕后再结束程序实例。 #### 使用 mqadmin 工具进行管理 RocketMQ 提供了一个名为 `mqadmin` 的命令行工具用于管理和监控集群状况。一些常用的子命令包括但不限于查询集群成员信息、列举主题(Topic)，以及获取某个具体 Topic 的当前状态等。下面给出几个例子说明如何利用这个工具来进行日常运维工作： - 获取整个集群的状态概览： ```bash mqadmin clusterList -n 127.0.0.1:9876 ``` - 列举所有的 Topics: ```bash mqadmin topicList -n 127.0.0.1:9876 ``` - 查询单个 Topic 的详情： ```bash mqadmin topicStatus -n 127.0.0.1:9876 -t <topic_name> ``` 其中 `<topic_name>` 应被替换成想要调查的具体 Topic 名字字符串。 #### 编译并启动 Web 控制台 除了命令行界面之外，还可以构建一个图形化的 Web 控制面板来辅助管理工作负载。这一步骤依赖于 Maven 构建工具和 Java 开发套件(JDK)版本至少达到 1.8 。按照官方文档指示执行下列步骤即可快速搭建起可视化的管理平台[^3]: ```bash mvn clean package -DskipTests java -jar target/rocketmq-console-ng-2.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 ``` 以上命令会编译项目源码并将打包后的 jar 文件置于目标目录(`target`)之中，随后即刻开启 HTTP 服务器监听本地地址 `localhost` 的 `8080` 端口号提供访问入口给浏览器客户端连接请求。