环境要求
操作系统：Linux、Windows
JDK：Java 8 或更高版本
系统权限：需要具有基本的 Linux 或 Windows 命令行操作权限

在 Linux 上安装 RocketMQ

1. 下载 RocketMQ
   访问 RocketMQ 的官网 或 GitHub Releases 页面。
   使用 wget 命令下载 RocketMQ：
   wget https://archive.apache.org/dist/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.tar.gz
2. 解压并安装 RocketMQ：
   tar -zxvf rocketmq-all-4.9.4-bin-release.tar.gz
   cd rocketmq-all-4.9.4-bin-release
3. 启动 NameServer
   nohup sh bin/mqnamesrv &
4. 启动 Broker
   nohup sh bin/mqbroker -n localhost:9876 &
5. 检查服务是否成功启动
   ps -ef | grep rocketmq
   tail -f ~/rocketmq-all-4.9.4-bin-release/logs/rocketmqlogs/*
6. 编写生产者和消费者
   生产者示例：

public class Producer {

public static void main(String[] args) throws Exception {
    DefaultMQProducer producer = new DefaultMQProducer("ProducerGroup");
    producer.setNamesrvAddr("localhost:9876");
    producer.start();

    Message msg = new Message("TopicTest", "TagA", "Hello RocketMQ".getBytes());
    producer.send(msg);

    producer.shutdown();
}

}

消费者示例：

public class Consumer {

public static void main(String[] args) throws Exception {
    DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
    consumer.setNamesrvAddr("localhost:9876");
    consumer.subscribe("TopicTest", "*");

    consumer.registerMessageListener((msgs, context) -> {
        for (MessageExt msg : msgs) {
            System.out.println("Received Message: " + new String(msg.getBody()));
        }
        return null;
    });

    consumer.start();
}

}

在 Windows 上安装 RocketMQ

1. 下载 RocketMQ
   首先，下载 RocketMQ 的压缩包，前往 官网 或 GitHub Releases 页面，下载最新版本。
2. 解压并安装 RocketMQ
   使用解压工具解压下载的 .tar.gz 或 .zip 文件。
   将解压后的文件夹保存到合适的位置。
3. 配置环境变量
   为了方便在命令行中调用 RocketMQ 的启动脚本，建议将 RocketMQ 的 bin 目录添加到 Windows 的环境变量 Path 中。

设置环境变量步骤：

打开 控制面板 → 系统 → 高级系统设置 → 环境变量。
在系统变量部分找到 Path，点击 编辑。
在弹出的窗口中，添加 RocketMQ 的 bin 路径。例如，假设你安装在 C:\rocketmq，则路径应为 C:\rocketmq\rocketmq-all-4.9.4-bin-release\bin。

4. 启动 NameServer
   打开命令行窗口，进入到 RocketMQ 安装目录下的 bin 文件夹。
   运行以下命令启动 NameServer：
   start mqnamesrv
5. 启动 Broker
   在另一个命令行窗口中，进入到 bin 目录。
   启动 Broker：
   start mqbroker -n localhost:9876
6. 检查是否启动成功
   打开任务管理器，确认 RocketMQ 服务进程是否已启动。
   也可以查看命令行窗口中的日志输出，确保没有错误。

RocketMQ 性能调优

1. 调整 Broker 配置
   你可以通过修改 conf/broker.conf 文件来调整 RocketMQ 的性能，具体配置项包括：

存储路径：调整消息存储路径。
线程数：调整消费线程数和生产线程数。
最大消息大小：调整最大消息体的大小。

2. 集群配置
   如果需要在生产环境中使用 RocketMQ，推荐配置多台 NameServer 和多个 Broker 实例来提升高可用性与负载均衡。