Spring Cloud Stream RocketMQ 入门

skymysky · Jun 28, 2020 · 1b1488e · 1b1488e
1 parent ce1d5b7
commit 1b1488e
Show file tree

Hide file tree

Showing 83 changed files with 21 additions and 21 deletions.
diff --git a/README.md b/README.md
@@ -161,9 +161,9 @@
 * [《芋道 Spring Cloud Alibaba 注册中心 Nacos 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Nacos-Discovery/?github) 对应 [labx-01-spring-cloud-alibaba-nacos-discovery](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-01-spring-cloud-alibaba-nacos-discovery)
 * [《芋道 Spring Cloud Alibaba 服务调用 Dubbo 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Dubbo/?github) 对应 [labx-07](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-07)
 * [《芋道 Spring Cloud Alibaba 服务容错 Sentinel 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Sentinel/?github) 对应 [labx-04-spring-cloud-alibaba-sentinel](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-04-spring-cloud-alibaba-sentinel)
-* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06)
+* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06-spring-cloud-stream-rocketmq](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06-spring-cloud-stream-rocketmq)
 * [《芋道 Spring Cloud Alibaba 事件总线 Bus RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Bus-RocketMQ/?github) 对应 [labx-20](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-20)
-* [《芋道 Spring Cloud Alibaba 配置中心 Nacos 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Nacos-Config/?github) 对应 [labx-05](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-05)
+* [《芋道 Spring Cloud Alibaba 配置中心 Nacos 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Nacos-Config/?github) 对应 [labx-05-spring-cloud-alibaba-nacos-config](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-05-spring-cloud-alibaba-nacos-config)
 * [《芋道 Spring Cloud Alibaba 分布式事务 Seata 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Seata/?github) 对应 [labx-17](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-17)
 
 ## 推荐搭配食用
@@ -212,7 +212,7 @@
 
 ## 配置中心
 
