Initial commit

.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CodeInsightWorkspaceSettings">
+    <option name="optimizeImportsOnTheFly" value="true" />
+  </component>
+</project>
\ No newline at end of file

.idea/workspace.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="AutoImportSettings">
+    <option name="autoReloadType" value="SELECTIVE" />
+  </component>
+  <component name="MavenImportPreferences">
+    <option name="generalSettings">
+      <MavenGeneralSettings>
+        <option name="userSettingsFile" value="$USER_HOME$/Documents/apache-maven-3.6.3/conf/settings.xml" />
+      </MavenGeneralSettings>
+    </option>
+  </component>
+  <component name="PropertiesComponent">
+    <property name="go.import.settings.migrated" value="true" />
+    <property name="settings.editor.selected.configurable" value="MTHome" />
+  </component>
+</project>
\ No newline at end of file

rocketmq-demo/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.kwan</groupId>
+    <artifactId>shuyu</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>
\ No newline at end of file

rocketmq-demo/rocketmq-demo.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_1_8">
+    <output url="file://$MODULE_DIR$/target/classes" />
+    <output-test url="file://$MODULE_DIR$/target/test-classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

rocketmq-demo/src/main/java/base/consumer/Consumer.java

+package base.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.common.message.MessageExt;
+import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
+
+import java.util.List;
+
+/**
+ * 消息的接受者
+ */
+public class Consumer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("base", "*");
+
+        //设定消费模式：负载均衡|广播模式
+        consumer.setMessageModel(MessageModel.BROADCASTING);
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+    }
+}

rocketmq-demo/src/main/java/base/producer/AsyncProducer.java

+package base.producer;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendCallback;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 发送异步消息
+ */
+public class AsyncProducer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 10; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("base", "Tag2", ("Hello World" + i).getBytes());
+            //5.发送异步消息
+            producer.send(msg, new SendCallback() {
+                /**
+                 * 发送成功回调函数
+                 * @param sendResult
+                 */
+                public void onSuccess(SendResult sendResult) {
+                    System.out.println("发送结果：" + sendResult);
+                }
+
+                /**
+                 * 发送失败回调函数
+                 * @param e
+                 */
+                public void onException(Throwable e) {
+                    System.out.println("发送异常：" + e);
+                }
+            });
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(1);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+}

rocketmq-demo/src/main/java/base/producer/OneWayProducer.java

+package base.producer;
+
+import org.apache.rocketmq.client.exception.MQBrokerException;
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 发送单向消息
+ */
+public class OneWayProducer {
+
+    public static void main(String[] args) throws Exception, MQBrokerException {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 3; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("base", "Tag3", ("Hello World，单向消息" + i).getBytes());
+            //5.发送单向消息
+            producer.sendOneway(msg);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(5);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+}

rocketmq-demo/src/main/java/base/producer/SyncProducer.java

+package base.producer;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.client.producer.SendStatus;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 发送同步消息
+ */
+public class SyncProducer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 10; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("springboot-mq", "Tag1", ("Hello World" + i).getBytes());
+            //5.发送消息
+            SendResult result = producer.send(msg);
+            //发送状态
+            SendStatus status = result.getSendStatus();
+
+            System.out.println("发送结果:" + result);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(1);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+}

rocketmq-demo/src/main/java/batch/Consumer.java

+package batch;
+
+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.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("BatchTopic", "*");
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+
+        System.out.println("消费者启动");
+    }
+}

rocketmq-demo/src/main/java/batch/Producer.java

+package batch;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.client.producer.SendStatus;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+
+        List<Message> msgs = new ArrayList<Message>();
+
+
+        //4.创建消息对象，指定主题Topic、Tag和消息体
+        /**
+         * 参数一：消息主题Topic
+         * 参数二：消息Tag
+         * 参数三：消息内容
+         */
+        Message msg1 = new Message("BatchTopic", "Tag1", ("Hello World" + 1).getBytes());
+        Message msg2 = new Message("BatchTopic", "Tag1", ("Hello World" + 2).getBytes());
+        Message msg3 = new Message("BatchTopic", "Tag1", ("Hello World" + 3).getBytes());
+
+        msgs.add(msg1);
+        msgs.add(msg2);
+        msgs.add(msg3);
+
+        //5.发送消息
+        SendResult result = producer.send(msgs);
+        //发送状态
+        SendStatus status = result.getSendStatus();
+
+        System.out.println("发送结果:" + result);
+
+        //线程睡1秒
+        TimeUnit.SECONDS.sleep(1);
+
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+
+}

rocketmq-demo/src/main/java/delay/Consumer.java

