当前位置： 首页 > article >正文

【OJ项目】深入剖析 JudgeServiceImpl 类：题目的判题逻辑详解

article 2025/2/15 13:41:56

《深入剖析 JudgeServiceImpl 类：题目的判题逻辑详解》

一、引言

在编程竞赛或者在线编程平台中，判题服务是核心功能之一。它负责对用户提交的代码进行编译、执行，并根据预设的测试用例判断代码的正确性。今天我们就来详细剖析一个名为 JudgeServiceImpl 的 Java 服务类，它实现了题目的判题逻辑。

二、代码整体概述

JudgeServiceImpl 类实现了 JudgeService 接口，主要用于处理题目的判题流程。整个判题过程可以分为以下几个主要步骤：

  1. 获取题目和提交信息：根据题目提交 ID 获取对应的题目和提交信息。
  2. 检查提交状态：确保题目提交状态为等待中，避免重复判题。
  3. 更新状态为判题中：将题目提交状态更新为“判题中”，防止重复执行。
  4. 调用代码沙箱：执行用户提交的代码，获取执行结果。
  5. 设置判题状态和信息：根据沙箱执行结果设置题目的判题状态和信息。
  6. 更新数据库判题结果：将最终的判题结果更新到数据库中。

三、代码详细解析

3.1 类的定义和依赖注入

@Service
public class JudgeServiceImpl implements JudgeService {

    @Resource
    private QuestionFeignClient questionFeignClient;

    @Resource
    private JudgeManager judgeManager;

    @Value("${codesandbox.type:example}")
    private String type;

    // ... 其他代码 ...
}
  • @Service 注解表明这是一个 Spring 服务类。
  • QuestionFeignClient 用于远程调用获取题目和提交信息，以及更新提交状态。
  • JudgeManager 负责具体的判题逻辑。
  • @Value 注解用于获取配置文件中代码沙箱的类型，默认值为 example。

3.2 获取题目和提交信息

@Override
public QuestionSubmit doJudge(long questionSubmitId) {
    // 1）传入题目的提交 id，获取到对应的题目、提交信息（包含代码、编程语言等）
    QuestionSubmit questionSubmit = questionFeignClient.getQuestionSubmitById(questionSubmitId);
    if (questionSubmit == null) {
        throw new BusinessException(ErrorCode.NOT_FOUND_ERROR, "提交信息不存在");
    }
    Long questionId = questionSubmit.getQuestionId();
    Question question = questionFeignClient.getQuestionById(questionId);
    if (question == null) {
        throw new BusinessException(ErrorCode.NOT_FOUND_ERROR, "题目不存在");
    }
    // ... 其他代码 ...
}
  • 通过 questionFeignClient 根据 questionSubmitId 获取题目提交信息。
  • 如果提交信息不存在，抛出 BusinessException 异常。
  • 从提交信息中获取 questionId，再通过 questionFeignClient 获取对应的题目信息。
  • 如果题目信息不存在，同样抛出异常。

3.3 检查提交状态

// 2）如果题目提交状态不为等待中，就不用重复执行了
if (!questionSubmit.getStatus().equals(QuestionSubmitStatusEnum.WAITING.getValue())) {
    throw new BusinessException(ErrorCode.OPERATION_ERROR, "题目正在判题中");
}
  • 检查题目提交状态是否为等待中，如果不是则抛出异常，避免重复判题。

3.4 更新状态为判题中

// 3）更改判题（题目提交）的状态为 “判题中”，防止重复执行
QuestionSubmit questionSubmitUpdate = new QuestionSubmit();
questionSubmitUpdate.setId(questionSubmitId);
questionSubmitUpdate.setStatus(QuestionSubmitStatusEnum.RUNNING.getValue());
boolean update = questionFeignClient.updateQuestionSubmitById(questionSubmitUpdate);
if (!update) {
    throw new BusinessException(ErrorCode.SYSTEM_ERROR, "题目状态更新错误");
}
  • 创建一个 QuestionSubmit 对象，设置其 ID 和状态为“判题中”。
  • 调用 questionFeignClient 的 updateQuestionSubmitById 方法更新状态。
  • 如果更新失败，抛出异常。

3.5 调用代码沙箱

// 4）调用沙箱，获取到执行结果
CodeSandbox codeSandbox = CodeSandboxFactory.newInstance(type);
codeSandbox = new CodeSandboxProxy(codeSandbox);
String language = questionSubmit.getLanguage();
String code = questionSubmit.getCode();
// 获取输入用例
String judgeCaseStr = question.getJudgeCase();
List<JudgeCase> judgeCaseList = JSONUtil.toList(judgeCaseStr, JudgeCase.class);
List<String> inputList = judgeCaseList.stream().map(JudgeCase::getInput).collect(Collectors.toList());
ExecuteCodeRequest executeCodeRequest = ExecuteCodeRequest.builder()
        .code(code)
        .language(language)
        .inputList(inputList)
        .build();
