本篇是基于Linux操作系统中的安装，故先准备一台干净的Linux操作系统，并在系统上先安装好JDK和Maven，本文中所有的操作基于CentOS8进行安装演示；
1、官网下载RocketMQ安装包cd /usr/local/
mkdir source
cd source/
wget https://dlcdn.apache.org/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip
2、解压RocketMQ安装包，阅读其中的README.md文件unzip rocketmq-all-4.9.2-bin-release.zip
cd rocketmq-4.9.2/
vim README.md
3、启动RocketMQ服务cd bin/
./mqnamesrv
4、新起一个终端窗口，修改runbroker.sh文件cd /usr/local/source/rocketmq-4.9.2/bin
vim runbroker.sh
默认设置的虚拟机内存参数过大，正常人的虚拟机根本跑不起来，改小点可以启动。
./mqbroker -n localhost:9876
5、新起一个终端窗口，测试RocketMQ功能修改tools.sh文件
cd /usr/local/source/rocketmq-4.9.2/bin
vim tools.sh
执行 ./tools.sh org.apache.rocketmq.example.quickstart.Producer 启动MQ生产者
新起一个终端窗口启动MQ消费者
cd /usr/local/source/rocketmq-4.9.2/bin
./tools.sh org.apache.rocketmq.example.quickstart.Consumer
6、RocketMQ中各角色的解读NameServer：主要的功能是用来收集其它角色的信息，相当于一个中介，维护了一个服务的列表，知道有哪些服务还存活。底层由netty实现，提供了路由管理、服务注册、服务发现的功能，是一个无状态节点；
Broker：面向Producer和Consumer接受和发送消息，向NameServer提交自己的信息。是消息中间件的消息存储、转发服务器。每个Broker节点在启动时，都会遍历NameServer列表，于每个NameServer建立长连接，注册自己的信息，之后定时上报；
Producer：消息生产者。通过集群中一个节点建立长连接，获得Topic的路由信息，包括Topic下面有哪些Queue，这些Queue分布在哪些Broker上等；
Consumer：消息消费者。通过NameServer集群获得Topic的路由信息，连接到对应的Broker上消费消息。注意，由于Master和Slave都可以读取消息，因此Consumer会与Master和Slave都建立连接。
7、RocketMQ的HelloWorld生产者Producer代码：
package com.feenix.rocketmq.producer;import org.apache.rocketmq.client.exception.MQBrokerException;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.client.producer.DefaultMQProducer;import org.apache.rocketmq.client.producer.SendResult;import org.apache.rocketmq.common.message.Message;import org.apache.rocketmq.remoting.exception.RemotingException;import java.nio.charset.StandardCharsets;public class Producer { private static final String PRODUCER_GROUP = "feenix_group"; private static final String NAMESRV_ADDR = "192.168.159.149:9876"; private static final String TOPIC = "feenix_topic"; public static void main(String[] args) throws MQClientException, MQBrokerException, RemotingException, InterruptedException { DefaultMQProducer producer = new DefaultMQProducer(PRODUCER_GROUP); // 设置NameServer的地址 producer.setNamesrvAddr(NAMESRV_ADDR); producer.start(); // Topic >> 消息将要发送到的地址 // body >> 真正流转的消息内容 String body = "Hello World By RocketMQ!"; Message message = new Message(TOPIC, body.getBytes()); SendResult result = producer.send(message); System.out.println("SendResult：" + result); // producer.shutdown(); }}
消费者Consumer代码：
package com.feenix.rocketmq.consumer;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.common.message.MessageExt;import java.util.List;public class Consumer { private static final String CONSUMER_GROUP = "feenix_consumer_group"; private static final String NAMESRV_ADDR = "192.168.159.149:9876"; private static final String TOPIC = "feenix_topic"; private static final String FILTER = "*"; public static void main(String[] args) throws MQClientException { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(CONSUMER_GROUP); consumer.setNamesrvAddr(NAMESRV_ADDR); // 每个consumer只能订阅一个topic consumer.subscribe(TOPIC, FILTER); // 注册消息监听器 consumer.registerMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List