AI生成不重复题目

鱼友们怎么实现的AI生成不重复题目呀，比如执行两次生成，每次生成3道题目，几乎都是重复的。 刚开始让AI生成，定义了一个全局缓存，所有请求共享一个缓存（如图一），想着先实现不重复题目，一个应用请求时效果还可以，但是两个应用混合后，肯定会有问题，测试发现在计算机网络应用中生成了操作系统的题，题还是缓存中的题。改进是根据不同请求实现不同的session，然后拼接到userPrompt中，最后效果还可以，部分还需要调试，比之前批次都是重复好很多。

▼
json
复制代码
[{"title":"哪种协议使用三次握手建立连接？","options":[{"score":1,"value":"TCP","key":"A"},{"score":0,"value":"UDP","key":"B"},{"score":0,"value":"ICMP","key":"C"},{"score":0,"value":"ARP","key":"D"}]},
{"title":"IPv4地址的默认子网掩码长度是多少位？","options":[{"score":0,"value":"16","key":"A"},{"score":1,"value":"32","key":"B"},{"score":0,"value":"64","key":"C"},{"score":0,"value":"128","key":"D"}]},
{"title":"MAC地址工作在OSI模型的哪一层？","options":[{"score":1,"value":"数据链路层","key":"A"},{"score":0,"value":"网络层","key":"B"},{"score":0,"value":"传输层","key":"C"},{"score":0,"value":"应用层","key":"D"}]},
{"title":"千兆以太网的标准传输速率是多少？","options":[{"score":0,"value":"100 Mbps","key":"A"},{"score":1,"value":"1 Gbps","key":"B"},{"score":0,"value":"10 Gbps","key":"C"},{"score":0,"value":"100 Gbps","key":"D"}]},
{"title":"哪种协议通常用于大文件传输？","options":[{"score":0,"value":"HTTP","key":"A"},{"score":1,"value":"FTP","key":"B"},{"score":0,"value":"SMTP","key":"C"},{"score":0,"value":"DNS","key":"D"}]},
{"title":"哪种协议提供拥塞控制机制？","options":[{"score":1,"value":"TCP","key":"A"},{"score":0,"value":"UDP","key":"B"},{"score":0,"value":"ICMP","key":"C"},{"score":0,"value":"ARP","key":"D"}]},
{"title":"IPv6地址的地址空间是多少？","options":[{"score":0,"value":"32位","key":"A"},{"score":1,"value":"64位","key":"B"},{"score":0,"value":"128位","key":"C"},{"score":0,"value":"256位","key":"D"}]},
{"title":"网卡工作在OSI模型的哪一层？","options":[{"score":0,"value":"物理层","key":"A"},{"score":1,"value":"数据链路层","key":"B"},{"score":0,"value":"网络层","key":"C"},{"score":0,"value":"传输层","key":"D"}]},
{"title":"千兆以太网的标准传输速率是多少？","options":[{"score":0,"value":"100 Mbps","key":"A"},{"score":1,"value":"1 Gbps","key":"B"},{"score":0,"value":"10 Gbps","key":"C"},{"score":0,"value":"100 Gbps","key":"D"}]},
{"title":"哪种协议通常用于批量文件传输？","options":[{"score":0,"value":"HTTP","key":"A"},{"score":1,"value":"FTP","key":"B"},{"score":0,"value":"SMTP","key":"C"},{"score":0,"value":"DNS","key":"D"}]},
{"title":"哪种协议在传输层提供流量控制和拥塞控制？","options":[{"score":1,"value":"TCP","key":"A"},{"score":0,"value":"UDP","key":"B"},{"score":0,"value":"ICMP","key":"C"},{"score":0,"value":"ARP","key":"D"}]},
{"title":"IPv6地址的长度是多少位？","options":[{"score":1,"value":"128位","key":"A"},{"score":0,"value":"32位","key":"B"},{"score":0,"value":"64位","key":"C"},{"score":0,"value":"256位","key":"D"}]},
{"title":"哪种协议在传输层提供可靠的数据传输服务？","options":[{"score":1,"value":"TCP","key":"A"},{"score":0,"value":"UDP","key":"B"},{"score":0,"value":"ICMP","key":"C"},{"score":0,"value":"ARP","key":"D"}]}]