ExecuteCodeResponse executeCodeResponse = codeSandbox.executeCode(executeCodeRequest);
List<String> outputList = executeCodeResponse.getOutputList();
  • 使用 CodeSandboxFactory 创建代码沙箱实例，并使用代理包装。
  • 从提交信息中获取代码和编程语言。
  • 从题目信息中获取输入用例，并转换为列表。
  • 创建 ExecuteCodeRequest 对象，包含代码、编程语言和输入用例列表。
  • 调用代码沙箱的 executeCode 方法执行代码，获取执行结果。

3.6 设置判题状态和信息

// 5）根据沙箱的执行结果，设置题目的判题状态和信息
JudgeContext judgeContext = new JudgeContext();
judgeContext.setJudgeInfo(executeCodeResponse.getJudgeInfo());
judgeContext.setInputList(inputList);
judgeContext.setOutputList(outputList);
judgeContext.setJudgeCaseList(judgeCaseList);
judgeContext.setQuestion(question);
judgeContext.setQuestionSubmit(questionSubmit);
JudgeInfo judgeInfo = judgeManager.doJudge(judgeContext);
  • 创建 JudgeContext 对象，将执行结果、输入用例、题目信息等设置到上下文中。
  • 调用 JudgeManager 的 doJudge 方法进行具体的判题逻辑，得到判题信息。

3.7 更新数据库判题结果

// 6）修改数据库中的判题结果
questionSubmitUpdate = new QuestionSubmit();
questionSubmitUpdate.setId(questionSubmitId);
questionSubmitUpdate.setStatus(QuestionSubmitStatusEnum.SUCCEED.getValue());
questionSubmitUpdate.setJudgeInfo(JSONUtil.toJsonStr(judgeInfo));
update = questionFeignClient.updateQuestionSubmitById(questionSubmitUpdate);
if (!update) {
    throw new BusinessException(ErrorCode.SYSTEM_ERROR, "题目状态更新错误");
}
QuestionSubmit questionSubmitResult = questionFeignClient.getQuestionSubmitById(questionSubmitId);
return questionSubmitResult;
  • 创建一个新的 QuestionSubmit 对象，设置其 ID、状态为“成功”，并将判题信息转换为 JSON 字符串。
  • 调用 questionFeignClient 的 updateQuestionSubmitById 方法更新数据库中的判题结果。
  • 如果更新失败，抛出异常。
  • 最后再次获取更新后的题目提交信息并返回。

四、代码优化建议

4.1 异常处理优化

在获取题目和提交信息时，如果信息不存在，直接抛出 BusinessException，可能会导致上层调用者难以处理。可以在抛出异常前记录日志，方便后续排查问题。同时，可以考虑提供更详细的错误信息。

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Service
public class JudgeServiceImpl implements JudgeService {

    private static final Logger logger = LoggerFactory.getLogger(JudgeServiceImpl.class);

    // ... 其他代码 ...

    @Override
    public QuestionSubmit doJudge(long questionSubmitId) {
        // 1）传入题目的提交 id，获取到对应的题目、提交信息（包含代码、编程语言等）
        QuestionSubmit questionSubmit = questionFeignClient.getQuestionSubmitById(questionSubmitId);
        if (questionSubmit == null) {
            logger.error("提交信息不存在，提交 ID: {}", questionSubmitId);
            throw new BusinessException(ErrorCode.NOT_FOUND_ERROR, "提交信息不存在，提交 ID: " + questionSubmitId);
        }
        Long questionId = questionSubmit.getQuestionId();
        Question question = questionFeignClient.getQuestionById(questionId);
        if (question == null) {
            logger.error("题目不存在，题目 ID: {}", questionId);
            throw new BusinessException(ErrorCode.NOT_FOUND_ERROR, "题目不存在，题目 ID: " + questionId);
        }
        // ... 其他代码 ...
    }
}

4.2 重复更新操作优化

在更新题目提交状态和判题结果时，都调用了 questionFeignClient.updateQuestionSubmitById 方法，代码存在重复。可以将更新操作封装成一个单独的方法，提高代码的复用性。

private boolean updateQuestionSubmit(QuestionSubmit questionSubmitUpdate) {
    return questionFeignClient.updateQuestionSubmitById(questionSubmitUpdate);
}

@Override
public QuestionSubmit doJudge(long questionSubmitId) {
    // ... 其他代码 ...
    // 3）更改判题（题目提交）的状态为 “判题中”，防止重复执行
    QuestionSubmit questionSubmitUpdate = new QuestionSubmit();
    questionSubmitUpdate.setId(questionSubmitId);
    questionSubmitUpdate.setStatus(QuestionSubmitStatusEnum.RUNNING.getValue());
    if (!updateQuestionSubmit(questionSubmitUpdate)) {
        throw new BusinessException(ErrorCode.SYSTEM_ERROR, "题目状态更新错误");
    }
    // ... 其他代码 ...
    // 6）修改数据库中的判题结果
    questionSubmitUpdate = new QuestionSubmit();
    questionSubmitUpdate.setId(questionSubmitId);
    questionSubmitUpdate.setStatus(QuestionSubmitStatusEnum.SUCCEED.getValue());
    questionSubmitUpdate.setJudgeInfo(JSONUtil.toJsonStr(judgeInfo));
    if (!updateQuestionSubmit(questionSubmitUpdate)) {
        throw new BusinessException(ErrorCode.SYSTEM_ERROR, "题目状态更新错误");
    }
    // ... 其他代码 ...
}

4.3 错误处理优化

在调用代码沙箱执行代码时，如果出现异常，没有进行处理。可以添加异常处理逻辑，将题目提交状态更新为“失败”。

try {
    ExecuteCodeResponse executeCodeResponse = codeSandbox.executeCode(executeCodeRequest);
    List<String> outputList = executeCodeResponse.getOutputList();
    // ... 其他代码 ...
} catch (Exception e) {
    logger.error("代码沙箱执行代码出错，提交 ID: {}", questionSubmitId, e);
    QuestionSubmit questionSubmitUpdate = new QuestionSubmit();
    questionSubmitUpdate.setId(questionSubmitId);
    questionSubmitUpdate.setStatus(QuestionSubmitStatusEnum.FAILED.getValue());
    if (!updateQuestionSubmit(questionSubmitUpdate)) {
        logger.error("题目状态更新为失败出错，提交 ID: {}", questionSubmitId);
    }
    throw new BusinessException(ErrorCode.SYSTEM_ERROR, "代码沙箱执行代码出错");
}

4.4 最后获取结果的 ID 错误修正

questionFeignClient.getQuestionSubmitById(questionId); 这里传入的是 questionId，应该传入 questionSubmitId。

QuestionSubmit questionSubmitResult = questionFeignClient.getQuestionSubmitById(questionSubmitId);
return questionSubmitResult;

五、总结

通过对 JudgeServiceImpl 类的详细剖析，我们了解了题目的判题逻辑的具体实现。同时，通过优化建议，我们可以提高代码的健壮性、可维护性和可读性，避免一些潜在的错误。在实际开发中，我们可以根据具体需求对代码进行进一步的扩展和优化。


http://www.kler.cn/a/546332.html

相关文章：

  • 【Linux】--- 基础开发工具之yum/apt、vim、gcc/g++的使用
  • 【进阶】MySQL高级篇超详讲解！！！
  • FFmpeg+SDL实现简易视频播放器
  • Bash 中的运算方式
  • flink核心特性
  • DeepSeek从入门到精通（清华大学）
  • 基于javaweb的SpringBootoa办公自动化系统设计和实现(源码+文档+部署讲解）
  • 【油猴脚本/Tampermonkey】DeepSeek 服务器繁忙无限重试（20250214优化）
  • CZML 格式详解，javascript加载导出CZML文件示例
  • 图数据库neo4j进阶(一):csv文件导入节点及关系
  • Vue 2 — 配置请求转发
  • qt + opengl 给立方体增加阴影
  • 08模拟法 + 技巧 + 数学 + 缓存（D3_数学）
  • LLM：BERT or BART 之BART
  • 微信小程序 - 模版语法
  • Elastic Cloud Serverless 现已在 Microsoft Azure 上提供技术预览版
  • Spring生态体系深度解析：现代Java开发的核心架构
  • 苹果转型独立AR眼镜：一场技术与创新的深度探索
  • 【鸿蒙开发】第三十章 应用稳定性-检测、分析、优化、运维汇总
  • 图形渲染（一）——Skia、OpenGL、Mesa 和 Vulkan简介
  • Spring Boot中使用Flyway进行数据库迁移
  • 网络安全——网络安全基础、常用网络命令
  • 如何动态修改第三方组件库的内部样式
  • 伯克利 CS61A 课堂笔记 07 —— Lists
  • 服务器，交换机和路由器的一些笔记
  • 天芒传奇Ⅱ·前传-特殊武器