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

// 1.創(chuàng)建一個DefaultMQProducer實例，指定生產(chǎn)者組名 
DefaultMQProducer producer = new DefaultMQProducer("my-producer-group1");  
// 2.設置NameServer的地址
producer.setNamesrvAddr("192.168.220.135:9876");    
// 3.啟動生產(chǎn)者實例  
producer.start();   
// 4.使用for循環(huán)發(fā)送10條消息  
for (int i = 0; i < 10; i++) {  
    // 創(chuàng)建一條消息，指定Topic為"MyTopic1"，Tag標簽為"TagA"，消息體為"hello rocketmq"加上循環(huán)變量的值，同時把字符串轉(zhuǎn)換為字節(jié)數(shù)組  
    Message message = new Message("MyTopic1","TagA",("hello rocketmq"+i).getBytes(StandardCharsets.UTF_8));       
    // 5.發(fā)送消息并接收發(fā)送結(jié)果  
    SendResult sendResult = producer.send(message);  
    // 打印發(fā)送結(jié)果，包括消息ID、發(fā)送狀態(tài)等信息  
    System.out.println(sendResult);  
}  
// 6.發(fā)送完所有消息后，關(guān)閉生產(chǎn)者實例，釋放資源  
producer.shutdown();

// 1.和生產(chǎn)者一樣，創(chuàng)建一個DefaultMQPushConsumer實例
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("my-consumer-group1");  
// 2.設置NameServer的地址，消費者通過這個地址與NameServer進行通信，來獲取Broker的地址信息  
consumer.setNamesrvAddr("192.168.220.135:9876");  
// 訂閱一個或多個Topic，以及Tag來過濾需要消費的消息。我們訂閱了"MyTopic1"，使用"*"來匹配此Topic下的所有Tag  
consumer.subscribe("MyTopic1", "*");  
// 3.注冊消息監(jiān)聽器，用于處理從Broker接收到的消息。使用MessageListenerConcurrently接口的實現(xiàn)，表示并行消費  
consumer.registerMessageListener(new MessageListenerConcurrently() {  
    @Override  
    // 4.當收到消息時，方法會被調(diào)用。
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext consumeConcurrentlyContext) {  
        // 5.遍歷消息列表，并打印每條消息的內(nèi)容（注意：這里直接打印msg對象不會得到預期的消息內(nèi)容字符串）  
        for (MessageExt msg : msgs) {  
            // 所以我們打印msg.getBody()的內(nèi)容，為了保留消息原樣  
            System.out.println("已收到消息" + msg);  
        }  
        // 6.返回消費狀態(tài)，這里表示消息已成功消費  
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;  
    }  
});  
// 7.啟動消費者實例  
consumer.start();  
// 8.打印日志消費者已啟動  
System.out.println("消費者已啟動");