rocketmq切换为rabbitmq

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/TestController.java

@@ -129,7 +129,7 @@ public class TestController extends BaseController {
 //        TLogIdGenerator bean = SpringUtil.getBean(TLogIdGenerator.class);
 //        log.info(bean.generateTraceId());
 
-        for(int i=0; i<5; i++){
+        for(int i=0; i<1; i++){
             BuildSceneCallMessage message = new BuildSceneCallMessage();
             message.setFileId("hhjjS鬼地方个" + "-" + i);
             rabbitMqProducer.sendByWorkQueue(modelingQueueConfig.modelingPre, message);

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

@@ -77,8 +77,8 @@ public class RabbitMqListener {
     public void buildScenePreHandler(Channel channel, Message message) throws Exception {
         String correlationId = message.getMessageProperties().getCorrelationId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+        log.info("场景计算资源准备开始，队列名：{}，id：{},消息体:{}", queueModelingPre, correlationId, msg);
         BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
-        log.info("场景计算资源准备开始，队列名：{}，id：{}", queueModelingPre, correlationId);
         Thread.sleep(2000L);
         buildScenePreService.buildScenePre(buildSceneMessage);
         channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
@@ -97,8 +97,8 @@ public class RabbitMqListener {
     public void buildScenePostHandler(Channel channel, Message message) throws Exception {
         String correlationId = message.getMessageProperties().getCorrelationId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+        log.info("场景计算结果处理开始,队列名：{},id:{},消息体:{}", queueModelingPost, correlationId, msg);
         BuildSceneResultMqMessage resultMessage = JSONObject.parseObject(msg, BuildSceneResultMqMessage.class);
-        log.info("场景计算结果处理开始，队列名：{}，id：{}", queueModelingPost, correlationId);
         Thread.sleep(2000L);
         buildScenePostService.buildScenePost(resultMessage);
         channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
@@ -117,8 +117,8 @@ public class RabbitMqListener {
     public void buildSceneDTHandler(Channel channel, Message message) throws Exception {
         String correlationId = message.getMessageProperties().getCorrelationId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+        log.info("发送钉钉消息处理，队列名：{}，id：{},消息体:{}", queueModelingDt, correlationId, msg);
         BuildSceneFailDTMqMessage dtMessage = JSONObject.parseObject(msg, BuildSceneFailDTMqMessage.class);
-        log.info("发送钉钉消息处理，队列名：{}，id：{}", queueModelingDt, correlationId);
         buildSceneDTService.handFail(dtMessage.getReason(), dtMessage.getServerPath(),
             dtMessage.getNum(), dtMessage.getHostName(), BuildSceneDTServiceImpl.contentExt);
         channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);