diff --git a/pay-service/pom.xml b/pay-service/pom.xml index 8d796bc..d319cc0 100644 --- a/pay-service/pom.xml +++ b/pay-service/pom.xml @@ -85,7 +85,6 @@ org.apache.rocketmq rocketmq-client - 5.3.2 diff --git a/pay-service/src/main/java/cn/mayiming/Service/PayService.java b/pay-service/src/main/java/cn/mayiming/Service/PayService.java index 074b782..a2975af 100644 --- a/pay-service/src/main/java/cn/mayiming/Service/PayService.java +++ b/pay-service/src/main/java/cn/mayiming/Service/PayService.java @@ -5,6 +5,7 @@ import cn.mayiming.Entity.PayRecord; import cn.mayiming.Entity.PayTriggerMsgDTO; import cn.mayiming.Mapper.payMapper; import jakarta.annotation.Resource; +import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; diff --git a/pay-service/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.import b/pay-service/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.import new file mode 100644 index 0000000..96d8d2e --- /dev/null +++ b/pay-service/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.import @@ -0,0 +1,2 @@ +# RocketMQ 2.2.3 version does not adapt to SpringBoot3 +org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration \ No newline at end of file diff --git a/pay-service/src/main/resources/application.yml b/pay-service/src/main/resources/application.yml index 9c5ff52..8f9f31f 100644 --- a/pay-service/src/main/resources/application.yml +++ b/pay-service/src/main/resources/application.yml @@ -41,6 +41,8 @@ spring: rocketmq: # NameServer 地址(替换为你的 RocketMQ 服务器IP) name-server: 127.0.0.1:9876 + producer: + group: pay-producer-group consumer: # 消费者组名(必须唯一,建议按服务+用途命名) group: pay-service-consumer diff --git a/pom.xml b/pom.xml index 562261a..743029a 100644 --- a/pom.xml +++ b/pom.xml @@ -18,6 +18,24 @@ 3.2.3 + + + apache-snapshots + Apache Snapshots + https://repository.apache.org/content/repositories/releases/ + + true + + + false + + + + + central + https://repo.maven.apache.org/maven2 + + @@ -87,18 +105,13 @@ org.apache.rocketmq - rocketmq-client-java + rocketmq-client 5.3.2 org.apache.rocketmq rocketmq-spring-boot-starter - 2.3.2 - - - org.apache.rocketmq - rocketmq-client - 5.3.2 + 2.3.4