diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java
new file mode 100644
index 0000000000..3418912ccf
--- /dev/null
+++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/GroupConstants.java
@@ -0,0 +1,28 @@
+package cn.iocoder.yudao.framework.mq.rocketmq.core;
+
+/**
+ * @author bixuan
+ * @version 1.0
+ * @description: TODO
+ * @date 2025/5/4 10:22
+ */
+public interface GroupConstants {
+    String BIND_CARD_PACKAGE_GROUP = "bind-card-package-group";
+    String UNBIND_CARD_PACKAGE_GROUP = "unbind-card-package-group";
+    String CHANGE_CARD_PACKAGE_GROUP = "change-card-package-group";
+    String SYNC_BATCH_GROUP = "sync-batch-group";
+    String SYNC_CARD_PACKAGE_GROUP = "sync-card-package-group";
+    String SYNC_CARD_PACKAGE_TRAFFIC_GROUP = "sync-card-package-traffic-group";
+    String SYNC_CARD_POOL_TRAFFIC_GROUP = "sync-card-pool-traffic-group";
+    String SYNC_POOL_TRAFFIC_GROUP = "sync-pool-traffic-group";
+    String SYNC_STATISTICS_CARD_POOL_TRAFFIC_GROUP = "sync-statistics-card-pool-traffic-group";
+    String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_GROUP = "sync-statistics-card-package-traffic-group";
+    String PAY_ORDER_DELAY_CLOSE_GROUP = "pay-order-delay-close-group";
+    String PAY_ORDER_GENERATE_BILL_GROUP = "pay-order-generate-bill-group";
+    String REFUND_ORDER_WRITE_OFF_BILL_GROUP = "refund-order-write-off-bill-group";
+    String SYNC_PACKAGE_TRAFFIC_GROUP = "sync-package-traffic-group";
+    String PAY_ORDER_REFUND_GROUP = "pay-order-refund-group";
+    String EIOT_CLUB_NOTIFY_SUBPKGLIST_GROUP = "eiot-club-notify-subPkgList-group";
+    String EIOT_CLUB_NOTIFY_REFUND_GROUP = "eiot-club-notify-refund-group";
+
+}
diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java
new file mode 100644
index 0000000000..52bc432bef
--- /dev/null
+++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicNameConstants.java
@@ -0,0 +1,41 @@
+package cn.iocoder.yudao.framework.mq.rocketmq.core;
+
+
+
+/**
+ * @program: b2b2c-admin
+ * @ClassName TopicNameConstants
+ * @description:
+ * @author: HuangLei
+ * @create: 2025/4/28/周一 9:55
+ * @Version 1.0
+ **/
+public interface TopicNameConstants {
+
+
+    /**
+     * 运营商主题,相同操作消息可以使用tag区分
+     */
+    String IOT_OPERATOR = "iot-operator";
+
+    /**
+     * 事务主题,相同操作消息可以使用tag区分
+     */
+    String IOT_TRANSACTION = "iot-transaction";
+
+    /**
+     * 延时主题,相同操作消息可以使用tag区分
+     */
+    String IOT_DELAY = "iot-delay";
+
+    /**
+     * 退款主题,相同操作消息可以使用tag区分
+     */
+    String PAY_REFUND_ORDER = "pay-refund-order";
+
+
+    /**
+     * eiotclub异步通知主题
+     */
+    String EIOT_CLUB_NOTIFY_TOPIC = "eiot-club-notify";
+}
diff --git a/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java
new file mode 100644
index 0000000000..b177a6b347
--- /dev/null
+++ b/yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/TopicTagConstants.java
@@ -0,0 +1,27 @@
+package cn.iocoder.yudao.framework.mq.rocketmq.core;
+
+/**
+ * @description: TODO
+ * @author bixuan
+ * @date 2025/5/4 10:22
+ * @version 1.0
+ */
+ public interface TopicTagConstants {
+     String BIND_CARD_PACKAGE_TAG = "bind_card_package";
+     String UNBIND_CARD_PACKAGE_TAG = "unbind_card_package";
+     String CHANGE_CARD_PACKAGE_TAG = "change_card_package";
+     String SYNC_BATCH_TAG = "sync_batch";
+     String SYNC_CARD_PACKAGE_TAG = "sync_card_package";
+     String SYNC_CARD_PACKAGE_TRAFFIC_TAG = "sync_card_package_traffic";
+     String SYNC_CARD_POOL_TRAFFIC_TAG = "sync_card_pool_traffic";
+     String SYNC_POOL_TRAFFIC_TAG = "sync_pool_traffic";
+     String SYNC_STATISTICS_CARD_POOL_TRAFFIC_TAG = "sync_statistics_card_pool_traffic";
+     String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_TAG = "sync_statistics_card_package_traffic";
+
+     String PAY_ORDER_SUCCESS_BILL_TAG = "pay_order_success_bill";
+     String REFUND_SUCCESS_BILL_TAG = "refund_success_bill";
+     String DELAY_PAY_ORDER_DELAY_CLOSE = "delay_pay_order_close";
+
+
+
+}