mq做负载

sapi/src/main/java/com/xhkjedu/sapi/config/RabbitConfig.java

@@ -13,30 +13,45 @@ import org.springframework.context.annotation.Configuration;
  **/
 @Configuration
 public class RabbitConfig {
+    //消费者mq
+    @Value("${rabbitmq.researchHandleQueue}")
+    private String researchHandleQueue;
 
+    //负载一生产者mq
     @Value("${rabbitmq.researchTransferQueue}")
     private String researchTransferQueue;
-
     @Value("${rabbitmq.resourceDelQueue}")
     private String resourceDelQueue;
 
-    @Value("${rabbitmq.researchHandleQueue}")
-    private String researchHandleQueue;
+    //负载二生产者mq
+    @Value("${rabbitmq.researchTransferQueue2}")
+    private String researchTransferQueue2;
+    @Value("${rabbitmq.resourceDelQueue2}")
+    private String resourceDelQueue2;
 
+    //消费者mq
+    @Bean
+    public Queue researchHandleQueue() {
+        return new Queue(researchHandleQueue);
+    }
 
+    //负载一生产者mq
     @Bean
     public Queue researchTransferQueue() {
         return new Queue(researchTransferQueue);
     }
-
     @Bean
     public Queue resourceDelQueue() {
         return new Queue(resourceDelQueue);
     }
 
+    //负载二生产者mq
     @Bean
-    public Queue researchHandleQueue() {
-        return new Queue(researchHandleQueue);
+    public Queue researchTransferQueue2() {
+        return new Queue(researchTransferQueue2);
+    }
+    @Bean
+    public Queue resourceDelQueue2() {
+        return new Queue(resourceDelQueue2);
     }
-
 }

sapi/src/main/java/com/xhkjedu/sapi/listener/MessageSender.java

@@ -20,21 +20,37 @@ import java.util.Map;
 public class MessageSender {
     @Autowired
     private AmqpTemplate rabbitTemplate;
+    //负载一生产者mq
     @Value("${rabbitmq.researchTransferQueue}")
     private String researchTransferQueue;
     @Value("${rabbitmq.resourceDelQueue}")
     private String resourceDelQueue;
+    //负载二生产者mq
+    @Value("${rabbitmq.researchTransferQueue2}")
+    private String researchTransferQueue2;
+    @Value("${rabbitmq.resourceDelQueue2}")
+    private String resourceDelQueue2;
+    //负载一节点名称
+    private final String node2="node02/";
 
     //教研视频转换mq
     public void convertVideo(Integer resourceid, String resourceurl) {
         Map map = new HashMap();
         map.put("resourceid",resourceid);
         map.put("resourceurl",resourceurl);
-        rabbitTemplate.convertAndSend(researchTransferQueue, JSON.toJSONString(map));
+        if (resourceurl.contains(node2)) {
+            rabbitTemplate.convertAndSend(researchTransferQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(researchTransferQueue, JSON.toJSONString(map));
+        }
     }
 
     //资源删除mq
     public void resourceDel(List<String> resourceurls) {
-        rabbitTemplate.convertAndSend(resourceDelQueue,JSON.toJSONString(resourceurls));
+        if (resourceurls.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(resourceDelQueue2, JSON.toJSONString(resourceurls));
+        } else {
+            rabbitTemplate.convertAndSend(resourceDelQueue, JSON.toJSONString(resourceurls));
+        }
     }
 }

sapi/src/main/resources/application.properties

@@ -49,9 +49,14 @@ spring.redis.jedis.pool.max-active=60000
 redisdatatime=604800
 #secretKey必须为24位
 secretKey=nanhuakaizhangjianwangni
-rabbitmq.researchTransferQueue=xhkjedutest.xhschool.researchTransferQueue_dev
-rabbitmq.resourceDelQueue=xhkjedutest.xhschool.resourceDelQueue_dev
+#消费者mq
 rabbitmq.researchHandleQueue=xhkjedutest.xhschool.researchHandleQueue_dev
+#负载一生产者mq
+rabbitmq.researchTransferQueue=xhkjedutest.xhschool.researchTransferQueue_node01_dev
+rabbitmq.resourceDelQueue=xhkjedutest.xhschool.resourceDelQueue_node01_dev
+#负载二生产者mq
+#rabbitmq.researchTransferQueue2=xhkjedutest.xhschool.researchTransferQueue_node02_dev
+#rabbitmq.resourceDelQueue2=xhkjedutest.xhschool.resourceDelQueue_node02_dev
 spring.rabbitmq.host=49.4.26.249
 spring.rabbitmq.port=5672
 spring.rabbitmq.username=xhkjedu

sexam/src/main/java/com/xhkjedu/sexam/config/RabbitConfig.java

@@ -13,51 +13,75 @@ import org.springframework.context.annotation.Configuration;
  **/
 @Configuration
 public class RabbitConfig {
+    //消费者mq
+    @Value("${rabbitmq.examImgMergeHandleQueue}")
+    private String examImgMergeHandleQueue;
+    @Value("${rabbitmq.examBaseToPdfHandleQueue}")
+    private String examBaseToPdfHandleQueue;
+    @Value("${rabbitmq.examBaseToScanImgHandleQueue}")
+    private String examBaseToScanImgHandleQueue;
+    @Value("${rabbitmq.examImgToPdfHandleQueue}")
+    private String examImgToPdfHandleQueue;
 
+    //负载一生产者mq
     @Value("${rabbitmq.examImgMergeQueue}")
     private String examImgMergeQueue;
-    @Value("${rabbitmq.examImgMergeHandleQueue}")
-    private String examImgMergeHandleQueue;
     @Value("${rabbitmq.examBaseToPdfQueue}")
     private String examBaseToPdfQueue;
-    @Value("${rabbitmq.examBaseToPdfHandleQueue}")
-    private String examBaseToPdfHandleQueue;
     @Value("${rabbitmq.examBaseToScanImgQueue}")
     private String examBaseToScanImgQueue;
-    @Value("${rabbitmq.examBaseToScanImgHandleQueue}")
-    private String examBaseToScanImgHandleQueue;
     @Value("${rabbitmq.examImgToPdfQueue}")
     private String examImgToPdfQueue;
-    @Value("${rabbitmq.examImgToPdfHandleQueue}")
-    private String examImgToPdfHandleQueue;
 
-    @Bean
-    public Queue examImgMergeQueue() {
-        return new Queue(examImgMergeQueue);
-    }
+    //负载二生产者mq
+    @Value("${rabbitmq.examImgMergeQueue2}")
+    private String examImgMergeQueue2;
+    @Value("${rabbitmq.examBaseToPdfQueue2}")
+    private String examBaseToPdfQueue2;
+    @Value("${rabbitmq.examBaseToScanImgQueue2}")
+    private String examBaseToScanImgQueue2;
+    @Value("${rabbitmq.examImgToPdfQueue2}")
+    private String examImgToPdfQueue2;
 
+    //消费者mq
     @Bean
     public Queue examImgMergeHandleQueue() {
         return new Queue(examImgMergeHandleQueue);
     }
-
-    @Bean
-    public Queue examBaseToPdfQueue() {
-        return new Queue(examBaseToPdfQueue);
-    }
-
     @Bean
     public Queue examBaseToPdfHandleQueue() {
         return new Queue(examBaseToPdfHandleQueue);
     }
+    @Bean
+    public Queue examBaseToScanImgHandleQueue(){ return new Queue(examBaseToScanImgHandleQueue);}
+    @Bean
+    public Queue examImgToPdfHandleQueue(){ return new Queue(examImgToPdfHandleQueue);}
 
+    //负载一生产者mq
+    @Bean
+    public Queue examImgMergeQueue() {
+        return new Queue(examImgMergeQueue);
+    }
+    @Bean
+    public Queue examBaseToPdfQueue() {
+        return new Queue(examBaseToPdfQueue);
+    }
     @Bean
     public Queue examBaseToScanImgQueue(){ return new Queue(examBaseToScanImgQueue);}
     @Bean
-    public Queue examBaseToScanImgHandleQueue(){ return new Queue(examBaseToScanImgHandleQueue);}
+    public Queue examImgToPdfQueue(){ return new Queue(examImgToPdfQueue);}
 
+    //负载二生产者mq
     @Bean
-    public Queue examImgToPdfQueue(){ return new Queue(examImgToPdfQueue);}
+    public Queue examImgMergeQueue2() {
+        return new Queue(examImgMergeQueue2);
+    }
     @Bean
-    public Queue examImgToPdfHandleQueue(){ return new Queue(examImgToPdfHandleQueue);}
+    public Queue examBaseToPdfQueue2() {
+        return new Queue(examBaseToPdfQueue2);
+    }
+    @Bean
+    public Queue examBaseToScanImgQueue2(){ return new Queue(examBaseToScanImgQueue2);}
+    @Bean
+    public Queue examImgToPdfQueue2(){ return new Queue(examImgToPdfQueue2);}
 }

sexam/src/main/java/com/xhkjedu/sexam/listener/MessageSender.java

@@ -22,16 +22,26 @@ import java.util.Map;
 public class MessageSender {
     @Autowired
     private AmqpTemplate rabbitTemplate;
-
+    //负载一生产者mq
     @Value("${rabbitmq.examImgMergeQueue}")
     private String examImgMergeQueue;
     @Value("${rabbitmq.examBaseToPdfQueue}")
     private String examBaseToPdfQueue;
     @Value("${rabbitmq.examBaseToScanImgQueue}")
     private String examBaseToScanImgQueue;
-    private String examBaseToScanImgHandleQueue;
     @Value("${rabbitmq.examImgToPdfQueue}")
     private String examImgToPdfQueue;
+    //负载二生产者mq
+    @Value("${rabbitmq.examImgMergeQueue2}")
+    private String examImgMergeQueue2;
+    @Value("${rabbitmq.examBaseToPdfQueue2}")
+    private String examBaseToPdfQueue2;
+    @Value("${rabbitmq.examBaseToScanImgQueue2}")
+    private String examBaseToScanImgQueue2;
+    @Value("${rabbitmq.examImgToPdfQueue2}")
+    private String examImgToPdfQueue2;
+    //负载一节点名称
+    private final String node2="node02/";
 
     /**
      * @Description 学生答案合并
@@ -45,7 +55,11 @@ public class MessageSender {
         map.put("epsqid", epsqid);
         map.put("stuanswers", userAnswers);
         map.put("device", device);
-        rabbitTemplate.convertAndSend(examImgMergeQueue, JSON.toJSONString(map));
+        if (userAnswers.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(examImgMergeQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(examImgMergeQueue, JSON.toJSONString(map));
+        }
     }
 
     /**
@@ -63,8 +77,11 @@ public class MessageSender {
         map.put("scantroncol", scantroncol);
         map.put("savefolder",savefolder);
         map.put("filename",filename);
-
-        rabbitTemplate.convertAndSend(examBaseToPdfQueue, JSON.toJSONString(map));
+        if (imgs.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(examBaseToPdfQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(examBaseToPdfQueue, JSON.toJSONString(map));
+        }
     }
 
     /**
@@ -80,7 +97,11 @@ public class MessageSender {
         map.put("examid", examid);
         map.put("imgs", imgs);
         map.put("savefolder",savefolder);
-        rabbitTemplate.convertAndSend(examBaseToScanImgQueue, JSON.toJSONString(map));
+        if (imgs.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(examBaseToScanImgQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(examBaseToScanImgQueue, JSON.toJSONString(map));
+        }
     }
 
     /**
@@ -94,6 +115,10 @@ public class MessageSender {
         Map map = new HashMap();
         map.put("epid",epid);
         map.put("imgs", imgs);
-        rabbitTemplate.convertAndSend(examImgToPdfQueue, JSON.toJSONString(map));
+        if (imgs.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(examImgToPdfQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(examImgToPdfQueue, JSON.toJSONString(map));
+        }
     }
 }

sexam/src/main/java/com/xhkjedu/sexam/mapper/paperstudent/EPaperStudentQuestionMapper.java

@@ -1,11 +1,9 @@
 package com.xhkjedu.sexam.mapper.paperstudent;
 
 import com.xhkjedu.sexam.base.TkMapper;
-import com.xhkjedu.sexam.model.paperstudent.EPaperStudent;
 import com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion;
 import com.xhkjedu.sexam.vo.paperstudent.PsqAnswerVo;
 import org.apache.ibatis.annotations.Param;
-import org.springframework.jmx.export.annotation.ManagedOperationParameter;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
@@ -61,4 +59,9 @@ public interface EPaperStudentQuestionMapper extends TkMapper<EPaperStudentQuest
     //根据学生试卷id获取学生作答内容
     List<EPaperStudentQuestion> listStuQuestionsByEpsid(@Param("epsid")Integer epsid);
 
+    //获取试卷中未合并图片
+    List<EPaperStudentQuestion> listNoMergeUserAnswer();
+
+    //获取未合并图片考试模式列表
+    List<Map> listExamByIds(@Param("examids") List<Integer> examids);
 }

sexam/src/main/java/com/xhkjedu/sexam/service/paperstudent/EPaperStudentService.java

@@ -405,6 +405,31 @@ public class EPaperStudentService {
         }
     }
 
+    /*
+     * 合并学生答案
+     * @Param []
+     * @Author ywx
+     * @Date 2022/11/12 17:34
+     * @return void
+     **/
+    public void paperStuQuestionAnswerMerge() {
+        //获取试卷中未合并图片
+        List<EPaperStudentQuestion> list = ePaperStudentQuestionMapper.listNoMergeUserAnswer();
+        if (N_Utils.isListEmpty(list)) return;
+        List<Integer> examids = list.stream().map(s -> s.getExamid()).distinct().collect(Collectors.toList());
+        List<Map> exams = ePaperStudentQuestionMapper.listExamByIds(examids);//获取未合并图片考试模式列表
+        Map<Integer, Integer> emap = exams.stream().collect(Collectors.toMap(e -> (Integer) e.get("examid")
+                , e -> (Integer) e.get("exammode")));
+        if (N_Utils.isListNotEmpty(list)) {
+            for (EPaperStudentQuestion sq : list) {
+                List<String> stuanswer = JSON.parseArray(sq.getStuanswer(), String.class);
+                if (N_Utils.isListNotEmpty(stuanswer) && stuanswer.size() > 1) {
+                    convertUtil.imgMerge(sq.getEpsqid(), stuanswer, emap.get(sq.getExamid()));
+                }
+            }
+        }
+    }
+
     /**
      * @Description 提交试卷试题（网页端）
      * @Param [pswvo]

sexam/src/main/java/com/xhkjedu/sexam/task/PaperTask.java

@@ -2,6 +2,7 @@ package com.xhkjedu.sexam.task;
 
 import com.xhkjedu.sexam.mapper.exam.ESubjectMapper;
 import com.xhkjedu.sexam.mapper.paper.EPaperCorrectTeacherMapper;
+import com.xhkjedu.sexam.service.paperstudent.EPaperStudentService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -23,6 +24,8 @@ public class PaperTask {
     private ESubjectMapper eSubjectMapper;
     @Resource
     private EPaperCorrectTeacherMapper ePaperCorrectTeacherMapper;
+    @Resource
+    EPaperStudentService ePaperStudentService;
 
     /**
      * 试卷开始考试
@@ -63,4 +66,17 @@ public class PaperTask {
         ePaperCorrectTeacherMapper.unLockQuestion();
     }
 
+    /*
+     * 合并学生答案
+     * @Param []
+     * @Author ywx
+     * @Date 2022/11/12 17:17
+     * @return void
+     **/
+    @Async("threadPoolTaskScheduler")
+    @Scheduled(cron = "${cron.imgMerge}")
+    public void paperStuQuestionAnswerMerge() {
+        ePaperStudentService.paperStuQuestionAnswerMerge();
+    }
+
 }

sexam/src/main/resources/application.properties

@@ -51,14 +51,21 @@ spring.redis.jedis.pool.max-active=60000
 #缓存访问数据有效时长60*60*24*7
 redisdatatime=604800
 
-rabbitmq.examImgMergeQueue=xhkjedutest.xhschool.examImgMergeQueue_dev
+#消费者mq
 rabbitmq.examImgMergeHandleQueue=xhkjedutest.xhschool.examImgMergeHandleQueue_dev
-rabbitmq.examBaseToPdfQueue=xhkjedutest.xhschool.examBaseToPdfQueue_dev
 rabbitmq.examBaseToPdfHandleQueue=xhkjedutest.xhschool.examBaseToPdfHandleQueue_dev
-rabbitmq.examBaseToScanImgQueue=xhkjedutest.xhschool.examBaseToScanImgQueue_dev
 rabbitmq.examBaseToScanImgHandleQueue=xhkjedutest.xhschool.examBaseToScanImgHandleQueue_dev
-rabbitmq.examImgToPdfQueue=xhkjedutest.xhschool.examImgToPdfQueue_dev
 rabbitmq.examImgToPdfHandleQueue=xhkjedutest.xhschool.examImgToPdfHandleQueue_dev
+#负载一生产者mq
+rabbitmq.examImgMergeQueue=xhkjedutest.xhschool.examImgMergeQueue_node01_dev
+rabbitmq.examBaseToPdfQueue=xhkjedutest.xhschool.examBaseToPdfQueue_node01_dev
+rabbitmq.examBaseToScanImgQueue=xhkjedutest.xhschool.examBaseToScanImgQueue_node01_dev
+rabbitmq.examImgToPdfQueue=xhkjedutest.xhschool.examImgToPdfQueue_node01_dev
+#负载二生产者mq
+rabbitmq.examImgMergeQueue2=xhkjedutest.xhschool.examImgMergeQueue_node02_dev
+rabbitmq.examBaseToPdfQueue2=xhkjedutest.xhschool.examBaseToPdfQueue_node02_dev
+rabbitmq.examBaseToScanImgQueue2=xhkjedutest.xhschool.examBaseToScanImgQueue_node02_dev
+rabbitmq.examImgToPdfQueue2=xhkjedutest.xhschool.examImgToPdfQueue_node02_dev
 
 spring.rabbitmq.host=49.4.26.249
 spring.rabbitmq.port=5672
@@ -87,6 +94,8 @@ signName=【河南星火燎原】
 enable.scheduled=false
 #每隔1分钟修改试卷状态
 cron.updatePaperState=0 0/1 * * * ?
+#每天凌晨1点处理未合并的学生答案
+cron.imgMerge=0 0 1 * * ?
 
 #配置socket地址和face地址
 exam.socket=wss://wsexam.xhkjedu.com/ws

sexam/src/main/resources/mapper/paperstudent/EPaperStudentQuestionMapper.xml

@@ -33,6 +33,18 @@
         select epsqid,stuanswer from e_paper_student_question
         where epsid=#{epsid} and answertype=1 and answered=1 and converted=0 order by qorder
     </select>
+    <!--获取试卷中未合并图片-->
+    <select id="listNoMergeUserAnswer" resultType="com.xhkjedu.sexam.model.paperstudent.EPaperStudentQuestion">
+        select epsqid,stuanswer,examid from e_paper_student_question
+        where answertype=1 and answered=1 and converted=0 order by qorder
+    </select>
+    <!--获取未合并图片考试模式列表-->
+    <select id="listExamByIds" resultType="java.util.Map">
+        select examid,exammode from e_base where examid in
+        <foreach collection="examids" item="examid" open="(" separator="," close=")">
+            ${examid}
+        </foreach>
+    </select>
 
     <!--获取试卷中所有试题正确答案及分值-->
     <select id="listPaperQuestionsAnswer" resultType="com.xhkjedu.sexam.vo.paperstudent.PsqAnswerVo">

sstudy/src/main/java/com/xhkjedu/sstudy/config/RabbitConfig.java

@@ -13,7 +13,13 @@ import org.springframework.context.annotation.Configuration;
  **/
 @Configuration
 public class RabbitConfig {
+    //消费者mq
+    @Value("${rabbitmq.resourceHandleQueue}")
+    private String resourceHandleQueue;
+    @Value("${rabbitmq.imgMergeHandleQueue}")
+    private String imgMergeHandleQueue;
 
+    //负载一生产者mq
     @Value("${rabbitmq.resourceToPdfQueue}")
     private String resourceToPdfQueue;
     @Value("${rabbitmq.resourceTransferQueue}")
@@ -22,45 +28,72 @@ public class RabbitConfig {
     private String resourceUnZipQueue;
     @Value("${rabbitmq.resourceDelQueue}")
     private String resourceDelQueue;
-    @Value("${rabbitmq.resourceHandleQueue}")
-    private String resourceHandleQueue;
     @Value("${rabbitmq.imgMergeQueue}")
     private String imgMergeQueue;
-    @Value("${rabbitmq.imgMergeHandleQueue}")
-    private String imgMergeHandleQueue;
 
+    //负载二生产者mq
+    @Value("${rabbitmq.resourceToPdfQueue2}")
+    private String resourceToPdfQueue2;
+    @Value("${rabbitmq.resourceTransferQueue2}")
+    private String resourceTransferQueue2;
+    @Value("${rabbitmq.resourceUnZipQueue2}")
+    private String resourceUnZipQueue2;
+    @Value("${rabbitmq.resourceDelQueue2}")
+    private String resourceDelQueue2;
+    @Value("${rabbitmq.imgMergeQueue2}")
+    private String imgMergeQueue2;
+
+    //消费者mq
+    @Bean
+    public Queue resourceHandleQueue() {
+        return new Queue(resourceHandleQueue);
+    }
+    @Bean
+    public Queue imgMergeHandleQueue() {
+        return new Queue(imgMergeHandleQueue);
+    }
+
+    //负载一生产者mq
     @Bean
     public Queue resourceToPdfQueue() {
         return new Queue(resourceToPdfQueue);
     }
-
     @Bean
     public Queue resourceTransferQueue() {
         return new Queue(resourceTransferQueue);
     }
-
     @Bean
     public Queue resourceUnZipQueue() {
         return new Queue(resourceUnZipQueue);
     }
-
     @Bean
     public Queue resourceDelQueue() {
         return new Queue(resourceDelQueue);
     }
-
-    @Bean
-    public Queue resourceHandleQueue() {
-        return new Queue(resourceHandleQueue);
-    }
-
     @Bean
     public Queue imgMergeQueue() {
         return new Queue(imgMergeQueue);
     }
 
+    //负载二生产者mq
     @Bean
-    public Queue imgMergeHandleQueue() {
-        return new Queue(imgMergeHandleQueue);
+    public Queue resourceToPdfQueue2() {
+        return new Queue(resourceToPdfQueue2);
+    }
+    @Bean
+    public Queue resourceTransferQueue2() {
+        return new Queue(resourceTransferQueue2);
+    }
+    @Bean
+    public Queue resourceUnZipQueue2() {
+        return new Queue(resourceUnZipQueue2);
+    }
+    @Bean
+    public Queue resourceDelQueue2() {
+        return new Queue(resourceDelQueue2);
+    }
+    @Bean
+    public Queue imgMergeQueue2() {
+        return new Queue(imgMergeQueue2);
     }
 }

sstudy/src/main/java/com/xhkjedu/sstudy/listener/MessageSender.java

@@ -21,6 +21,7 @@ import java.util.Map;
 public class MessageSender {
     @Autowired
     private AmqpTemplate rabbitTemplate;
+    //负载一生产者mq
     @Value("${rabbitmq.resourceToPdfQueue}")
     private String resourceToPdfQueue;
     @Value("${rabbitmq.resourceTransferQueue}")
@@ -31,23 +32,49 @@ public class MessageSender {
     private String resourceDelQueue;
     @Value("${rabbitmq.imgMergeQueue}")
     private String imgMergeQueue;
+    //负载二生产者mq
+    @Value("${rabbitmq.resourceToPdfQueue2}")
+    private String resourceToPdfQueue2;
+    @Value("${rabbitmq.resourceTransferQueue2}")
+    private String resourceTransferQueue2;
+    @Value("${rabbitmq.resourceUnZipQueue2}")
+    private String resourceUnZipQueue2;
+    @Value("${rabbitmq.resourceDelQueue2}")
+    private String resourceDelQueue2;
+    @Value("${rabbitmq.imgMergeQueue2}")
+    private String imgMergeQueue2;
+    //负载一节点名称
+    private final String node2="node02/";
 
     //资源转换mq
     public String convertResource(ResourceVo resource) {
         Integer resourceclass = resource.getResourceclass();
+        String resourceurl = resource.getResourceurl();
         Map map = new HashMap();
         map.put("resourceid", resource.getResourceid());
         map.put("resourceclass", resourceclass);
-        map.put("resourceurl", resource.getResourceurl());
+        map.put("resourceurl", resourceurl);
         map.put("suffix", resource.getSuffix());
         String mqKey;
         if (resourceclass == 5) {
             map.put("source", "resource");
-            mqKey = resourceTransferQueue;
+            if (resourceurl.contains(node2)) {
+                mqKey = resourceTransferQueue2;
+            } else {
+                mqKey = resourceTransferQueue;
+            }
         } else if (resourceclass == 7) {
-            mqKey = resourceUnZipQueue;
+            if (resourceurl.contains(node2)) {
+                mqKey = resourceUnZipQueue2;
+            } else {
+                mqKey = resourceUnZipQueue;
+            }
         } else {
-            mqKey = resourceToPdfQueue;
+            if (resourceurl.contains(node2)) {
+                mqKey = resourceToPdfQueue2;
+            } else {
+                mqKey = resourceToPdfQueue;
+            }
         }
         rabbitTemplate.convertAndSend(mqKey, JSON.toJSONString(map));
         return null;
@@ -61,12 +88,20 @@ public class MessageSender {
         map.put("resourceurl", resourceurl);
         map.put("suffix", "mp4");
         map.put("source", source);
-        rabbitTemplate.convertAndSend(resourceTransferQueue, JSON.toJSONString(map));
+        if (resourceurl.contains(node2)) {
+            rabbitTemplate.convertAndSend(resourceTransferQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(resourceTransferQueue, JSON.toJSONString(map));
+        }
     }
 
     //资源删除mq
     public void resourceDel(List<String> resourceurls) {
-        rabbitTemplate.convertAndSend(resourceDelQueue, JSON.toJSONString(resourceurls));
+        if (resourceurls.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(resourceDelQueue2, JSON.toJSONString(resourceurls));
+        } else {
+            rabbitTemplate.convertAndSend(resourceDelQueue, JSON.toJSONString(resourceurls));
+        }
     }
 
     /**
@@ -82,6 +117,10 @@ public class MessageSender {
         map.put("psqid", psqid);
         map.put("userAnswers", userAnswers);
         map.put("papertype", papertype);
-        rabbitTemplate.convertAndSend(imgMergeQueue, JSON.toJSONString(map));
+        if (userAnswers.toString().contains(node2)) {
+            rabbitTemplate.convertAndSend(imgMergeQueue2, JSON.toJSONString(map));
+        } else {
+            rabbitTemplate.convertAndSend(imgMergeQueue, JSON.toJSONString(map));
+        }
     }
 }

sstudy/src/main/resources/application.properties

@@ -56,14 +56,21 @@ spring.redis.jedis.pool.max-active=60000
 redisdatatime=604800
 #secretKey必须为24位
 secretKey=nanhuakaizhangjianwangni
-
-rabbitmq.resourceToPdfQueue=xhkjedutest.xhschool.resourceToPdfQueue_dev
-rabbitmq.resourceTransferQueue=xhkjedutest.xhschool.resourceTransferQueue_dev
-rabbitmq.resourceUnZipQueue=xhkjedutest.xhschool.resourceUnZipQueue_dev
-rabbitmq.resourceDelQueue=xhkjedutest.xhschool.resourceDelQueue_dev
+#消费者mq
 rabbitmq.resourceHandleQueue=xhkjedutest.xhschool.resourceHandleQueue_dev
-rabbitmq.imgMergeQueue=xhkjedutest.xhschool.imgMergeQueue_dev
 rabbitmq.imgMergeHandleQueue=xhkjedutest.xhschool.imgMergeHandleQueue_dev
+#负载一生产者mq
+rabbitmq.resourceToPdfQueue=xhkjedutest.xhschool.resourceToPdfQueue_node01_dev
+rabbitmq.resourceTransferQueue=xhkjedutest.xhschool.resourceTransferQueue_node01_dev
+rabbitmq.resourceUnZipQueue=xhkjedutest.xhschool.resourceUnZipQueue_node01_dev
+rabbitmq.resourceDelQueue=xhkjedutest.xhschool.resourceDelQueue_node01_dev
+rabbitmq.imgMergeQueue=xhkjedutest.xhschool.imgMergeQueue_node01_dev
+#负载二生产者mq
+rabbitmq.resourceToPdfQueue2=xhkjedutest.xhschool.resourceToPdfQueue_node02_dev
+rabbitmq.resourceTransferQueue2=xhkjedutest.xhschool.resourceTransferQueue_node02_dev
+rabbitmq.resourceUnZipQueue2=xhkjedutest.xhschool.resourceUnZipQueue_node02_dev
+rabbitmq.resourceDelQueue2=xhkjedutest.xhschool.resourceDelQueue_node02_dev
+rabbitmq.imgMergeQueue2=xhkjedutest.xhschool.imgMergeQueue_node02_dev
 spring.rabbitmq.host=49.4.26.249
 spring.rabbitmq.port=5672
 spring.rabbitmq.username=xhkjedu