test: 测试rabbitmq

seec-oj-server/src/main/java/cn/seecoder/ojserver/controller/JudgeController.java

@@ -47,6 +47,11 @@ public class JudgeController {
         return Response.buildSuccess(judgeService.asyncJudgeCode(problemId, codeJudgeVO));
     }
 
+    @PostMapping("/rabbit")
+    public Response rabbit(@RequestParam(value = "problemId") Integer problemId, @RequestBody CodeJudgeVO codeJudgeVO){
+        return Response.buildSuccess(judgeService.rabbit(problemId, codeJudgeVO));
+    }
+
 
 
 }

seec-oj-server/src/main/java/cn/seecoder/ojserver/service/JudgeService.java

@@ -7,4 +7,5 @@ public interface JudgeService {
     public JudgeResult judgeCode(Integer questionId, CodeJudgeVO codeJudgeVO);
     public JudgeResult asyncJudgeCode(Integer questionId, CodeJudgeVO codeJudgeVO);
     public JudgeResult syncJudgeCode(Integer questionId, CodeJudgeVO codeJudgeVO);
+    public JudgeResult rabbit(Integer questionId, CodeJudgeVO codeJudgeVO);
 }

seec-oj-server/src/main/java/cn/seecoder/ojserver/service/impl/JudgeServiceImpl.java

@@ -126,5 +126,12 @@ public class JudgeServiceImpl implements JudgeService {
         return null;
     }
 
+    @Override
+    public JudgeResult rabbit(Integer questionId, CodeJudgeVO codeJudgeVO) {
+        CodeJudgeDTO codeJudgeDTO = new CodeJudgeDTO(1, questionId, codeJudgeVO);
+        rabbitTemplate.convertAndSend("test_queue", codeJudgeDTO);
+        return null;
+    }
+
 
 }