-* [《芋道 Spring Cloud Alibaba 配置中心 Nacos 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Nacos-Config/?github) 对应 [labx-05](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-05)
+* [《芋道 Spring Cloud Alibaba 配置中心 Nacos 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Nacos-Config/?github) 对应 [labx-05-spring-cloud-alibaba-nacos-config](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-05-spring-cloud-alibaba-nacos-config)
 * [《芋道 Spring Cloud 配置中心 Apollo 入门》](http://www.iocoder.cn/Spring-Cloud/Apollo/?github) 对应 [labx-09](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-09)
 * [《芋道 Spring Cloud 配置中心 Spring Cloud Config 入门》](http://www.iocoder.cn/Spring-Cloud/Spring-Cloud-Config/?github) 对应 [labx-12](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-12)
 * [《芋道 Spring Cloud 配置中心 Zookeeper 入门》](http://www.iocoder.cn/Spring-Cloud/ZooKeeper-Config/?github) 对应 [labx-26](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-26)
@@ -222,7 +222,7 @@
 ## 消息队列
 
 **Spring Cloud Stream**
-* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06)
+* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06-spring-cloud-stream-rocketmq](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06-spring-cloud-stream-rocketmq)
 * [《芋道 Spring Cloud 消息队列 RabbitMQ 入门》](http://www.iocoder.cn/Spring-Cloud/RabbitMQ/?github) 对应 [labx-10](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-10)
 * [《芋道 Spring Cloud 消息队列 Kafka 入门》](http://www.iocoder.cn/Spring-Cloud/Kafka/?github) 对应 [labx-11](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-11)
 * [《芋道 Spring Cloud 消息队列 ActiveMQ 入门》](http://www.iocoder.cn/Spring-Cloud/ActiveMQ/?github)
@@ -322,7 +322,7 @@
 
 * [《RocketMQ 极简入门》](http://www.iocoder.cn/RocketMQ/install/?github)
 * [《芋道 Spring Boot 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Boot/RocketMQ/?github) 对应 [lab-31](https://github.com/YunaiV/SpringBoot-Labs/tree/master/lab-31)
-* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06)
+* [《芋道 Spring Cloud Alibaba 消息队列 RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/RocketMQ/?github) 对应 [labx-06-spring-cloud-stream-rocketmq](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-06-spring-cloud-stream-rocketmq)
 * [《芋道 Spring Cloud Alibaba 事件总线 Bus RocketMQ 入门》](http://www.iocoder.cn/Spring-Cloud-Alibaba/Bus-RocketMQ/?github) 对应 [labx-20](https://github.com/YunaiV/SpringBoot-Labs/tree/master/labx-20)
 * [《芋道 RocketMQ 源码解析系列》](http://www.iocoder.cn/categories/RocketMQ/?github)
 * [《性能测试 —— RocketMQ 基准测试》](http://www.iocoder.cn/Performance-Testing/RocketMQ-benchmark/?github)

diff --git a/...stream-rocketmq-consumer-actuator/pom.xml → ...stream-rocketmq-consumer-actuator/pom.xml b/...stream-rocketmq-consumer-actuator/pom.xml → ...stream-rocketmq-consumer-actuator/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml b/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml
diff --git a/...a-stream-rocketmq-consumer-aliyun/pom.xml → ...a-stream-rocketmq-consumer-aliyun/pom.xml b/...a-stream-rocketmq-consumer-aliyun/pom.xml → ...a-stream-rocketmq-consumer-aliyun/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...aliyun/src/main/resources/application.yml → ...aliyun/src/main/resources/application.yml b/...aliyun/src/main/resources/application.yml → ...aliyun/src/main/resources/application.yml
diff --git a/...am-rocketmq-consumer-broadcasting/pom.xml → ...am-rocketmq-consumer-broadcasting/pom.xml b/...am-rocketmq-consumer-broadcasting/pom.xml → ...am-rocketmq-consumer-broadcasting/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...asting/src/main/resources/application.yml → ...asting/src/main/resources/application.yml b/...asting/src/main/resources/application.yml → ...asting/src/main/resources/application.yml
diff --git a/...sca-stream-rocketmq-consumer-demo/pom.xml → ...sca-stream-rocketmq-consumer-demo/pom.xml b/...sca-stream-rocketmq-consumer-demo/pom.xml → ...sca-stream-rocketmq-consumer-demo/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml b/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml
diff --git a/...m-rocketmq-consumer-error-handler/pom.xml → ...m-rocketmq-consumer-error-handler/pom.xml b/...m-rocketmq-consumer-error-handler/pom.xml → ...m-rocketmq-consumer-error-handler/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...andler/src/main/resources/application.yml → ...andler/src/main/resources/application.yml b/...andler/src/main/resources/application.yml → ...andler/src/main/resources/application.yml
diff --git a/...a-stream-rocketmq-consumer-filter/pom.xml → ...a-stream-rocketmq-consumer-filter/pom.xml b/...a-stream-rocketmq-consumer-filter/pom.xml → ...a-stream-rocketmq-consumer-filter/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...filter/src/main/resources/application.yml → ...filter/src/main/resources/application.yml b/...filter/src/main/resources/application.yml → ...filter/src/main/resources/application.yml
diff --git a/...-stream-rocketmq-consumer-orderly/pom.xml → ...-stream-rocketmq-consumer-orderly/pom.xml b/...-stream-rocketmq-consumer-orderly/pom.xml → ...-stream-rocketmq-consumer-orderly/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...rderly/src/main/resources/application.yml → ...rderly/src/main/resources/application.yml b/...rderly/src/main/resources/application.yml → ...rderly/src/main/resources/application.yml
diff --git a/...ca-stream-rocketmq-consumer-retry/pom.xml → ...ca-stream-rocketmq-consumer-retry/pom.xml b/...ca-stream-rocketmq-consumer-retry/pom.xml → ...ca-stream-rocketmq-consumer-retry/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java b/...emo/consumerdemo/ConsumerApplication.java → ...emo/consumerdemo/ConsumerApplication.java
diff --git a/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java b/...consumerdemo/listener/Demo01Consumer.java → ...consumerdemo/listener/Demo01Consumer.java
diff --git a/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java b/...tmqdemo/consumerdemo/listener/MySink.java → ...tmqdemo/consumerdemo/listener/MySink.java
diff --git a/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java b/...o/consumerdemo/message/Demo01Message.java → ...o/consumerdemo/message/Demo01Message.java
diff --git a/...-retry/src/main/resources/application.yml → ...-retry/src/main/resources/application.yml b/...-retry/src/main/resources/application.yml → ...-retry/src/main/resources/application.yml
diff --git a/...stream-rocketmq-producer-actuator/pom.xml → ...stream-rocketmq-producer-actuator/pom.xml b/...stream-rocketmq-producer-actuator/pom.xml → ...stream-rocketmq-producer-actuator/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java b/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java
diff --git a/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java b/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java
diff --git a/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java b/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java
diff --git a/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java b/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java
diff --git a/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml b/...tuator/src/main/resources/application.yml → ...tuator/src/main/resources/application.yml
diff --git a/...a-stream-rocketmq-producer-aliyun/pom.xml → ...a-stream-rocketmq-producer-aliyun/pom.xml b/...a-stream-rocketmq-producer-aliyun/pom.xml → ...a-stream-rocketmq-producer-aliyun/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java b/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java
diff --git a/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java b/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java
diff --git a/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java b/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java
diff --git a/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java b/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java
diff --git a/...aliyun/src/main/resources/application.yml → ...aliyun/src/main/resources/application.yml b/...aliyun/src/main/resources/application.yml → ...aliyun/src/main/resources/application.yml
diff --git a/...sca-stream-rocketmq-producer-demo/pom.xml → ...sca-stream-rocketmq-producer-demo/pom.xml b/...sca-stream-rocketmq-producer-demo/pom.xml → ...sca-stream-rocketmq-producer-demo/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java b/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java
diff --git a/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java b/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java
diff --git a/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java b/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java
diff --git a/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java b/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java
diff --git a/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml b/...r-demo/src/main/resources/application.yml → ...r-demo/src/main/resources/application.yml
diff --git a/...-stream-rocketmq-producer-orderly/pom.xml → ...-stream-rocketmq-producer-orderly/pom.xml b/...-stream-rocketmq-producer-orderly/pom.xml → ...-stream-rocketmq-producer-orderly/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java b/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java
diff --git a/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java b/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java
diff --git a/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java b/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java
diff --git a/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java b/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java
diff --git a/...rderly/src/main/resources/application.yml → ...rderly/src/main/resources/application.yml b/...rderly/src/main/resources/application.yml → ...rderly/src/main/resources/application.yml
diff --git a/...eam-rocketmq-producer-transaction/pom.xml → ...eam-rocketmq-producer-transaction/pom.xml b/...eam-rocketmq-producer-transaction/pom.xml → ...eam-rocketmq-producer-transaction/pom.xml
@@ -3,7 +3,7 @@
          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">
     <parent>
-        <artifactId>labx-06</artifactId>
+        <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
         <groupId>cn.iocoder.springboot.labs</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>

diff --git a/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java b/...emo/producerdemo/ProducerApplication.java → ...emo/producerdemo/ProducerApplication.java
diff --git a/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java b/...ucerdemo/controller/Demo01Controller.java → ...ucerdemo/controller/Demo01Controller.java
diff --git a/...emo/listener/TransactionListenerImpl.java → ...emo/listener/TransactionListenerImpl.java b/...emo/listener/TransactionListenerImpl.java → ...emo/listener/TransactionListenerImpl.java
diff --git a/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java b/...o/producerdemo/message/Demo01Message.java → ...o/producerdemo/message/Demo01Message.java
diff --git a/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java b/...mqdemo/producerdemo/message/MySource.java → ...mqdemo/producerdemo/message/MySource.java
diff --git a/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml b/...action/src/main/resources/application.yml → ...action/src/main/resources/application.yml
diff --git a/labx-06/pom.xml → labx-06-spring-cloud-stream-rocketmq/pom.xml b/labx-06/pom.xml → labx-06-spring-cloud-stream-rocketmq/pom.xml
@@ -9,7 +9,7 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <artifactId>labx-06</artifactId>
+    <artifactId>labx-06-spring-cloud-stream-rocketmq</artifactId>
     <packaging>pom</packaging>
     <modules>
         <module>labx-06-sca-stream-rocketmq-consumer-demo</module>

diff --git a/...Spring Cloud Alibaba 消息队列 RocketMQ 入门》.md → ...Spring Cloud Alibaba 消息队列 RocketMQ 入门》.md b/...Spring Cloud Alibaba 消息队列 RocketMQ 入门》.md → ...Spring Cloud Alibaba 消息队列 RocketMQ 入门》.md
diff --git a/pom.xml b/pom.xml
@@ -85,8 +85,8 @@
 <!--        <module>labx-02-spring-cloud-netflix-ribbon</module>-->
 <!--        <module>labx-03-spring-cloud-feign</module>-->
 <!--        <module>labx-04-spring-cloud-alibaba-sentinel</module>-->
-        <module>labx-05-spring-cloud-alibaba-nacos-config</module>
-<!--        <module>labx-06</module>-->
+<!--        <module>labx-05-spring-cloud-alibaba-nacos-config</module>-->
+        <module>labx-06-spring-cloud-stream-rocketmq</module>
 <!--        <module>labx-07</module>-->
 <!--        <module>labx-08</module>-->
 <!--        <module>labx-09</module>-->