java復(fù)制代碼
// 1. 文本向量檢索（Milvus）
List<Float> textVector = openAIService.vectorize(queryText);
SearchParam textSearchParam = buildTextSearchParam(textVector);

// 2. 圖像特征檢索（CLIP模型）
float[] imageVector = clipService.vectorize(uploadedImage);
SearchParam imageSearchParam = buildImageSearchParam(imageVector);

// 3. 結(jié)果融合（加權(quán)平均）
List<Document> textResults = milvusClient.search(textSearchParam);
List<Document> imageResults = milvusClient.search(imageSearchParam);
List<Document> fusedResults = FusionUtil.weightedFusion(textResults, imageResults, 0.6, 0.4);

java復(fù)制代碼
public String expandQuery(String originalQuery) {
    String prompt = """
        你是一個(gè)專業(yè)的搜索優(yōu)化助手，請(qǐng)根據(jù)以下查詢生成3個(gè)語(yǔ)義相關(guān)的擴(kuò)展查詢：
        原始查詢：%s
        輸出格式：JSON數(shù)組，字段為"queries"
        """.formatted(originalQuery);

    String response = openAIService.chatCompletion(prompt);
    List<String> expandedQueries = parseExpandedQueries(response); // 解析JSON
    return String.join(" ", expandedQueries);
}

// 檢索時(shí)使用擴(kuò)展后的查詢
String enhancedQuery = expandQuery(userQuery);
float[] vector = vectorizationService.vectorize(enhancedQuery);

java復(fù)制代碼
@RestController
public class FeedbackController {
    @PostMapping("/feedback")
    public void handleFeedback(@RequestBody FeedbackRequest request) {
        // 根據(jù)用戶標(biāo)注的相關(guān)性分?jǐn)?shù)調(diào)整模型
        retrainingService.adjustWeights(
            request.getQueryVector(),
            request.getDocId(),
            request.getRelevanceScore()
        );
    }
}

java復(fù)制代碼
public String compressContext(String rawContext) {
    String prompt = """
        請(qǐng)從以下文本中提取與問(wèn)題相關(guān)的核心事實(shí)，忽略無(wú)關(guān)細(xì)節(jié)：
        問(wèn)題：%s
        文本：%s
        輸出要求：用簡(jiǎn)潔的Markdown列表呈現(xiàn)
        """.formatted(userQuestion, rawContext);

    return openAIService.chatCompletion(prompt);
}

java復(fù)制代碼
public String generateWithReflection(String question) {
    // 第一階段：初步回答
    String initialAnswer = openAIService.chatCompletion(question);
    
    // 第二階段：反思修正
    String reflectionPrompt = """
        請(qǐng)檢查以下回答是否存在事實(shí)錯(cuò)誤或不完整之處：
        問(wèn)題：%s
        初版回答：%s
        輸出格式：{"errors": [錯(cuò)誤1, 錯(cuò)誤2], "improved_answer": "修正后的回答"}
        """.formatted(question, initialAnswer);
    
    String reflectionResult = openAIService.chatCompletion(reflectionPrompt);
    return parseImprovedAnswer(reflectionResult);
}

java復(fù)制代碼
public List<Document> rerankDocuments(String query, List<Document> candidates) {
    String promptTemplate = """
        請(qǐng)根據(jù)問(wèn)題相關(guān)性對(duì)以下文檔排序（最相關(guān)在前）：
        問(wèn)題：%s
        文檔列表：
        %s
        輸出要求：返回排序后的文檔ID列表，如[3,1,2]
        """;
    
    String docList = candidates.stream()
        .map(doc -> "ID:%d 內(nèi)容:%s".formatted(doc.getId(), doc.getContent()))
        .collect(Collectors.joining("\n"));
    
    String response = openAIService.chatCompletion(promptTemplate.formatted(query, docList));
    return applyReordering(candidates, parseOrderedIds(response));
}

//java復(fù)制代碼
@Cacheable(value = "ragCache", key = "#query.hashCode()")
public RAGResponse cachedRetrieve(String query) {
    // 正常檢索生成流程
    List<Document> docs = retrieveDocuments(query);
    String answer = generateAnswer(query, docs);
    return new RAGResponse(docs, answer);
}

//java復(fù)制代碼
@Async
public CompletableFuture<RAGResponse> asyncProcess(String query) {
    CompletableFuture<List<Document>> retrievalFuture = CompletableFuture.supplyAsync(
        () -> retrieveDocuments(query), 
        retrievalExecutor
    );
    
    return retrievalFuture.thenApplyAsync(docs -> {
        String answer = generateAnswer(query, docs);
        return new RAGResponse(docs, answer);
    }, generationExecutor);
}

//java復(fù)制代碼
@Aspect
@Component
public class MonitoringAspect {
    @Around("execution(* com.example.service.RAGService.*(..))")
    public Object logMetrics(ProceedingJoinPoint joinPoint) throws Throwable {
        long start = System.currentTimeMillis();
        Object result = joinPoint.proceed();
        
        Metrics.gauge("rag.latency", System.currentTimeMillis() - start);
        if (result instanceof RAGResponse resp) {
            Metrics.counter("rag.doc_count").increment(resp.getDocuments().size());
        }
        
        return result;
    }
}

//java復(fù)制代碼
@PostMapping("/query")
public RAGResponse handleQuery(@RequestBody QueryRequest request) {
    if (experimentGroup.isInGroup(request.getUserId(), "V2_ENHANCED")) {
        return enhancedRetriever.process(request.getQuery());
    } else {
        return baselineRetriever.process(request.getQuery());
    }
}

//java復(fù)制代碼
public class Evaluator {
    // 計(jì)算MRR（平均倒數(shù)排名）
    public double calculateMRR(List<TestCase> testCases) {
        return testCases.stream()
            .mapToDouble(tc -> 1.0 / (getFirstRelevantRank(tc)+1))
            .average().orElse(0);
    }
    
    // 生成質(zhì)量人工評(píng)估
    public void humanEvaluation(List<RAGResponse> samples) {
        // 與標(biāo)注平臺(tái)集成
    }
}