场景计算拆分

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneFailDTMQListener.java

@@ -36,7 +36,7 @@ import org.springframework.stereotype.Component;
 @Component
 @RocketMQMessageListener(
         consumerGroup = "${rocketmq.consumer.build-scene-dt-group-test}",
-        topic = "${rocketmq.build-scene-result.topicName.topic-modeling-a-dt-test}",
+        topic = "${rocketmq.build-scene.topicName.topic-modeling-a-dt-test}",
         messageModel = MessageModel.CLUSTERING,//负载均衡模式
         consumeThreadMax = 10
 )

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildScenePreMQListener.java

@@ -59,9 +59,8 @@ import org.springframework.stereotype.Component;
 @Component
 @RocketMQMessageListener(
         consumerGroup = "${rocketmq.consumer.build-scene-pre-group-test}",
-        topic = "${rocketmq.build-scene-result.topicName.topic-modeling-a-pre-test}",
-        messageModel = MessageModel.CLUSTERING,
-    //负载均衡模式
+        topic = "${rocketmq.build-scene.topicName.topic-modeling-a-pre-test}",
+        messageModel = MessageModel.CLUSTERING,//负载均衡模式
         consumeThreadMax = 10
 )
 public class BuildScenePreMQListener implements RocketMQListener<String> {
@@ -105,9 +104,14 @@ public class BuildScenePreMQListener implements RocketMQListener<String> {
     @Override
     public void onMessage(String message) {
 
-        BuildSceneMqMessage buildSceneMqMessage = JSONObject.parseObject(message, BuildSceneMqMessage.class);
-        log.info("开始处理消息，消费者组：{}，主题名：{}， 消息内容：{}", "build-scene-pre-group", "topic-modeling-a-pre", message);
-        process(buildSceneMqMessage);
+        try {
+            BuildSceneMqMessage buildSceneMqMessage = JSONObject.parseObject(message, BuildSceneMqMessage.class);
+            log.info("开始处理消息，消费者组：{}，主题名：{}， 消息内容：{}", "build-scene-pre-group", "topic-modeling-a-pre", message);
+            process(buildSceneMqMessage);
+        }catch (Exception e){
+
+        }
+
     }
 
     private void process(BuildSceneMqMessage message){