From 7633bc5d5e0cdc845d604cc1596b6f8856125d5d Mon Sep 17 00:00:00 2001 From: HuangLei Date: Wed, 18 Jun 2025 15:38:09 +0800 Subject: [PATCH] =?UTF-8?q?refactor(mq):=20=E7=A7=BB=E9=99=A4=20RocketMQ?= =?UTF-8?q?=20=E6=B6=88=E8=B4=B9=E8=80=85=E5=92=8C=E7=94=9F=E4=BA=A7?= =?UTF-8?q?=E8=80=85=E7=A4=BA=E4=BE=8B=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 删除了 yudao-spring-boot-starter-mq 模块中的 Consumer 和 Product 类 - 在 yudao-server 模块中添加了 yudao-spring-boot-starter-mq 依赖 - 更新了 YudaoServerApplication 类，扫描 framework 包 - 在 pom.xml 中添加了 maven-compiler-plugin配置，支持 Java 17 --- pom.xml | 23 +++++++++++----- .../framework/mq/rocketmq/core/Consumer.java | 26 ------------------- .../framework/mq/rocketmq/core/Product.java | 26 ------------------- yudao-server/pom.xml | 6 +++++ .../yudao/server/YudaoServerApplication.java | 5 ++-- 5 files changed, 25 insertions(+), 61 deletions(-) delete mode 100644 yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java delete mode 100644 yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java diff --git a/pom.xml b/pom.xml index e9dfb5757d..6bcbdf5f80 100644 --- a/pom.xml +++ b/pom.xml @@ -15,16 +15,16 @@ yudao-module-system yudao-module-infra - - + + yudao-module-report - + yudao-module-pay - - - + + + yudao-module-ai - + ${project.artifactId} @@ -134,6 +134,15 @@ + + org.apache.maven.plugins + maven-compiler-plugin + + 17 + 17 + UTF-8 + + diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java deleted file mode 100644 index f4099592ec..0000000000 --- a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java +++ /dev/null @@ -1,26 +0,0 @@ -package cn.iocoder.yudao.framework.mq.rocketmq.core; - -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; -import org.apache.rocketmq.spring.core.RocketMQListener; -import org.springframework.stereotype.Component; - -/** - * - - * - * @author HuangLei - * @since 2025-06-18 - */ -@Component -@Slf4j -@RequiredArgsConstructor -@RocketMQMessageListener( - topic = TopicNameConstants.PAY_REFUND_ORDER, - consumerGroup = GroupConstants.PAY_ORDER_REFUND_GROUP) -public class Consumer implements RocketMQListener { - @Override - public void onMessage(String message) { - log.info("【消费】- {}", message); - } -} \ No newline at end of file diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java deleted file mode 100644 index 8f61bc3e48..0000000000 --- a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java +++ /dev/null @@ -1,26 +0,0 @@ -package cn.iocoder.yudao.framework.mq.rocketmq.core; - -import cn.iocoder.yudao.framework.common.util.json.JsonUtils; -import jakarta.annotation.PostConstruct; -import lombok.AllArgsConstructor; -import org.apache.rocketmq.spring.core.RocketMQTemplate; -import org.springframework.stereotype.Component; - -/** - * @author HuangLei - * @since 2025-06-18 - */ -@Component -@AllArgsConstructor -public class Product { - - - private final RocketMQTemplate rocketMQTemplate; - - - @PostConstruct - public void init(){ - System.out.println("开始发送消息"); - rocketMQTemplate.convertAndSend("pay-refund-order", JsonUtils.toJsonString("hello world")); - } -} \ No newline at end of file diff --git a/yudao-server/pom.xml b/yudao-server/pom.xml index 49bd846a9c..d5df468a52 100644 --- a/yudao-server/pom.xml +++ b/yudao-server/pom.xml @@ -108,6 +108,12 @@ ${revision} + + cn.iocoder.boot + yudao-spring-boot-starter-mq + ${revision} + + diff --git a/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java b/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java index 57db3f9421..cfe11fdc8f 100644 --- a/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java +++ b/yudao-server/src/main/java/cn/iocoder/yudao/server/YudaoServerApplication.java @@ -9,11 +9,12 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; * 如果你碰到启动的问题，请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 * 如果你碰到启动的问题，请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 * 如果你碰到启动的问题，请认真阅读 https://doc.iocoder.cn/quick-start/ 文章 - * + * cn.iocoder.yudao.server * @author 芋道源码 */ @SuppressWarnings("SpringComponentScan") // 忽略 IDEA 无法识别 ${yudao.info.base-package} -@SpringBootApplication(scanBasePackages = {"${yudao.info.base-package}.server", "${yudao.info.base-package}.module"}) +@SpringBootApplication(scanBasePackages = {"${yudao.info.base-package}.server", "${yudao.info.base-package}.module", + "${yudao.info.base-package}.framework.*"}) public class YudaoServerApplication { public static void main(String[] args) {