Merge remote-tracking branch 'origin/master'

- 新增 GroupConstants 接口，定义了多个消费者组常量- 新增 TopicNameConstants 接口，定义了多个主题名常量
- 新增 TopicTagConstants 接口，定义了多个主题标签常量

yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java

@@ -0,0 +1,26 @@
+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<String> {
+    @Override
+    public void onMessage(String message) {
+        log.info("【消费】- {}", message);
+    }
+}

yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java

@@ -0,0 +1,26 @@
+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"));
+    }
+}