+package delay;
+
+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.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("DelayTopic", "*");
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("消息ID：【" + msg.getMsgId() + "】,延迟时间：" + (System.currentTimeMillis() - msg.getStoreTimestamp()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+
+        System.out.println("消费者启动");
+    }
+}

rocketmq-demo/src/main/java/delay/Producer.java

+package delay;
+
+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.client.producer.SendStatus;
+import org.apache.rocketmq.common.message.Message;
+import org.apache.rocketmq.remoting.exception.RemotingException;
+
+import java.util.concurrent.TimeUnit;
+
+public class Producer {
+
+    public static void main(String[] args) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 10; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("DelayTopic", "Tag1", ("Hello World" + i).getBytes());
+            //设定延迟时间
+            //msg.setDelayTimeLevel(2);
+            //5.发送消息
+            SendResult result = producer.send(msg);
+            //发送状态
+            SendStatus status = result.getSendStatus();
+
+            System.out.println("发送结果:" + result);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(1);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+
+}

rocketmq-demo/src/main/java/filter/sql/Consumer.java

+package filter.sql;
+
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.consumer.MessageSelector;
+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.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("FilterSQLTopic", MessageSelector.bySql("i>5"));
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+        System.out.println("消费者启动");
+    }
+}

rocketmq-demo/src/main/java/filter/sql/Producer.java

+package filter.sql;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.client.producer.SendStatus;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.concurrent.TimeUnit;
+
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 10; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("FilterSQLTopic", "Tag1", ("Hello World" + i).getBytes());
+
+            msg.putUserProperty("i", String.valueOf(i));
+
+            //5.发送消息
+            SendResult result = producer.send(msg);
+            //发送状态
+            SendStatus status = result.getSendStatus();
+
+            System.out.println("发送结果:" + result);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(2);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+
+}

rocketmq-demo/src/main/java/filter/tag/Consumer.java

+package filter.tag;
+
+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.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("FilterTagTopic", "Tag1 || Tag2 ");
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+        System.out.println("消费者启动");
+    }
+}

rocketmq-demo/src/main/java/filter/tag/Producer.java

+package filter.tag;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.client.producer.SendStatus;
+import org.apache.rocketmq.common.message.Message;
+
+import java.util.concurrent.TimeUnit;
+
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+
+        for (int i = 0; i < 3; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("FilterTagTopic", "Tag2", ("Hello World" + i).getBytes());
+            //5.发送消息
+            SendResult result = producer.send(msg);
+            //发送状态
+            SendStatus status = result.getSendStatus();
+
+            System.out.println("发送结果:" + result);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(1);
+        }
+
+        //6.关闭生产者producer
+        producer.shutdown();
+    }
+
+}

rocketmq-demo/src/main/java/order/Consumer.java

+package order;
+
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
+import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
+import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
+import org.apache.rocketmq.client.exception.MQClientException;
+import org.apache.rocketmq.common.message.MessageExt;
+
+import java.util.List;
+
+public class Consumer {
+    public static void main(String[] args) throws MQClientException {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("OrderTopic", "*");
+
+        //4.注册消息监听器
+        consumer.registerMessageListener(new MessageListenerOrderly() {
+
+            @Override
+            public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("线程名称：【" + Thread.currentThread().getName() + "】:" + new String(msg.getBody()));
+                }
+                return ConsumeOrderlyStatus.SUCCESS;
+            }
+        });
+
+        //5.启动消费者
+        consumer.start();
+
+        System.out.println("消费者启动");
+
+    }
+}

rocketmq-demo/src/main/java/order/OrderStep.java

+package order;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 订单构建者
+ */
+public class OrderStep {
+    private long orderId;
+    private String desc;
+
+    public long getOrderId() {
+        return orderId;
+    }
+
+    public void setOrderId(long orderId) {
+        this.orderId = orderId;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public void setDesc(String desc) {
+        this.desc = desc;
+    }
+
+    @Override
+    public String toString() {
+        return "OrderStep{" +
+                "orderId=" + orderId +
+                ", desc='" + desc + '\'' +
+                '}';
+    }
+
+    public static List<OrderStep> buildOrders() {
+        //  1039L   : 创建    付款 推送 完成
+        //  1065L   ： 创建   付款
+        //  7235L   ：创建    付款
+        List<OrderStep> orderList = new ArrayList<OrderStep>();
+
+        OrderStep orderDemo = new OrderStep();
+        orderDemo.setOrderId(1039L);
+        orderDemo.setDesc("创建");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1065L);
+        orderDemo.setDesc("创建");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1039L);
+        orderDemo.setDesc("付款");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(7235L);
+        orderDemo.setDesc("创建");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1065L);
+        orderDemo.setDesc("付款");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(7235L);
+        orderDemo.setDesc("付款");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1065L);
+        orderDemo.setDesc("完成");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1039L);
+        orderDemo.setDesc("推送");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(7235L);
+        orderDemo.setDesc("完成");
+        orderList.add(orderDemo);
+
+        orderDemo = new OrderStep();
+        orderDemo.setOrderId(1039L);
+        orderDemo.setDesc("完成");
+        orderList.add(orderDemo);
+
+        return orderList;
+    }
+}

rocketmq-demo/src/main/java/order/Producer.java

+package order;
+
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.apache.rocketmq.client.producer.MessageQueueSelector;
+import org.apache.rocketmq.client.producer.SendResult;
+import org.apache.rocketmq.common.message.Message;
+import org.apache.rocketmq.common.message.MessageQueue;
+
+import java.util.List;
+
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        DefaultMQProducer producer = new DefaultMQProducer("group1");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.启动producer
+        producer.start();
+        //构建消息集合
+        List<OrderStep> orderSteps = OrderStep.buildOrders();
+        //发送消息
+        for (int i = 0; i < orderSteps.size(); i++) {
+            String body = orderSteps.get(i) + "";
+            Message message = new Message("OrderTopic", "Order", "i" + i, body.getBytes());
+            /**
+             * 参数一：消息对象
+             * 参数二：消息队列的选择器
+             * 参数三：选择队列的业务标识（订单ID）
+             */
+            SendResult sendResult = producer.send(message, new MessageQueueSelector() {
+                /**
+                 *
+                 * @param mqs：队列集合
+                 * @param msg：消息对象
+                 * @param arg：业务标识的参数
+                 * @return
+                 */
+                @Override
+                public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {
+                    long orderId = (long) arg;
+                    long index = orderId % mqs.size();
+                    return mqs.get((int) index);
+                }
+            }, orderSteps.get(i).getOrderId());
+
+            System.out.println("发送结果：" + sendResult);
+        }
+        producer.shutdown();
+    }
+
+}

rocketmq-demo/src/main/java/transaction/Consumer.java

+package transaction;
+
+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.common.message.MessageExt;
+
+import java.util.List;
+
+/**
+ * 消息的接受者
+ */
+public class Consumer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消费者Consumer，制定消费者组名
+        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
+        //2.指定Nameserver地址
+        consumer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+        //3.订阅主题Topic和Tag
+        consumer.subscribe("TransactionTopic", "*");
+
+
+        //4.设置回调函数，处理消息
+        consumer.registerMessageListener(new MessageListenerConcurrently() {
+
+            //接受消息内容
+            @Override
+            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
+                for (MessageExt msg : msgs) {
+                    System.out.println("consumeThread=" + Thread.currentThread().getName() + "," + new String(msg.getBody()));
+                }
+                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
+            }
+        });
+        //5.启动消费者consumer
+        consumer.start();
+        System.out.println("生产者启动");
+    }
+}

rocketmq-demo/src/main/java/transaction/Producer.java

+package transaction;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.rocketmq.common.message.Message;
+import org.apache.rocketmq.common.message.MessageExt;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 发送同步消息
+ */
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        //1.创建消息生产者producer，并制定生产者组名
+        TransactionMQProducer producer = new TransactionMQProducer("group5");
+        //2.指定Nameserver地址
+        producer.setNamesrvAddr("192.168.25.135:9876;192.168.25.138:9876");
+
+        //添加事务监听器
+        producer.setTransactionListener(new TransactionListener() {
+            /**
+             * 在该方法中执行本地事务
+             * @param msg
+             * @param arg
+             * @return
+             */
+            @Override
+            public LocalTransactionState executeLocalTransaction(Message msg, Object arg) {
+                if (StringUtils.equals("TAGA", msg.getTags())) {
+                    return LocalTransactionState.COMMIT_MESSAGE;
+                } else if (StringUtils.equals("TAGB", msg.getTags())) {
+                    return LocalTransactionState.ROLLBACK_MESSAGE;
+                } else if (StringUtils.equals("TAGC", msg.getTags())) {
+                    return LocalTransactionState.UNKNOW;
+                }
+                return LocalTransactionState.UNKNOW;
+            }
+
+            /**
+             * 该方法时MQ进行消息事务状态回查
+             * @param msg
+             * @return
+             */
+            @Override
+            public LocalTransactionState checkLocalTransaction(MessageExt msg) {
+                System.out.println("消息的Tag:" + msg.getTags());
+                return LocalTransactionState.COMMIT_MESSAGE;
+            }
+        });
+
+        //3.启动producer
+        producer.start();
+
+        String[] tags = {"TAGA", "TAGB", "TAGC"};
+
+        for (int i = 0; i < 3; i++) {
+            //4.创建消息对象，指定主题Topic、Tag和消息体
+            /**
+             * 参数一：消息主题Topic
+             * 参数二：消息Tag
+             * 参数三：消息内容
+             */
+            Message msg = new Message("TransactionTopic", tags[i], ("Hello World" + i).getBytes());
+            //5.发送消息
+            SendResult result = producer.sendMessageInTransaction(msg, null);
+            //发送状态
+            SendStatus status = result.getSendStatus();
+
+            System.out.println("发送结果:" + result);
+
+            //线程睡1秒
+            TimeUnit.SECONDS.sleep(2);
+        }
+
+        //6.关闭生产者producer
+        //producer.shutdown();
+    }
+}

springboot-rocketmq-consumer/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.itheima.springboot</groupId>
+    <artifactId>springboot-rocketmq-consumer</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.0.1.RELEASE</version>
+    </parent>
+
+    <properties>
+        <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
+    </properties>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>${rocketmq-spring-boot-starter-version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.6</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>
\ No newline at end of file

springboot-rocketmq-consumer/src/main/java/cn/itcast/MQSpringBootApplication.java

+package cn.itcast;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class MQSpringBootApplication {
+
+
+    public static void main(String[] args) {
+        SpringApplication.run(MQSpringBootApplication.class);
+    }
+
+
+}

springboot-rocketmq-consumer/src/main/java/cn/itcast/mq/Consumer.java

+package cn.itcast.mq;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1")
+public class Consumer implements RocketMQListener<String> {
+
+    @Override
+    public void onMessage(String message) {
+        log.info("Receive message："+message);
+    }
+}

springboot-rocketmq-consumer/src/main/resources/application.properties

+rocketmq.name-server=192.168.25.135:9876;192.168.25.138:9876
+rocketmq.producer.group=my-group
\ No newline at end of file

springboot-rocketmq-consumer/target/classes/application.properties

+rocketmq.name-server=192.168.25.135:9876;192.168.25.138:9876
+rocketmq.producer.group=my-group
\ No newline at end of file

springboot-rocketmq-producer/.idea/compiler.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="CompilerConfiguration">
+    <annotationProcessing>
+      <profile name="Maven default annotation processors profile" enabled="true">
+        <sourceOutputDir name="target/generated-sources/annotations" />
+        <sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
+        <outputRelativeToContentRoot value="true" />
+        <module name="springboot-rocketmq-producer" />
+      </profile>
+    </annotationProcessing>
+    <bytecodeTargetLevel>
+      <module name="springboot-rocketmq-producer" target="1.8" />
+    </bytecodeTargetLevel>
+  </component>
+</project>
\ No newline at end of file

springboot-rocketmq-producer/.idea/encodings.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Encoding">
+    <file url="file://$PROJECT_DIR$" charset="UTF-8" />
+  </component>
+</project>
\ No newline at end of file

springboot-rocketmq-producer/.idea/inspectionProfiles/Project_Default.xml

+<component name="InspectionProjectProfileManager">
+  <profile version="1.0">
+    <option name="myName" value="Project Default" />
+    <inspection_tool class="JavaDoc" enabled="true" level="WARNING" enabled_by_default="true">
+      <option name="TOP_LEVEL_CLASS_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="INNER_CLASS_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="METHOD_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="@return@param@throws or @exception" />
+        </value>
+      </option>
+      <option name="FIELD_OPTIONS">
+        <value>
+          <option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
+          <option name="REQUIRED_TAGS" value="" />
+        </value>
+      </option>
+      <option name="IGNORE_DEPRECATED" value="false" />
+      <option name="IGNORE_JAVADOC_PERIOD" value="true" />
+      <option name="IGNORE_DUPLICATED_THROWS" value="false" />
+      <option name="IGNORE_POINT_TO_ITSELF" value="false" />
+      <option name="myAdditionalJavadocTags" value="date" />
+    </inspection_tool>
+  </profile>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_2_3.xml

+<component name="libraryTable">
+  <library name="Maven: ch.qos.logback:logback-classic:1.2.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__ch_qos_logback_logback_core_1_2_3.xml

+<component name="libraryTable">
+  <library name="Maven: ch.qos.logback:logback-core:1.2.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/ch/qos/logback/logback-core/1.2.3/logback-core-1.2.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_alibaba_fastjson_1_2_51.xml

+<component name="libraryTable">
+  <library name="Maven: com.alibaba:fastjson:1.2.51">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/alibaba/fastjson/1.2.51/fastjson-1.2.51.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/alibaba/fastjson/1.2.51/fastjson-1.2.51-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/alibaba/fastjson/1.2.51/fastjson-1.2.51-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_fasterxml_classmate_1_3_4.xml

+<component name="libraryTable">
+  <library name="Maven: com.fasterxml:classmate:1.3.4">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/classmate/1.3.4/classmate-1.3.4.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/classmate/1.3.4/classmate-1.3.4-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/classmate/1.3.4/classmate-1.3.4-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_9_0.xml

+<component name="libraryTable">
+  <library name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-annotations/2.9.0/jackson-annotations-2.9.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-annotations/2.9.0/jackson-annotations-2.9.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-annotations/2.9.0/jackson-annotations-2.9.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_9_5.xml

+<component name="libraryTable">
+  <library name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.5">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-core/2.9.5/jackson-core-2.9.5.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-core/2.9.5/jackson-core-2.9.5-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-core/2.9.5/jackson-core-2.9.5-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_5.xml

+<component name="libraryTable">
+  <library name="Maven: com.fasterxml.jackson.core:jackson-databind:2.9.5">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-databind/2.9.5/jackson-databind-2.9.5.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-databind/2.9.5/jackson-databind-2.9.5-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/fasterxml/jackson/core/jackson-databind/2.9.5/jackson-databind-2.9.5-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_google_guava_guava_19_0.xml

+<component name="libraryTable">
+  <library name="Maven: com.google.guava:guava:19.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/google/guava/guava/19.0/guava-19.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/google/guava/guava/19.0/guava-19.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/google/guava/guava/19.0/guava-19.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_4_0.xml

+<component name="libraryTable">
+  <library name="Maven: com.jayway.jsonpath:json-path:2.4.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml

+<component name="libraryTable">
+  <library name="Maven: com.vaadin.external.google:android-json:0.0.20131108.vaadin1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/com/vaadin/external/google/android-json/0.0.20131108.vaadin1/android-json-0.0.20131108.vaadin1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__commons_cli_commons_cli_1_2.xml

+<component name="libraryTable">
+  <library name="Maven: commons-cli:commons-cli:1.2">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-cli/commons-cli/1.2/commons-cli-1.2-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-cli/commons-cli/1.2/commons-cli-1.2-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__commons_codec_commons_codec_1_11.xml

+<component name="libraryTable">
+  <library name="Maven: commons-codec:commons-codec:1.11">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-codec/commons-codec/1.11/commons-codec-1.11.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-codec/commons-codec/1.11/commons-codec-1.11-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/commons-codec/commons-codec/1.11/commons-codec-1.11-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__io_netty_netty_all_4_1_23_Final.xml

+<component name="libraryTable">
+  <library name="Maven: io.netty:netty-all:4.1.23.Final">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-all/4.1.23.Final/netty-all-4.1.23.Final.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-all/4.1.23.Final/netty-all-4.1.23.Final-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-all/4.1.23.Final/netty-all-4.1.23.Final-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_1_1_33_Fork26.xml

+<component name="libraryTable">
+  <library name="Maven: io.netty:netty-tcnative-boringssl-static:1.1.33.Fork26">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-tcnative-boringssl-static/1.1.33.Fork26/netty-tcnative-boringssl-static-1.1.33.Fork26.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-tcnative-boringssl-static/1.1.33.Fork26/netty-tcnative-boringssl-static-1.1.33.Fork26-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/io/netty/netty-tcnative-boringssl-static/1.1.33.Fork26/netty-tcnative-boringssl-static-1.1.33.Fork26-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__javax_annotation_javax_annotation_api_1_3_2.xml

+<component name="libraryTable">
+  <library name="Maven: javax.annotation:javax.annotation-api:1.3.2">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__javax_validation_validation_api_2_0_1_Final.xml

+<component name="libraryTable">
+  <library name="Maven: javax.validation:validation-api:2.0.1.Final">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/validation/validation-api/2.0.1.Final/validation-api-2.0.1.Final.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/validation/validation-api/2.0.1.Final/validation-api-2.0.1.Final-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/javax/validation/validation-api/2.0.1.Final/validation-api-2.0.1.Final-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__junit_junit_4_12.xml

+<component name="libraryTable">
+  <library name="Maven: junit:junit:4.12">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/junit/junit/4.12/junit-4.12.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/junit/junit/4.12/junit-4.12-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/junit/junit/4.12/junit-4.12-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__net_bytebuddy_byte_buddy_1_7_11.xml

+<component name="libraryTable">
+  <library name="Maven: net.bytebuddy:byte-buddy:1.7.11">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy/1.7.11/byte-buddy-1.7.11.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy/1.7.11/byte-buddy-1.7.11-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy/1.7.11/byte-buddy-1.7.11-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__net_bytebuddy_byte_buddy_agent_1_7_11.xml

+<component name="libraryTable">
+  <library name="Maven: net.bytebuddy:byte-buddy-agent:1.7.11">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy-agent/1.7.11/byte-buddy-agent-1.7.11.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy-agent/1.7.11/byte-buddy-agent-1.7.11-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/bytebuddy/byte-buddy-agent/1.7.11/byte-buddy-agent-1.7.11-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__net_minidev_accessors_smart_1_2.xml

+<component name="libraryTable">
+  <library name="Maven: net.minidev:accessors-smart:1.2">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__net_minidev_json_smart_2_3.xml

+<component name="libraryTable">
+  <library name="Maven: net.minidev:json-smart:2.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/json-smart/2.3/json-smart-2.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/json-smart/2.3/json-smart-2.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/net/minidev/json-smart/2.3/json-smart-2.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_7.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.commons:commons-lang3:3.7">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/commons/commons-lang3/3.7/commons-lang3-3.7.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/commons/commons-lang3/3.7/commons-lang3-3.7-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/commons/commons-lang3/3.7/commons-lang3-3.7-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_10_0.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.logging.log4j:log4j-api:2.10.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-api/2.10.0/log4j-api-2.10.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-api/2.10.0/log4j-api-2.10.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-api/2.10.0/log4j-api-2.10.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_logging_log4j_log4j_to_slf4j_2_10_0.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.logging.log4j:log4j-to-slf4j:2.10.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-to-slf4j/2.10.0/log4j-to-slf4j-2.10.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-to-slf4j/2.10.0/log4j-to-slf4j-2.10.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/logging/log4j/log4j-to-slf4j/2.10.0/log4j-to-slf4j-2.10.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_acl_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-acl:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-acl/4.5.1/rocketmq-acl-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-acl/4.5.1/rocketmq-acl-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-acl/4.5.1/rocketmq-acl-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_client_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-client:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-client/4.5.1/rocketmq-client-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-client/4.5.1/rocketmq-client-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-client/4.5.1/rocketmq-client-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_common_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-common:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-common/4.5.1/rocketmq-common-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-common/4.5.1/rocketmq-common-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-common/4.5.1/rocketmq-common-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_logging_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-logging:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-logging/4.5.1/rocketmq-logging-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-logging/4.5.1/rocketmq-logging-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-logging/4.5.1/rocketmq-logging-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_remoting_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-remoting:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-remoting/4.5.1/rocketmq-remoting-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-remoting/4.5.1/rocketmq-remoting-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-remoting/4.5.1/rocketmq-remoting-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_spring_boot_2_0_3.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-spring-boot:2.0.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot/2.0.3/rocketmq-spring-boot-2.0.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot/2.0.3/rocketmq-spring-boot-2.0.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot/2.0.3/rocketmq-spring-boot-2.0.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_spring_boot_starter_2_0_3.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-spring-boot-starter:2.0.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot-starter/2.0.3/rocketmq-spring-boot-starter-2.0.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot-starter/2.0.3/rocketmq-spring-boot-starter-2.0.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-spring-boot-starter/2.0.3/rocketmq-spring-boot-starter-2.0.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_srvutil_4_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.rocketmq:rocketmq-srvutil:4.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-srvutil/4.5.1/rocketmq-srvutil-4.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-srvutil/4.5.1/rocketmq-srvutil-4.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/rocketmq/rocketmq-srvutil/4.5.1/rocketmq-srvutil-4.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_8_5_29.xml

+<component name="libraryTable">
+  <library name="Maven: org.apache.tomcat.embed:tomcat-embed-el:8.5.29">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/tomcat/embed/tomcat-embed-el/8.5.29/tomcat-embed-el-8.5.29.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/tomcat/embed/tomcat-embed-el/8.5.29/tomcat-embed-el-8.5.29-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/apache/tomcat/embed/tomcat-embed-el/8.5.29/tomcat-embed-el-8.5.29-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_assertj_assertj_core_3_9_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.assertj:assertj-core:3.9.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/assertj/assertj-core/3.9.1/assertj-core-3.9.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/assertj/assertj-core/3.9.1/assertj-core-3.9.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/assertj/assertj-core/3.9.1/assertj-core-3.9.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml

+<component name="libraryTable">
+  <library name="Maven: org.hamcrest:hamcrest-core:1.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml

+<component name="libraryTable">
+  <library name="Maven: org.hamcrest:hamcrest-library:1.3">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-library/1.3/hamcrest-library-1.3.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-library/1.3/hamcrest-library-1.3-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hamcrest/hamcrest-library/1.3/hamcrest-library-1.3-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_hibernate_validator_hibernate_validator_6_0_9_Final.xml

+<component name="libraryTable">
+  <library name="Maven: org.hibernate.validator:hibernate-validator:6.0.9.Final">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hibernate/validator/hibernate-validator/6.0.9.Final/hibernate-validator-6.0.9.Final.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hibernate/validator/hibernate-validator/6.0.9.Final/hibernate-validator-6.0.9.Final-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/hibernate/validator/hibernate-validator/6.0.9.Final/hibernate-validator-6.0.9.Final-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_2_Final.xml

+<component name="libraryTable">
+  <library name="Maven: org.jboss.logging:jboss-logging:3.3.2.Final">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/jboss/logging/jboss-logging/3.3.2.Final/jboss-logging-3.3.2.Final.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/jboss/logging/jboss-logging/3.3.2.Final/jboss-logging-3.3.2.Final-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/jboss/logging/jboss-logging/3.3.2.Final/jboss-logging-3.3.2.Final-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_mockito_mockito_core_2_15_0.xml

+<component name="libraryTable">
+  <library name="Maven: org.mockito:mockito-core:2.15.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/mockito/mockito-core/2.15.0/mockito-core-2.15.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/mockito/mockito-core/2.15.0/mockito-core-2.15.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/mockito/mockito-core/2.15.0/mockito-core-2.15.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_objenesis_objenesis_2_6.xml

+<component name="libraryTable">
+  <library name="Maven: org.objenesis:objenesis:2.6">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/objenesis/objenesis/2.6/objenesis-2.6.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/objenesis/objenesis/2.6/objenesis-2.6-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/objenesis/objenesis/2.6/objenesis-2.6-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_ow2_asm_asm_5_0_4.xml

+<component name="libraryTable">
+  <library name="Maven: org.ow2.asm:asm:5.0.4">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_projectlombok_lombok_1_18_6.xml

+<component name="libraryTable">
+  <library name="Maven: org.projectlombok:lombok:1.18.6">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/projectlombok/lombok/1.18.6/lombok-1.18.6.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/projectlombok/lombok/1.18.6/lombok-1.18.6-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/projectlombok/lombok/1.18.6/lombok-1.18.6-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_5_0.xml

+<component name="libraryTable">
+  <library name="Maven: org.skyscreamer:jsonassert:1.5.0">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/skyscreamer/jsonassert/1.5.0/jsonassert-1.5.0.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/skyscreamer/jsonassert/1.5.0/jsonassert-1.5.0-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/skyscreamer/jsonassert/1.5.0/jsonassert-1.5.0-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_25.xml

+<component name="libraryTable">
+  <library name="Maven: org.slf4j:jul-to-slf4j:1.7.25">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/jul-to-slf4j/1.7.25/jul-to-slf4j-1.7.25-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_25.xml

+<component name="libraryTable">
+  <library name="Maven: org.slf4j:slf4j-api:1.7.25">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/slf4j/slf4j-api/1.7.25/slf4j-api-1.7.25-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot/2.0.1.RELEASE/spring-boot-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot/2.0.1.RELEASE/spring-boot-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot/2.0.1.RELEASE/spring-boot-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-autoconfigure:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-autoconfigure/2.0.1.RELEASE/spring-boot-autoconfigure-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-autoconfigure/2.0.1.RELEASE/spring-boot-autoconfigure-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-autoconfigure/2.0.1.RELEASE/spring-boot-autoconfigure-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-starter:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter/2.0.1.RELEASE/spring-boot-starter-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter/2.0.1.RELEASE/spring-boot-starter-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter/2.0.1.RELEASE/spring-boot-starter-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-starter-logging:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-logging/2.0.1.RELEASE/spring-boot-starter-logging-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-logging/2.0.1.RELEASE/spring-boot-starter-logging-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-logging/2.0.1.RELEASE/spring-boot-starter-logging-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-starter-test:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-test/2.0.1.RELEASE/spring-boot-starter-test-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-test/2.0.1.RELEASE/spring-boot-starter-test-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-test/2.0.1.RELEASE/spring-boot-starter-test-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_validation_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-starter-validation:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-validation/2.0.1.RELEASE/spring-boot-starter-validation-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-validation/2.0.1.RELEASE/spring-boot-starter-validation-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-starter-validation/2.0.1.RELEASE/spring-boot-starter-validation-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-test:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test/2.0.1.RELEASE/spring-boot-test-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test/2.0.1.RELEASE/spring-boot-test-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test/2.0.1.RELEASE/spring-boot-test-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_0_1_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework.boot:spring-boot-test-autoconfigure:2.0.1.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test-autoconfigure/2.0.1.RELEASE/spring-boot-test-autoconfigure-2.0.1.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test-autoconfigure/2.0.1.RELEASE/spring-boot-test-autoconfigure-2.0.1.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/boot/spring-boot-test-autoconfigure/2.0.1.RELEASE/spring-boot-test-autoconfigure-2.0.1.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_aop_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-aop:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-aop/5.0.5.RELEASE/spring-aop-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-aop/5.0.5.RELEASE/spring-aop-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-aop/5.0.5.RELEASE/spring-aop-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_beans_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-beans:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-beans/5.0.5.RELEASE/spring-beans-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-beans/5.0.5.RELEASE/spring-beans-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-beans/5.0.5.RELEASE/spring-beans-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_context_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-context:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-context/5.0.5.RELEASE/spring-context-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-context/5.0.5.RELEASE/spring-context-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-context/5.0.5.RELEASE/spring-context-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_core_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-core:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-core/5.0.5.RELEASE/spring-core-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-core/5.0.5.RELEASE/spring-core-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-core/5.0.5.RELEASE/spring-core-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_expression_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-expression:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-expression/5.0.5.RELEASE/spring-expression-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-expression/5.0.5.RELEASE/spring-expression-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-expression/5.0.5.RELEASE/spring-expression-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_jcl_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-jcl:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-jcl/5.0.5.RELEASE/spring-jcl-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-jcl/5.0.5.RELEASE/spring-jcl-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-jcl/5.0.5.RELEASE/spring-jcl-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_messaging_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-messaging:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-messaging/5.0.5.RELEASE/spring-messaging-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-messaging/5.0.5.RELEASE/spring-messaging-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-messaging/5.0.5.RELEASE/spring-messaging-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_springframework_spring_test_5_0_5_RELEASE.xml

+<component name="libraryTable">
+  <library name="Maven: org.springframework:spring-test:5.0.5.RELEASE">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-test/5.0.5.RELEASE/spring-test-5.0.5.RELEASE.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-test/5.0.5.RELEASE/spring-test-5.0.5.RELEASE-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/springframework/spring-test/5.0.5.RELEASE/spring-test-5.0.5.RELEASE-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_xmlunit_xmlunit_core_2_5_1.xml

+<component name="libraryTable">
+  <library name="Maven: org.xmlunit:xmlunit-core:2.5.1">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/xmlunit/xmlunit-core/2.5.1/xmlunit-core-2.5.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/xmlunit/xmlunit-core/2.5.1/xmlunit-core-2.5.1-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/xmlunit/xmlunit-core/2.5.1/xmlunit-core-2.5.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/libraries/Maven__org_yaml_snakeyaml_1_19.xml

+<component name="libraryTable">
+  <library name="Maven: org.yaml:snakeyaml:1.19">
+    <CLASSES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/yaml/snakeyaml/1.19/snakeyaml-1.19.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/yaml/snakeyaml/1.19/snakeyaml-1.19-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://D:/develop/apache-maven-3.3.9/repository/org/yaml/snakeyaml/1.19/snakeyaml-1.19-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>
\ No newline at end of file

springboot-rocketmq-producer/.idea/misc.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="MavenProjectsManager">
+    <option name="originalFiles">
+      <list>
+        <option value="$PROJECT_DIR$/pom.xml" />
+      </list>
+    </option>
+  </component>
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_9" default="false" project-jdk-name="1.8" project-jdk-type="JavaSDK" />
+</project>
\ No newline at end of file

springboot-rocketmq-producer/.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/springboot-rocketmq-producer.iml" filepath="$PROJECT_DIR$/springboot-rocketmq-producer.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

springboot-rocketmq-producer/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.0.1.RELEASE</version>
+    </parent>
+
+    <groupId>com.itheima.springboot</groupId>
+    <artifactId>springboot-rocketmq-producer</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <rocketmq-spring-boot-starter-version>2.0.3</rocketmq-spring-boot-starter-version>
+    </properties>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>${rocketmq-spring-boot-starter-version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.6</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>
\ No newline at end of file