▼
Java
复制代码
@PostMapping("/ai_generate")
    public BaseResponse<List<QuestionContentDTO>> aiGenerateQuestion(
            @RequestBody AiGenerateQuestionRequest aiGenerateQuestionRequest,HttpServletRequest request) {
        ThrowUtils.throwIf(aiGenerateQuestionRequest == null, ErrorCode.PARAMS_ERROR);
        // 获取参数
        Long appId = aiGenerateQuestionRequest.getAppId();
        int questionNumber = aiGenerateQuestionRequest.getQuestionNumber();
        int optionNumber = aiGenerateQuestionRequest.getOptionNumber();
        // 获取应用信息
        App app = appService.getById(appId);
        ThrowUtils.throwIf(app == null, ErrorCode.NOT_FOUND_ERROR);

        // 获取当前用户的Session
        // 使用应用ID和用户ID组合作为key
        long id=userService.getLoginUser(request).getId();
        String cacheKey = "generatedTitles_" + appId + "_" + id;
        HttpSession session = request.getSession();
        // 从Session中获取已生成的题目标题集合
        @SuppressWarnings("unchecked")
        Set<String> userGeneratedTitles = (Set<String>) session.getAttribute(cacheKey);
        if (userGeneratedTitles == null) {
            userGeneratedTitles = ConcurrentHashMap.newKeySet(); // 使用线程安全的Set
            session.setAttribute(cacheKey, userGeneratedTitles);
        }
        // 打印当前用户的缓存大小（仅用于调试）
        log.info("应用{}的缓存历史题目数量: {}", appId,userGeneratedTitles.size());  // 封装 Prompt
        // 打印部分历史题目（用于调试）
        if (!userGeneratedTitles.isEmpty()) {
            log.info("应用{}的缓存部分历史题目: {}",appId,
                    String.join("\n", userGeneratedTitles.stream().limit(10).collect(Collectors.toList())) +
                            (userGeneratedTitles.size() > 10 ? "\n..." : ""));
        }

        String userMessage = getGenerateQuestionUserMessage(app, questionNumber, optionNumber)+
                "\n\n【重要提示】：生成的新题目不能和以下题目相似或重复，需要发散思维：\n" +
                String.join("\n", userGeneratedTitles.stream().limit(50).collect(Collectors.toList()));
        log.info("用户消息{}",userMessage.toString());
        // AI 生成
        String result = aiManager.doSyncRequest(GENERATE_QUESTION_SYSTEM_MESSAGE, userMessage, null);
        log.info("生成的新问题{}",result.toString());
        // 解析结果
        List<QuestionContentDTO> newQuestions = parseAiResult(result);

        // 更新全局缓存（仅存储标题）
        for (QuestionContentDTO question : newQuestions) {
            if (question.getTitle() == null) {
                log.warn("题目 title 为 null: {}", question);  // 打印整个对象
            } else {
                userGeneratedTitles.add(question.getTitle());
            }
        }
        // 更新Session中的缓存
        session.setAttribute(cacheKey, userGeneratedTitles);
        return ResultUtils.success(newQuestions);
    }

        // 解析AI返回结果
        private List<QuestionContentDTO> parseAiResult(String result) {
        try {
            int start = result.indexOf("[");
            int end = result.lastIndexOf("]");
            String json = result.substring(start, end + 1);
            return JSONUtil.toList(json, QuestionContentDTO.class);
        } catch (Exception e) {
            throw new BusinessException(ErrorCode.SYSTEM_ERROR, "解析AI生成结果失败");
        }
    }