# 输出示例：
create topic to 192.168.1.51:10911 success.
TopicConfig [topicName=fgedu_topic, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

# 查看主题列表
$ sh /opt/rocketmq/bin/mqadmin topicList -n 192.168.1.51:9876

# 输出示例：
fgedu_topic
RMQ_SYS_TRANS_HALF_TOPIC
BenchmarkTest
OFFSET_MOVED_EVENT
TBW102
SELF_TEST_TOPIC
DefaultCluster_REPLY_TOPIC
SCHEDULE_TOPIC_XXXX

# 查看主题详情
$ sh /opt/rocketmq/bin/mqadmin topicStatus -n 192.168.1.51:9876 -t fgedu_topic

# 输出示例：
#Broker Name #QID #Min Offset #Max Offset #InTPS #OutTPS
fgedudb01 0 0 0 0.00 0.00
fgedudb01 1 0 0 0.00 0.00
fgedudb01 2 0 0 0.00 0.00

# 输出示例：
SendResult [sendStatus=SEND_OK, msgId=C0A8013300002A9F0000000000000000, offsetMsgId=C0A8013300002A9F0000000000000000, messageQueue=MessageQueue [topic=fgedu_topic, brokerName=fgedudb01, queueId=0], queueOffset=0]

# 使用Java发送消息
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

public class Producer {
public static void main(String[] args) throws Exception {
DefaultMQProducer producer = new DefaultMQProducer(“fgedu_producer_group”);
producer.setNamesrvAddr(“192.168.1.51:9876”);
producer.start();

Message msg = new Message(“fgedu_topic”, “TagA”, “Hello RocketMQ”.getBytes());
SendResult sendResult = producer.send(msg);
System.out.println(sendResult);

producer.shutdown();
}
}

# 输出示例：
ConsumeMessageThread_please_rename_unique_group_name_4_1 receive new Messages: [MessageExt [brokerName=fgedudb01, queueId=0, storeSize=203, queueOffset=0, sysFlag=0, bornTimestamp=1712205600000, bornHost=/192.168.1.51:12345, storeTimestamp=1712205600000, storeHost=/192.168.1.51:10911, msgId=C0A8013300002A9F0000000000000000, commitLogOffset=0, bodyCRC=1234567890, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic=’fgedu_topic’, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=1, KEYS=OrderID001, CONSUME_START_TIME=1712205600000}, body=[72, 101, 108, 108, 111, 32, 82, 111, 99, 107, 101, 116, 77, 81], transactionId=’null’}]]

# 使用Java消费消息
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;

public class Consumer {
public static void main(String[] args) throws Exception {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(“fgedu_consumer_group”);
consumer.setNamesrvAddr(“192.168.1.51:9876”);
consumer.subscribe(“fgedu_topic”, “*”);
consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
for (MessageExt msg : msgs) {
System.out.println(new String(msg.getBody()));
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
consumer.start();
}
}

brokerClusterName = FgeDuCluster
brokerName = broker-a
brokerId = 0
namesrvAddr = 192.168.1.51:9876;192.168.1.52:9876
brokerIP1 = 192.168.1.51
listenPort = 10911
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH

# Slave节点配置 (fgedudb02)
$ vi /opt/rocketmq/conf/broker.conf

brokerClusterName = FgeDuCluster
brokerName = broker-a
brokerId = 1
namesrvAddr = 192.168.1.51:9876;192.168.1.52:9876
brokerIP1 = 192.168.1.52
listenPort = 10911
brokerRole = SLAVE
flushDiskType = ASYNC_FLUSH

# 启动Master
$ nohup sh /opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/broker.conf > /data/rocketmq/logs/broker.log 2>&1 &

# 启动Slave
$ nohup sh /opt/rocketmq/bin/mqbroker -c /opt/rocketmq/conf/broker.conf > /data/rocketmq/logs/broker.log 2>&1 &

# 查看集群状态
$ sh /opt/rocketmq/bin/mqadmin clusterList -n 192.168.1.51:9876

# 输出示例：
#Cluster Name #Broker Name #BrokerId #Addr #Version
FgeDuCluster broker-a 0 192.168.1.51:10911 V5_3_0
FgeDuCluster broker-a 1 192.168.1.52:10911 V5_3_0

brokerClusterName = FgeDuCluster
brokerName = broker-a
brokerId = 0
namesrvAddr = 192.168.1.51:9876;192.168.1.52:9876
brokerIP1 = 192.168.1.51
listenPort = 10911
brokerRole = ASYNC_MASTER

# 节点2配置 (fgedudb02)
$ vi /opt/rocketmq/conf/broker-b.conf

brokerClusterName = FgeDuCluster
brokerName = broker-b
brokerId = 0
namesrvAddr = 192.168.1.51:9876;192.168.1.52:9876
brokerIP1 = 192.168.1.52
listenPort = 10911
brokerRole = ASYNC_MASTER

# 查看集群状态
$ sh /opt/rocketmq/bin/mqadmin clusterList -n 192.168.1.51:9876

# 输出示例：
#Cluster Name #Broker Name #BrokerId #Addr #Version
FgeDuCluster broker-a 0 192.168.1.51:10911 V5_3_0
FgeDuCluster broker-b 0 192.168.1.52:10911 V5_3_0