diff --git a/pom.xml b/pom.xml
index 9c7072e80bf5d0e0cef2a1eab8ef391efa5eefba..b5c31496f08616cac8946f4dba2fe932da9ad31f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -63,6 +63,11 @@
 			<artifactId>log4j-core</artifactId>
 			<version>2.17.2</version>
 		</dependency>
+		<dependency>
+			<groupId>org.apache.rocketmq</groupId>
+			<artifactId>rocketmq-client</artifactId>
+			<version>4.7.1</version>
+		</dependency>
 
 	</dependencies>
 
diff --git a/src/main/java/com/example/demo/rocketmq/MqConsumer.java b/src/main/java/com/example/demo/rocketmq/MqConsumer.java
new file mode 100644
index 0000000000000000000000000000000000000000..05e404f902690650441e3ac6248ae20c9aaeb22a
--- /dev/null
+++ b/src/main/java/com/example/demo/rocketmq/MqConsumer.java
@@ -0,0 +1,22 @@
+package com.example.demo.rocketmq;
+
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
+
+public class MqConsumer {
+    private static DefaultMQPushConsumer consumer=new DefaultMQPushConsumer("myConsumer");
+    private static int initialstate=0;
+
+    public MqConsumer() {
+    }
+    public static DefaultMQPushConsumer getDefaultMQPushConsumer(){
+        if(consumer==null){
+            consumer=new DefaultMQPushConsumer("myConsumer");
+        }
+        if(initialstate==0){
+            consumer.setNamesrvAddr("103.160.151.37:9876");
+            consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+        }
+        return consumer;
+    }
+}
diff --git a/src/main/java/com/example/demo/rocketmq/MqConsumerTest.java b/src/main/java/com/example/demo/rocketmq/MqConsumerTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..b3baf36f461ca6719f49899380f231392457b23f
--- /dev/null
+++ b/src/main/java/com/example/demo/rocketmq/MqConsumerTest.java
@@ -0,0 +1,39 @@
+package com.example.demo.rocketmq;
+
+import com.sun.org.apache.xpath.internal.operations.String;
+import lombok.extern.slf4j.Slf4j;
+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;
+@Slf4j
+public class MqConsumerTest {
+    public static void main(String[] args) {
+
+    }
+    public static void receiveMsg(){
+        DefaultMQPushConsumer consumer=MqConsumer.getDefaultMQPushConsumer();
+        try {
+            consumer.subscribe("TopicTest","*");
+            consumer.registerMessageListener(new MessageListenerConcurrently() {
+                @Override
+                public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
+                    MessageExt msg=msgs.get(0);
+                    if(msg.getTopic().equals("TopicTest")){
+                        if(msg.getTags().equals("TagA")){
+                            log.error(msg.getBody().toString());
+                        }
+                    }
+                    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+                }
+            });
+            consumer.start();
+        } catch (MQClientException e) {
+            e.printStackTrace();
+        }
+    }
+}
diff --git a/src/main/java/com/example/demo/rocketmq/MqProducer.java b/src/main/java/com/example/demo/rocketmq/MqProducer.java
new file mode 100644
index 0000000000000000000000000000000000000000..3fc69418cc154b87a777b928b0d04ef04fc34dfa
--- /dev/null
+++ b/src/main/java/com/example/demo/rocketmq/MqProducer.java
@@ -0,0 +1,38 @@
+package com.example.demo.rocketmq;
+
+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.common.RemotingHelper;
+
+public class MqProducer {
+    // 实例化消息生产者Producer
+    private static DefaultMQProducer producer = new DefaultMQProducer("myProducer");
+    private static int initialState=0;
+
+    public MqProducer() {
+    }
+    public static DefaultMQProducer getDefaultMQProducer() throws MQClientException {
+        if(producer==null){
+            producer=new DefaultMQProducer("myProducer");
+        }
+        if(initialState==0){
+            // 设置NameServer的地址
+            producer.setNamesrvAddr("103.160.151.37:9876");
+            // 启动Producer实例
+            producer.start();
+            initialState=1;
+        }
+        return producer;
+    }
+
+    public static void main(String[] args) throws Exception {
+
+
+
+
+
+    }
+}
+
diff --git a/src/main/java/com/example/demo/rocketmq/MqProducerTest.java b/src/main/java/com/example/demo/rocketmq/MqProducerTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..c5c5d0ea7e1ccd4c406276c2d3b3034849e23155
--- /dev/null
+++ b/src/main/java/com/example/demo/rocketmq/MqProducerTest.java
@@ -0,0 +1,48 @@
+package com.example.demo.rocketmq;
+
+import lombok.extern.slf4j.Slf4j;
+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.common.RemotingHelper;
+import org.apache.rocketmq.remoting.exception.RemotingException;
+
+import java.io.UnsupportedEncodingException;
+@Slf4j
+public class MqProducerTest {
+    public static void main(String[] args) {
+        sendMsg();
+    }
+    public static void sendMsg() {
+        DefaultMQProducer producer= null;
+        try {
+            producer = MqProducer.getDefaultMQProducer();
+            for (int i = 0; i < 100; i++) {
+                // 创建消息，并指定Topic，Tag和消息体
+                Message msg = new Message(
+                        "TopicTest" /* Topic */,
+                        "TagA" /* Tag */,
+                        ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
+                );
+                // 发送消息到一个Broker
+                SendResult sendResult = producer.send(msg);
+                // 通过sendResult返回消息是否成功送达
+                //System.out.printf("%s%n", sendResult);
+                log.error(sendResult.toString());
+            }
+        } catch (MQClientException | UnsupportedEncodingException e) {
+            e.printStackTrace();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } catch (RemotingException e) {
+            e.printStackTrace();
+        } catch (MQBrokerException e) {
+            e.printStackTrace();
+        }
+        // 如果不再发送消息，关闭Producer实例。
+        producer.shutdown();
+    }
+
+}