当前位置：首页 > news >正文

RocketMQ入门实战详解

news 2025/8/2 13:32:35

RocketMQ 入门实战详解：从理论到实践

Apache RocketMQ 是阿里巴巴开源、捐赠给 Apache 基金会的分布式消息中间件，具备高吞吐、低延迟、高可用、高可靠、灵活可扩展等特点，广泛应用于金融、电商、物联网等领域。

本文将带你从零开始掌握 RocketMQ 的核心概念、部署方法及实战应用，帮助你快速入门并落地使用。

一、RocketMQ 基础概念

在使用 RocketMQ 之前，先理解其核心组成部分：

Producer（生产者）：消息的发送方。
- 同步发送
- 异步发送
- 单向发送
Consumer（消费者）：消息的接收方，支持推（Push）和拉（Pull）两种模式。
Broker（代理服务器）：存储和转发消息的组件，支持主从架构。
NameServer（名称服务）：路由管理器，Producer 和 Consumer 根据它获取 Broker 的路由信息。
Topic：消息的逻辑分类标识。
MessageQueue：物理上的队列，一个 Topic 会对应多个队列。

二、本地环境搭建

1. 下载和解压

从官网下载 RocketMQ：

wget https://dlcdn.apache.org/rocketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip
unzip rocketmq-all-5.1.4-bin-release.zip
cd rocketmq-5.1.4

2. 启动 NameServer 和 Broker

先启动 NameServer：

sh bin/mqnamesrv

再启动 Broker：

sh bin/mqbroker -n localhost:9876

确保你本地 Java 版本在 JDK 8+，并设置了环境变量。

三、实战：发送与接收消息

RocketMQ 提供 Java 客户端 SDK。以下是使用 Maven 构建的 Producer 和 Consumer 示例。

1. 添加 Maven 依赖

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client-java</artifactId><version>5.1.4</version>
</dependency>

2. 编写 Producer 示例

public class SimpleProducer {public static void main(String[] args) throws Exception {DefaultMQProducer producer = new DefaultMQProducer("demo_producer_group");producer.setNamesrvAddr("localhost:9876");producer.start();Message msg = new Message("TestTopic", "Hello RocketMQ".getBytes());SendResult result = producer.send(msg);System.out.println("Send status: " + result.getSendStatus());producer.shutdown();}
}

3. 编写 Consumer 示例

public class SimpleConsumer {public static void main(String[] args) throws Exception {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("demo_consumer_group");consumer.setNamesrvAddr("localhost:9876");consumer.subscribe("TestTopic", "*");consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {for (MessageExt msg : msgs) {System.out.printf("Received: %s%n", new String(msg.getBody()));}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;});consumer.start();System.out.println("Consumer started.");}
}