MQ

src/main/java/com/izouma/nineth/config/GeneralProperties.java

@@ -22,4 +22,6 @@ public class GeneralProperties {
     private String  mintGroup;
     private String  mintTopic;
     private boolean notifyServer;
+    private String  updateActivityStockGroup;
+    private String  updateActivityStockTopic;
 }

src/main/java/com/izouma/nineth/listener/UpdateActivityStockListener.java

@@ -13,8 +13,8 @@ import org.springframework.stereotype.Service;
 @Slf4j
 @AllArgsConstructor
 @RocketMQMessageListener(
-        consumerGroup = "${general.update-stock-group}",
-        topic = "${general.update-stock-topic}",
+        consumerGroup = "${general.update-activity-stock-group}",
+        topic = "${general.update-activity-stock-topic}",
         consumeMode = ConsumeMode.ORDERLY)
 @ConditionalOnProperty(value = "general.notify-server", havingValue = "false", matchIfMissing = true)
 public class UpdateActivityStockListener implements RocketMQListener<Long> {

src/main/java/com/izouma/nineth/service/MintActivityService.java

@@ -41,7 +41,7 @@ public class MintActivityService {
             log.info("创建redis铸造活动库存：{}", success);
         }
         Long stock = ops.increment(number);
-        rocketMQTemplate.convertAndSend(generalProperties.getUpdateStockTopic(), id);
+        rocketMQTemplate.convertAndSend(generalProperties.getUpdateActivityStockTopic(), id);
         return stock;
     }
 

src/main/resources/application.yaml

@@ -151,6 +151,8 @@ general:
   order-notify-topic: order-notify-topic-dev
   mint-group: mint-group-dev
   mint-topic: mint-topic-dev
+  update-activity-stock-group: update-activity-stock-group-dev
+  update-activity-stock-topic: update-activity-stock-topic-dev
 mychain:
   rest:
     bizid: a00e36c5
@@ -214,6 +216,8 @@ general:
   order-notify-topic: order-notify-topic-test
   mint-group: mint-group-test
   mint-topic: mint-topic-test
+  update-activity-stock-group: update-activity-stock-group-test
+  update-activity-stock-topic: update-activity-stock-topic-test
 ---
 
 spring:
@@ -239,6 +243,8 @@ general:
   mint-group: mint-group-test1
   mint-topic: mint-topic-test1
   notify-server: true
+  update-activity-stock-group: update-activity-stock-group-test1
+  update-activity-stock-topic: update-activity-stock-topic-test1
 wx:
   pay:
     notify-url: https://test1.raex.vip/notify/order/weixin
@@ -289,6 +295,8 @@ general:
   order-notify-topic: order-notify-topic
   mint-group: mint-group
   mint-topic: mint-topic
+  update-activity-stock-group: update-activity-stock-group
+  update-activity-topic-group: update-activity-topic-group
 wx:
   pay:
     notify-url: https://www.raex.vip/notify/order/weixin
@@ -329,6 +337,8 @@ general:
   mint-group: mint-group
   mint-topic: mint-topic
   notify-server: true
+  update-activity-stock-group: update-activity-stock-group
+  update-activity-topic-group: update-activity-topic-group
 wx:
   pay:
     notify-url: https://www.raex.vip/notify/order/weixin
@@ -369,6 +379,8 @@ general:
   mint-group: mint-group-test
   mint-topic: mint-topic-test
   notify-server: true
+  update-activity-stock-group: update-activity-stock-group-test
+  update-activity-topic-group: update-activity-stock-topic-test
 rocketmq:
   name-server: 172.29.50.102:9876
   producer: