Apache RocketMQ5.x-消息队列体验

**Apache RocketMQ5.x 消息队列体验**

RocketMQ 是一个开源的分布式消息队列系统，支持多种消息模式，如点对点（P2P）、发布订阅（Pub/Sub）等。它提供了高性能、高可靠性和易于使用的特性，使其成为企业级消息队列系统的理想选择。

**安装和配置**

首先，我们需要下载并安装RocketMQ。可以从Apache官网下载最新版本的源码，然后编译和安装。

bash# 下载源码git clone  进入源码目录cd rocketmq# 编译和安装mvn clean package -Dmaven.test.skip=true

接下来，我们需要配置RocketMQ。我们需要创建一个`namesrv.properties`文件来配置Nameserver（NS），以及一个`broker.properties`文件来配置Broker。

properties# namesrv.propertiesnamesrvAddress=127.0.0.1:9876# broker.propertiesbrokerId=0brokerName=my-brokerbrokerClusterName=my-cluster

**启动 Nameserver 和 Broker**

我们可以使用以下命令启动Nameserver和Broker：

bash# 启动 Nameserversh bin/mqnamesrv -c etc/namesrv.properties# 启动 Brokersh bin/mqbroker -c etc/broker.properties

**发送消息**

我们可以使用`mqadmin`工具来发送消息到RocketMQ。

bash# 发送一条消息mqadmin messagePut --brokerList127.0.0.1:10911 --topic my-topic --msgBody "Hello, RocketMQ!"

**消费消息**

我们可以使用`mqadmin`工具来消费消息从RocketMQ。

bash# 消费一条消息mqadmin messagePull --brokerList127.0.0.1:10911 --topic my-topic --maxMsgNums1

**发布订阅模式**

在发布订阅模式下，生产者将消息发送到一个主题（Topic），然后消费者可以从同一个主题中拉取消息。

bash# 发布一条消息mqadmin messagePut --brokerList127.0.0.1:10911 --topic my-topic --msgBody "Hello, RocketMQ!"

# 消费一条消息mqadmin messagePull --brokerList127.0.0.1:10911 --topic my-topic --maxMsgNums1

**点对点模式**

在点对点模式下，生产者将消息发送到一个队列（Queue），然后消费者可以从同一个队列中拉取消息。

bash# 发布一条消息mqadmin messagePut --brokerList127.0.0.1:10911 --queue my-queue --msgBody "Hello, RocketMQ!"

# 消费一条消息mqadmin messagePull --brokerList127.0.0.1:10911 --queue my-queue --maxMsgNums1

**总结**

在本文中，我们介绍了Apache RocketMQ5.x的基本概念和使用方法。我们学习了如何安装和配置RocketMQ，如何发送消息到RocketMQ，以及如何消费消息从RocketMQ。在发布订阅模式下，我们可以将消息发送到一个主题，然后消费者可以从同一个主题中拉取消息。在点对点模式下，我们可以将消息发送到一个队列，然后消费者可以从同一个队列中拉取消息。