RocketMQ 5.0 快速入门

**RocketMQ5.0 快速入门**

RocketMQ 是一个开源的分布式消息队列系统，支持多种协议，如MQTT、AMQP、HTTP等。它可以作为一个高性能、高可靠性的消息中间件，用于实现应用程序之间的异步通信。

在本文中，我们将快速入门 RocketMQ5.0 的基本功能和配置。

**安装和启动**

首先，我们需要下载并安装 RocketMQ 的最新版本。您可以从以下网址下载：

/>
假设您已经下载了 RocketMQ 的压缩包，解压后，您会看到以下目录结构：

bashrocketmq-5.0.1/
├── bin│ ├── mqadmin.bat│ └── mqadmin.sh├── conf│ ├── broker.conf│ ├── namesrv.conf│ └── tools.conf├── lib│ ├── rocketmq-all-5.0.1.jar│ └── ...
└── tools └── RocketMQConsoleTool.jar

我们需要启动 Namesrv 和 Broker服务。首先，我们需要修改 `namesrv.conf` 文件，配置 Namesrv 的 IP 地址和端口：

properties# namesrv.confnamesrv.address=127.0.0.1:9876

然后，我们可以使用 `mqadmin` 工具启动 Namesrv 和 Broker服务：

bashbin/mqadmin server start -n127.0.0.1:9876 -c conf/namesrv.confbin/mqadmin broker start -b127.0.0.1:10911 -c conf/broker.conf

**发送和接收消息**

现在，我们可以使用 `mqadmin` 工具发送和接收消息。首先，我们需要创建一个主题：

bashbin/mqadmin topic create -t myTopic -n3 -c conf/namesrv.conf

然后，我们可以使用以下命令发送一条消息：

bashbin/mqadmin msg put -t myTopic -m "Hello, RocketMQ!" -c conf/broker.conf

接收消息的客户端可以订阅主题并接收消息：

javaimport org.apache.rocketmq.client.consumer.DefaultMQConsumer;
import org.apache.rocketmq.client.consumer.MessageListenerConcurrently;

public class Consumer {
 public static void main(String[] args) throws Exception {
 DefaultMQConsumer consumer = new DefaultMQConsumer("myTopic", "127.0.0.1:9876");
 consumer.subscribe("myTopic");

 while (true) {
 Message msg = consumer.receive();
 System.out.println(msg.getBody());
 }
 }
}

**代码注释**

* `mqadmin` 工具用于管理 Namesrv 和 Broker服务。
* `namesrv.conf` 文件配置 Namesrv 的 IP 地址和端口。
* `broker.conf` 文件配置 Broker 的 IP 地址和端口。
* `topic create` 命令创建一个主题。
* `msg put` 命令发送一条消息。
* `DefaultMQConsumer` 类用于接收消息。

**总结**

RocketMQ5.0 是一个强大的分布式消息队列系统，支持多种协议和高性能、高可靠性的特性。通过本文的快速入门指南，您可以轻松地开始使用 RocketMQ 来实现应用程序之间的异步通信。