1. 修复 seata 配置错误

2. 引入 Spring Cloud Stream RocketMQ 依赖

order/order-service-impl/pom.xml

@@ -100,8 +100,8 @@
 
         <!-- MQ 相关 -->
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
+            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
         </dependency>
 
         <!-- Job 相关 -->

order/order-service-impl/src/main/resources/config/application.yaml

@@ -78,6 +78,12 @@ logging:
 
 # Seata 配置项
 seata:
+  tx-service-group: default # Seata 事务组编号，用于 TC 集群名
+  # 服务配置项，对应 ServiceProperties 类
+  service:
+    # 虚拟组和分组的映射
+    vgroup-mapping:
+      default: default
   # Seata 注册中心配置项
   registry:
     type: nacos # 注册中心类型

pay/pay-service-impl/pom.xml

@@ -74,8 +74,8 @@
 
         <!-- MQ 相关 -->
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
+            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
         </dependency>
 
         <!-- Job 相关 -->

pay/pay-service-impl/src/main/resources/config/application.yaml

@@ -50,6 +50,12 @@ rocketmq:
 
 # Seata 配置项
 seata:
+  tx-service-group: default # Seata 事务组编号，用于 TC 集群名
+  # 服务配置项，对应 ServiceProperties 类
+  service:
+    # 虚拟组和分组的映射
+    vgroup-mapping:
+      default: default
   # Seata 注册中心配置项
   registry:
     type: nacos # 注册中心类型

pom.xml

@@ -47,7 +47,6 @@
         <mybatis-plus.version>3.1.1</mybatis-plus.version>
         <xxl-job.version>2.0.1</xxl-job.version>
         <guava.version>27.0.1-jre</guava.version>
-        <rocketmq-spring-boot-starter.version>2.0.1</rocketmq-spring-boot-starter.version>
 
         <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
         <org.projectlombok.version>1.16.14</org.projectlombok.version>
@@ -171,13 +170,6 @@
                 <version>${xxl-job.version}</version>
             </dependency>
 
-            <!-- MQ 相关 -->
-            <dependency>
-                <groupId>org.apache.rocketmq</groupId>
-                <artifactId>rocketmq-spring-boot-starter</artifactId>
-                <version>${rocketmq-spring-boot-starter.version}</version>
-            </dependency>
-
             <!-- 云服务相关 -->
             <dependency>
                 <groupId>com.qiniu</groupId>

product/product-service-impl/src/main/resources/config/application.yaml

@@ -70,6 +70,12 @@ dubbo:
 
 # Seata 配置项
 seata:
+  tx-service-group: default # Seata 事务组编号，用于 TC 集群名
+  # 服务配置项，对应 ServiceProperties 类
+  service:
+    # 虚拟组和分组的映射
+    vgroup-mapping:
+      default: default
   # Seata 注册中心配置项
   registry:
     type: nacos # 注册中心类型
@@ -77,3 +83,4 @@ seata:
       serverAddr: ${spring.cloud.nacos.discovery.server-addr} # Nacos 服务地址
       namespace: # Nacos 命名空间
       cluster: default # 使用的 Seata 分组
+

promotion/promotion-service-impl/pom.xml

@@ -66,10 +66,16 @@
             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
         </dependency>
 
+        <!-- Transaction 相关 -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-alibaba-seata</artifactId>
+        </dependency>
+
         <!-- MQ 相关 -->
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
+            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
         </dependency>
 
         <!-- Job 相关 -->

promotion/promotion-service-impl/src/main/resources/config/application.yaml

@@ -56,6 +56,12 @@ dubbo:
 
 # Seata 配置项
 seata:
+  tx-service-group: default # Seata 事务组编号，用于 TC 集群名
+  # 服务配置项，对应 ServiceProperties 类
+  service:
+    # 虚拟组和分组的映射
+    vgroup-mapping:
+      default: default
   # Seata 注册中心配置项
   registry:
     type: nacos # 注册中心类型

search/search-service-impl/pom.xml

@@ -54,8 +54,8 @@
 
         <!-- MQ 相关 -->
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
+            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
         </dependency>
 
         <!-- 工具类相关 -->

user/user-service-impl/pom.xml

@@ -67,8 +67,8 @@
 
         <!-- MQ 相关 -->
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
+            <groupId>com.alibaba.cloud</groupId>
-            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
         </dependency>
 
     </dependencies>