在实际的大模型应用开发中直接让模型回答用户问题往往会遇到知识过时、幻觉和缺乏专业领域知识的问题。检索增强生成RAG技术通过将外部知识库与大型语言模型结合成为了解决这些问题的核心方案。然而从概念到落地一个高效的RAG系统远不止是“向量检索生成”这么简单它涉及文档处理、检索、召回、重排、生成等多个环节的精细调优任何一个环节的短板都会导致最终效果大打折扣。本文面向希望构建或优化RAG应用的开发者将系统性地拆解RAG的全链路从文档接入、切片策略、向量化索引到混合检索、重排序再到工程化落地中的常见陷阱与调优策略。我们将结合一个基于 Spring Boot 和 Milvus 的实战项目展示如何将理论转化为可运行的代码并重点分析如何通过策略组合提升检索质量让你在构建企业级知识库或智能问答系统时能够清晰地定位问题、实施优化避免在工程实践中走弯路。1. 理解RAG不只是检索而是增强生成的全链路RAGRetrieval-Augmented Generation的核心思想是在大模型生成答案之前先从外部知识库中检索出与问题相关的文档片段然后将这些片段作为上下文与问题一同提交给大模型从而生成更准确、更具事实依据的答案。1.1 RAG的基本工作流程一个典型的RAG流程可以分解为以下几个阶段索引构建Indexing这是离线准备阶段。将原始文档如PDF、Word、网页进行清洗、解析分割成更小的文本块Chunk然后将这些文本块转化为向量Embedding并存入向量数据库构建索引。检索与召回Retrieval这是在线服务阶段。当用户提问时先将问题转化为向量然后在向量数据库中进行相似度搜索如余弦相似度找出最相关的K个文本块。这个过程称为“召回”。后处理与重排Reranking初步召回的结果可能包含相关性不高或冗余的信息。重排阶段使用一个更精细的模型通常比生成模型小但比向量模型更懂语义对召回的文档进行重新排序筛选出最相关的几个片段。提示工程与生成Generation将重排后的顶级相关文档作为上下文与用户问题一起构造成提示Prompt提交给大语言模型LLM由LLM生成最终答案。1.2 为什么需要全链路调优很多初建的RAG系统效果不佳往往是因为只关注了其中一两个环节。例如文档切片不合理切片过大包含无关信息干扰模型切片过小丢失关键上下文导致信息碎片化。检索策略单一仅依赖向量检索对关键词匹配、业务规则等考虑不足可能漏掉关键文档。缺乏重排环节向量检索返回的“最相似”片段在语义上未必是“最相关”的直接交给LLM可能导致答案偏离。工程化细节缺失没有处理文档更新、版本管理、多知识库路由、检索结果冲突等问题。因此构建一个健壮的RAG系统必须对全链路有清晰的认识和针对性的设计。2. 环境准备与核心组件选型在开始实战之前我们需要搭建开发环境并选择合适的技术组件。本实战项目将构建一个基于Java技术栈的本地化RAG问答系统。2.1 开发环境与依赖JDK: 17 或以上版本。构建工具: Maven 或 Gradle。IDE: IntelliJ IDEA 或 Eclipse。向量数据库: Milvus单机版用于存储和检索向量。嵌入模型: 选用一个开源的、支持本地部署的文本嵌入模型例如BAAI/bge-small-zh-v1.5它针对中文进行了优化。大语言模型LLM: 为了演示完整流程我们使用 OpenAI 的 GPT 系列需API Key或本地部署的Ollama如qwen:7b。生产环境可根据实际情况选择。重排模型: 可以使用BAAI/bge-reranker-base等专门的重排模型。2.2 项目依赖配置 (Maven)创建一个Spring Boot项目并在pom.xml中添加以下核心依赖dependencies !-- Spring Boot Web -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency !-- LangChain4j - 核心RAG框架 -- dependency groupIddev.langchain4j/groupId artifactIdlangchain4j/artifactId version0.31.0/version !-- 请使用最新稳定版 -- /dependency dependency groupIddev.langchain4j/groupId artifactIdlangchain4j-embeddings-all-minilm-l6-v2/artifactId !-- 本地嵌入模型 -- version0.31.0/version /dependency dependency groupIddev.langchain4j/groupId artifactIdlangchain4j-milvus/artifactId !-- Milvus集成 -- version0.31.0/version /dependency !-- 用于文档解析如PDF -- dependency groupIdorg.apache.tika/groupId artifactIdtika-core/artifactId version2.9.1/version /dependency !-- Lombok -- dependency groupIdorg.projectlombok/groupId artifactIdlombok/artifactId optionaltrue/optional /dependency /dependencies注意LangChain4j版本迭代较快请根据官方文档使用最新版本。如果使用OpenAI还需添加langchain4j-open-ai依赖。2.3 基础设施准备启动Milvus使用Docker快速启动一个单机版Milvus# 拉取最新镜像 docker pull milvusdb/milvus:latest # 运行Milvus单机版 docker run -d --name milvus-standalone \ -p 19530:19530 \ -p 9091:9091 \ milvusdb/milvus:latest启动后Milvus的gRPC服务端口19530和Web管理端口9091将暴露在本地。可以通过http://localhost:9091访问Milvus Attu管理界面进行可视化操作。3. RAG核心链路实现从文档到答案我们将按照索引构建、检索召回、重排、生成的顺序实现一个最小可运行的RAG问答服务。3.1 第一步文档接入、清洗与切片原始文档需要被处理成结构化的文本块。切片策略是影响召回精度的首要因素。关键配置类DocumentProcessorConfigimport dev.langchain4j.data.document.Document; import dev.langchain4j.data.document.DocumentSplitter; import dev.langchain4j.data.document.splitter.DocumentSplitters; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.nio.file.Path; import java.nio.file.Paths; Configuration public class DocumentProcessorConfig { Value(${rag.document.chunk-size:500}) private int chunkSize; Value(${rag.document.chunk-overlap:50}) private int chunkOverlap; /** * 配置文档分割器。 * 使用递归字符分割器按段落、句子、单词等自然边界分割。 * chunkSize: 每个文本块的最大字符数。 * chunkOverlap: 块与块之间的重叠字符数用于保持上下文连贯。 */ Bean public DocumentSplitter documentSplitter() { return DocumentSplitters.recursive(chunkSize, chunkOverlap); } /** * 加载文档示例从文件系统。 * 实际项目中可能需要支持PDF、Word、HTML、Notion、Confluence等多种来源。 */ public Document loadDocument(String filePath) throws IOException { Path path Paths.get(filePath); // LangChain4j 提供了多种DocumentLoader这里使用文本文件加载器 // 对于PDF等复杂格式需要集成Apache Tika或PDFBox Document document FileSystemDocumentLoader.loadDocument(path); return document; } }切片策略调优要点chunkSize块大小通常设置在200-1000字符之间。太小会丢失上下文太大会引入噪声。对于技术文档500左右是个不错的起点。chunkOverlap块重叠设置重叠可以防止关键信息被切在块边界而丢失。通常为块大小的10%-20%。更高级的策略可以按标题分割、按语义分割使用嵌入模型计算句子相似度进行切分或者混合策略。3.2 第二步向量化与索引构建文本块需要被转化为向量嵌入并存入向量数据库。关键服务类EmbeddingService与VectorStoreServiceimport dev.langchain4j.data.embedding.Embedding; import dev.langchain4j.model.embedding.EmbeddingModel; import dev.langchain4j.store.embedding.EmbeddingStore; import dev.langchain4j.store.embedding.milvus.MilvusEmbeddingStore; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import java.util.List; Service RequiredArgsConstructor public class VectorStoreService { private final EmbeddingModel embeddingModel; // 注入嵌入模型Bean private final EmbeddingStoreTextSegment embeddingStore; // 注入向量存储Bean /** * 将文档列表向量化并存入Milvus。 * param textSegments 分割后的文本块列表 */ public void indexDocuments(ListTextSegment textSegments) { // 批量生成向量 ListEmbedding embeddings embeddingModel.embedAll(textSegments).content(); // 将文本块与其对应的向量一起存储 embeddingStore.addAll(embeddings, textSegments); // Milvus会自动创建集合Collection和索引Index } /** * 根据查询文本检索相似向量。 * param query 用户查询 * param maxResults 最大返回结果数召回数 * return 检索到的文本块列表 */ public ListEmbeddingMatchTextSegment search(String query, int maxResults) { // 将查询文本转化为向量 Embedding queryEmbedding embeddingModel.embed(query).content(); // 在向量库中进行相似度搜索 return embeddingStore.findRelevant(queryEmbedding, maxResults); } }配置嵌入模型和向量存储Configuration public class EmbeddingConfig { Bean public EmbeddingModel embeddingModel() { // 使用本地嵌入模型All-MiniLM-L6-v2无需API Key return new AllMiniLmL6V2EmbeddingModel(); // 若使用OpenAI: return new OpenAiEmbeddingModel(your-api-key, text-embedding-ada-002); } Bean public EmbeddingStoreTextSegment embeddingStore() { // 配置Milvus连接和集合参数 MilvusEmbeddingStore.Configuration config MilvusEmbeddingStore.Configuration.builder() .host(localhost) .port(19530) .collectionName(rag_demo_collection) .dimension(384) // 必须与嵌入模型维度一致All-MiniLM-L6-v2是384维 .indexType(IndexType.IVF_FLAT) .metricType(MetricType.COSINE) .build(); return new MilvusEmbeddingStore(config); } }关键点dimension必须与你选用的嵌入模型输出的向量维度完全一致否则存储和检索会失败。3.3 第三步混合检索与重排序策略单纯使用向量检索语义搜索可能在某些场景下失效例如专有名词、缩写、代码片段。混合检索结合了语义搜索和关键词搜索如BM25能提升召回率。实现混合检索服务Service public class HybridRetrievalService { private final VectorStoreService vectorStoreService; private final KeywordSearchService keywordSearchService; // 假设有一个基于Lucene/Elasticsearch的关键词检索服务 private final RerankerService rerankerService; public ListTextSegment hybridSearch(String query, int initialRecallCount) { // 1. 并行执行两种检索 ListEmbeddingMatchTextSegment vectorResults vectorStoreService.search(query, initialRecallCount * 2); // 多召回一些 ListTextSegment keywordResults keywordSearchService.search(query, initialRecallCount * 2); // 2. 结果融合简单去重后合并 SetTextSegment combinedSet new LinkedHashSet(); // 可以给不同来源的结果赋予权重这里简单合并 vectorResults.forEach(match - combinedSet.add(match.embedded())); combinedSet.addAll(keywordResults); ListTextSegment combinedList new ArrayList(combinedSet); // 3. 重排序使用重排模型对合并后的结果进行精排 if (rerankerService ! null !combinedList.isEmpty()) { combinedList rerankerService.rerank(query, combinedList); } // 4. 返回Top N个最终结果 int finalTopN 5; // 最终交给LLM的上下文数量 return combinedList.subList(0, Math.min(finalTopN, combinedList.size())); } }实现重排服务重排模型通常是一个交叉编码器Cross-Encoder它同时接收查询和文档输出一个相关性分数比双编码器如向量模型的点积计算更精确。Service public class RerankerService { // 这里以调用远程重排模型API为例本地部署类似 public ListTextSegment rerank(String query, ListTextSegment candidates) { // 构造 (query, document) 对 ListPairString, String pairs candidates.stream() .map(seg - Pair.of(query, seg.text())) .collect(Collectors.toList()); // 调用重排模型API获取分数伪代码实际需集成具体SDK // ListFloat scores rerankerModelClient.predict(pairs); ListFloat scores mockRerankScores(pairs); // 模拟 // 根据分数对候选文档排序 ListIndexedScore indexedScores new ArrayList(); for (int i 0; i candidates.size(); i) { indexedScores.add(new IndexedScore(i, scores.get(i))); } indexedScores.sort((a, b) - Float.compare(b.score, a.score)); // 降序 // 返回重排后的文档列表 return indexedScores.stream() .map(is - candidates.get(is.index)) .collect(Collectors.toList()); } private static class IndexedScore { int index; float score; // ... constructor, getters } }3.4 第四步提示工程与答案生成将重排后的顶级相关文档作为上下文构造提示词调用LLM生成最终答案。关键服务类QAServiceService RequiredArgsConstructor public class QAService { private final HybridRetrievalService retrievalService; private final ChatLanguageModel chatModel; // 注入LLM如OpenAiChatModel或Ollama public String answerQuestion(String userQuestion) { // 1. 检索相关文档片段 ListTextSegment relevantSegments retrievalService.hybridSearch(userQuestion, 10); // 2. 构建提示词Prompt String context relevantSegments.stream() .map(TextSegment::text) .collect(Collectors.joining(\n\n---\n\n)); String promptTemplate 请基于以下上下文信息回答问题。如果上下文信息不足以回答问题请直接说“根据已知信息无法回答该问题”不要编造信息。 上下文 %s 问题%s 请用中文给出专业、准确的答案 ; String prompt String.format(promptTemplate, context, userQuestion); // 3. 调用LLM生成答案 ResponseAiMessage response chatModel.generate(prompt); return response.content().text(); } }配置LLMConfiguration public class LlmConfig { Bean ConditionalOnProperty(name llm.provider, havingValue openai) public ChatLanguageModel openAiChatModel(Value(${openai.api.key}) String apiKey) { return OpenAiChatModel.builder() .apiKey(apiKey) .modelName(gpt-3.5-turbo) .temperature(0.2) // 低温度使输出更确定 .build(); } Bean ConditionalOnProperty(name llm.provider, havingValue ollama) public ChatLanguageModel ollamaChatModel() { return OllamaChatModel.builder() .baseUrl(http://localhost:11434) .modelName(qwen:7b) .temperature(0.2) .build(); } }3.5 第五步组装与API暴露最后我们创建一个REST控制器来提供问答接口。RestController RequestMapping(/api/rag) RequiredArgsConstructor public class RagController { private final QAService qaService; PostMapping(/ask) public ResponseEntityAnswerResponse askQuestion(RequestBody QuestionRequest request) { try { String answer qaService.answerQuestion(request.getQuestion()); return ResponseEntity.ok(new AnswerResponse(answer)); } catch (Exception e) { return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) .body(new AnswerResponse(系统处理问题时出错 e.getMessage())); } } // 请求/响应DTO Data public static class QuestionRequest { private String question; } Data public static class AnswerResponse { private String answer; // 可以扩展如返回引用的文档片段ID public AnswerResponse(String answer) { this.answer answer; } } }启动Spring Boot应用后就可以通过POST /api/rag/ask接口进行提问了。4. 工程化落地关键问题与调优策略项目能运行只是第一步要让RAG系统在生产环境稳定、高效地工作还需要解决一系列工程问题。4.1 多知识库管理与路由当系统内有多个独立的知识库如产品手册、内部API文档、客服问答库时需要根据问题自动或手动选择正确的知识库进行检索。解决方案元数据过滤在存储向量时为每个文本块添加knowledge_base_id等元数据。检索时通过元数据过滤器限定搜索范围。路由模型训练一个轻量级分类模型根据用户问题判断其所属的知识库类别。前端选择在用户界面上让用户手动选择知识库。在Milvus中可以在创建集合时定义元数据字段并在搜索时通过expr参数进行过滤。4.2 检索结果冲突与去重混合检索或从不同来源召回的结果可能存在大量重复或高度相似的片段直接交给LLM会浪费上下文窗口并可能造成混淆。处理策略基于嵌入的去重计算召回片段之间的余弦相似度超过阈值则去重。基于内容的去重使用MinHash、SimHash等算法进行文本去重。多样化重排在重排模型中引入多样性惩罚避免返回内容过于同质化的结果。4.3 文档更新与增量索引知识库的内容是动态变化的。需要一套机制来处理文档的增、删、改。增量更新为每个文档块生成唯一ID如基于内容哈希。更新时先删除旧文档对应的所有块再插入新块。Milvus支持通过ID删除。版本管理更复杂的场景可能需要维护文档版本检索时指定版本号。定时任务设置定时任务扫描文档源如Git仓库、Confluence发现变更后触发索引更新。4.4 效果评估与监控没有评估就无法优化。需要建立一套评估体系。人工评估构建测试集QA对定期人工评估答案的准确性、相关性和流畅性。自动评估指标检索阶段计算召回率RecallK、平均精度MAP、归一化折损累计增益NDCG。生成阶段使用ROUGE、BLEU等指标对比生成答案与参考答案的相似度但需谨慎这些指标与人类判断并非完全一致。业务监控记录用户提问、检索到的文档、生成的答案、用户反馈如有。分析高频未命中问题、低满意度问题针对性优化切片策略或补充知识库。4.5 性能与成本优化索引优化根据数据规模和查询性能要求选择合适的Milvus索引类型如IVF_FLAT, HNSW和参数。缓存策略对高频或相同的问题及其检索结果进行缓存减少对向量数据库和LLM的调用。异步处理文档解析、向量化、索引构建等耗时操作应异步执行避免阻塞主请求链路。LLM调用优化合理设置上下文窗口大小对答案长度进行限制。考虑使用更经济的模型或对非关键查询使用缓存答案。5. 常见问题排查清单在开发和运维RAG系统时你会遇到各种问题。下面是一个快速排查清单。问题现象可能原因检查点与解决方案检索结果完全不相关1. 嵌入模型不匹配如用英文模型处理中文。2. 向量维度配置错误。3. 文档切片过大包含过多噪声。4. 查询本身歧义或太短。1. 确认嵌入模型是否针对你的语言和领域。2. 检查向量数据库集合的维度(dimension)是否与模型输出一致。3. 调整chunkSize尝试更小的值。4. 尝试对查询进行扩展或改写。LLM回答“根据已知信息无法回答”1. 知识库中确实没有相关信息。2. 检索召回的相关片段太少或质量差。3. 提示词Prompt设计不佳限制了模型。4. 上下文长度超限相关片段被截断。1. 检查检索日志看召回了哪些片段。2. 增加召回数量(maxResults)或优化检索/重排策略。3. 修改提示词鼓励模型基于上下文推理。4. 减少chunkSize或最终提交给LLM的片段数量。LLM生成幻觉答案1. 检索到的上下文不相关或包含错误信息。2. 提示词未明确要求“基于上下文”。3. LLM温度(temperature)参数过高。1. 提升检索精度加强重排使用混合检索。2. 在提示词中强化指令如“必须严格基于上下文”。3. 降低LLM的temperature值如0.1。系统响应速度慢1. 向量检索未建索引或索引类型不当。2. 网络延迟如调用远程Embedding/LLM API。3. 同步执行耗时操作如文档解析。4. 单次检索召回数量(K)太大。1. 在Milvus中为集合创建合适的索引如HNSW。2. 考虑本地部署嵌入模型和较小参数的LLM。3. 将索引构建等操作改为异步。4. 合理设置K值并在重排后只取Top N。新文档入库后检索不到1. 新文档的向量未成功插入数据库。2. 插入后索引未自动刷新/重建。3. 检索时使用了错误的集合或元数据过滤条件。1. 检查插入操作的返回状态和日志。2. Milvus中数据插入后索引可能需手动load到内存。检查集合的加载状态。3. 确认检索请求的参数是否正确。6. 进阶方向与最佳实践掌握了基础链路和问题排查后可以考虑以下方向进一步提升系统能力Self-RAG / Adaptive RAG让模型自己判断是否需要检索、何时检索、检索什么实现更智能的检索决策。多模态RAG支持图像、表格、音频等非文本知识的检索与生成。图增强检索利用知识图谱中的实体关系来改善检索路径解决复杂、多跳问题。Agentic RAG将RAG系统作为智能体Agent的工具之一使其能够自主规划、调用工具、完成复杂任务。端到端评估与持续学习建立自动化评估流水线利用用户反馈数据持续优化切片、检索和生成模型。构建一个高质量的RAG系统是一个持续迭代的过程。从简单的向量检索开始逐步引入更精细的文档处理、混合检索、重排序和提示工程同时建立完善的评估、监控和更新机制才能使其真正成为可靠的知识助手。本文提供的代码和思路是一个坚实的起点在实际项目中请务必根据你的具体数据、领域和性能要求进行深入的调优和测试。 在实际的大模型应用开发中直接让模型回答用户问题往往会遇到知识过时、幻觉和缺乏专业领域知识的问题。检索增强生成RAG技术通过将外部知识库与大型语言模型结合成为了解决这些问题的核心方案。然而从概念到落地一个高效的RAG系统远不止是“向量检索生成”这么简单它涉及文档处理、检索、召回、重排、生成等多个环节的精细调优任何一个环节的短板都会导致最终效果大打折扣。本文面向希望构建或优化RAG应用的开发者将系统性地拆解RAG的全链路从文档接入、切片策略、向量化索引到混合检索、重排序再到工程化落地中的常见陷阱与调优策略。我们将结合一个基于 Spring Boot 和 Milvus 的实战项目展示如何将理论转化为可运行的代码并重点分析如何通过策略组合提升检索质量让你在构建企业级知识库或智能问答系统时能够清晰地定位问题、实施优化避免在工程实践中走弯路。1. 理解RAG不只是检索而是增强生成的全链路RAGRetrieval-Augmented Generation的核心思想是在大模型生成答案之前先从外部知识库中检索出与问题相关的文档片段然后将这些片段作为上下文与问题一同提交给大模型从而生成更准确、更具事实依据的答案。1.1 RAG的基本工作流程一个典型的RAG流程可以分解为以下几个阶段索引构建Indexing这是离线准备阶段。将原始文档如PDF、Word、网页进行清洗、解析分割成更小的文本块Chunk然后将这些文本块转化为向量Embedding并存入向量数据库构建索引。检索与召回Retrieval这是在线服务阶段。当用户提问时先将问题转化为向量然后在向量数据库中进行相似度搜索如余弦相似度找出最相关的K个文本块。这个过程称为“召回”。后处理与重排Reranking初步召回的结果可能包含相关性不高或冗余的信息。重排阶段使用一个更精细的模型通常比生成模型小但比向量模型更懂语义对召回的文档进行重新排序筛选出最相关的几个片段。提示工程与生成Generation将重排后的顶级相关文档作为上下文与用户问题一起构造成提示Prompt提交给大语言模型LLM由LLM生成最终答案。1.2 为什么需要全链路调优很多初建的RAG系统效果不佳往往是因为只关注了其中一两个环节。例如文档切片不合理切片过大包含无关信息干扰模型切片过小丢失关键上下文导致信息碎片化。检索策略单一仅依赖向量检索对关键词匹配、业务规则等考虑不足可能漏掉关键文档。缺乏重排环节向量检索返回的“最相似”片段在语义上未必是“最相关”的直接交给LLM可能导致答案偏离。工程化细节缺失没有处理文档更新、版本管理、多知识库路由、检索结果冲突等问题。因此构建一个健壮的RAG系统必须对全链路有清晰的认识和针对性的设计。2. 环境准备与核心组件选型在开始实战之前我们需要搭建开发环境并选择合适的技术组件。本实战项目将构建一个基于Java技术栈的本地化RAG问答系统。2.1 开发环境与依赖JDK: 17 或以上版本。构建工具: Maven 或 Gradle。IDE: IntelliJ IDEA 或 Eclipse。向量数据库: Milvus单机版用于存储和检索向量。嵌入模型: 选用一个开源的、支持本地部署的文本嵌入模型例如BAAI/bge-small-zh-v1.5它针对中文进行了优化。大语言模型LLM: 为了演示完整流程我们使用 OpenAI 的 GPT 系列需API Key或本地部署的Ollama如qwen:7b。生产环境可根据实际情况选择。重排模型: 可以使用BAAI/bge-reranker-base等专门的重排模型。2.2 项目依赖配置 (Maven)创建一个Spring Boot项目并在pom.xml中添加以下核心依赖dependencies !-- Spring Boot Web -- dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-web/artifactId /dependency !-- LangChain4j - 核心RAG框架 -- dependency groupIddev.langchain4j/groupId artifactIdlangchain4j/artifactId version0.31.0/version !-- 请使用最新稳定版 -- /dependency dependency groupIddev.langchain4j/groupId artifactIdlangchain4j-embeddings-all-minilm-l6-v2/artifactId !-- 本地嵌入模型 -- version0.31.0/version /dependency dependency groupIddev.langchain4j/groupId artifactIdlangchain4j-milvus/artifactId !-- Milvus集成 -- version0.31.0/version /dependency !-- 用于文档解析如PDF -- dependency groupIdorg.apache.tika/groupId artifactIdtika-core/artifactId version2.9.1/version /dependency !-- Lombok -- dependency groupIdorg.projectlombok/groupId artifactIdlombok/artifactId optionaltrue/optional /dependency /dependencies注意LangChain4j版本迭代较快请根据官方文档使用最新版本。如果使用OpenAI还需添加langchain4j-open-ai依赖。2.3 基础设施准备启动Milvus使用Docker快速启动一个单机版Milvus# 拉取最新镜像 docker pull milvusdb/milvus:latest # 运行Milvus单机版 docker run -d --name milvus-standalone \ -p 19530:19530 \ -p 9091:9091 \ milvusdb/milvus:latest启动后Milvus的gRPC服务端口19530和Web管理端口9091将暴露在本地。可以通过http://localhost:9091访问Milvus Attu管理界面进行可视化操作。3. RAG核心链路实现从文档到答案我们将按照索引构建、检索召回、重排、生成的顺序实现一个最小可运行的RAG问答服务。3.1 第一步文档接入、清洗与切片原始文档需要被处理成结构化的文本块。切片策略是影响召回精度的首要因素。关键配置类DocumentProcessorConfigimport dev.langchain4j.data.document.Document; import dev.langchain4j.data.document.DocumentSplitter; import dev.langchain4j.data.document.splitter.DocumentSplitters; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.nio.file.Path; import java.nio.file.Paths; Configuration public class DocumentProcessorConfig { Value(${rag.document.chunk-size:500}) private int chunkSize; Value(${rag.document.chunk-overlap:50}) private int chunkOverlap; /** * 配置文档分割器。 * 使用递归字符分割器按段落、句子、单词等自然边界分割。 * chunkSize: 每个文本块的最大字符数。 * chunkOverlap: 块与块之间的重叠字符数用于保持上下文连贯。 */ Bean public DocumentSplitter documentSplitter() { return DocumentSplitters.recursive(chunkSize, chunkOverlap); } /** * 加载文档示例从文件系统。 * 实际项目中可能需要支持PDF、Word、HTML、Notion、Confluence等多种来源。 */ public Document loadDocument(String filePath) throws IOException { Path path Paths.get(filePath); // LangChain4j 提供了多种DocumentLoader这里使用文本文件加载器 // 对于PDF等复杂格式需要集成Apache Tika或PDFBox Document document FileSystemDocumentLoader.loadDocument(path); return document; } }切片策略调优要点chunkSize块大小通常设置在200-1000字符之间。太小会丢失上下文太大会引入噪声。对于技术文档500左右是个不错的起点。chunkOverlap块重叠设置重叠可以防止关键信息被切在块边界而丢失。通常为块大小的10%-20%。更高级的策略可以按标题分割、按语义分割使用嵌入模型计算句子相似度进行切分或者混合策略。3.2 第二步向量化与索引构建文本块需要被转化为向量嵌入并存入向量数据库。关键服务类EmbeddingService与VectorStoreServiceimport dev.langchain4j.data.embedding.Embedding; import dev.langchain4j.model.embedding.EmbeddingModel; import dev.langchain4j.store.embedding.EmbeddingStore; import dev.langchain4j.store.embedding.milvus.MilvusEmbeddingStore; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import java.util.List; Service RequiredArgsConstructor public class VectorStoreService { private final EmbeddingModel embeddingModel; // 注入嵌入模型Bean private final EmbeddingStoreTextSegment embeddingStore; // 注入向量存储Bean /** * 将文档列表向量化并存入Milvus。 * param textSegments 分割后的文本块列表 */ public void indexDocuments(ListTextSegment textSegments) { // 批量生成向量 ListEmbedding embeddings embeddingModel.embedAll(textSegments).content(); // 将文本块与其对应的向量一起存储 embeddingStore.addAll(embeddings, textSegments); // Milvus会自动创建集合Collection和索引Index } /** * 根据查询文本检索相似向量。 * param query 用户查询 * param maxResults 最大返回结果数召回数 * return 检索到的文本块列表 */ public ListEmbeddingMatchTextSegment search(String query, int maxResults) { // 将查询文本转化为向量 Embedding queryEmbedding embeddingModel.embed(query).content(); // 在向量库中进行相似度搜索 return embeddingStore.findRelevant(queryEmbedding, maxResults); } }配置嵌入模型和向量存储Configuration public class EmbeddingConfig { Bean public EmbeddingModel embeddingModel() { // 使用本地嵌入模型All-MiniLM-L6-v2无需API Key return new AllMiniLmL6V2EmbeddingModel(); // 若使用OpenAI: return new OpenAiEmbeddingModel(your-api-key, text-embedding-ada-002); } Bean public EmbeddingStoreTextSegment embeddingStore() { // 配置Milvus连接和集合参数 MilvusEmbeddingStore.Configuration config MilvusEmbeddingStore.Configuration.builder() .host(localhost) .port(19530) .collectionName(rag_demo_collection) .dimension(384) // 必须与嵌入模型维度一致All-MiniLM-L6-v2是384维 .indexType(IndexType.IVF_FLAT) .metricType(MetricType.COSINE) .build(); return new MilvusEmbeddingStore(config); } }关键点dimension必须与你选用的嵌入模型输出的向量维度完全一致否则存储和检索会失败。3.3 第三步混合检索与重排序策略单纯使用向量检索语义搜索可能在某些场景下失效例如专有名词、缩写、代码片段。混合检索结合了语义搜索和关键词搜索如BM25能提升召回率。实现混合检索服务Service public class HybridRetrievalService { private final VectorStoreService vectorStoreService; private final KeywordSearchService keywordSearchService; // 假设有一个基于Lucene/Elasticsearch的关键词检索服务 private final RerankerService rerankerService; public ListTextSegment hybridSearch(String query, int initialRecallCount) { // 1. 并行执行两种检索 ListEmbeddingMatchTextSegment vectorResults vectorStoreService.search(query, initialRecallCount * 2); // 多召回一些 ListTextSegment keywordResults keywordSearchService.search(query, initialRecallCount * 2); // 2. 结果融合简单去重后合并 SetTextSegment combinedSet new LinkedHashSet(); // 可以给不同来源的结果赋予权重这里简单合并 vectorResults.forEach(match - combinedSet.add(match.embedded())); combinedSet.addAll(keywordResults); ListTextSegment combinedList new ArrayList(combinedSet); // 3. 重排序使用重排模型对合并后的结果进行精排 if (rerankerService ! null !combinedList.isEmpty()) { combinedList rerankerService.rerank(query, combinedList); } // 4. 返回Top N个最终结果 int finalTopN 5; // 最终交给LLM的上下文数量 return combinedList.subList(0, Math.min(finalTopN, combinedList.size())); } }实现重排服务重排模型通常是一个交叉编码器Cross-Encoder它同时接收查询和文档输出一个相关性分数比双编码器如向量模型的点积计算更精确。Service public class RerankerService { // 这里以调用远程重排模型API为例本地部署类似 public ListTextSegment rerank(String query, ListTextSegment candidates) { // 构造 (query, document) 对 ListPairString, String pairs candidates.stream() .map(seg - Pair.of(query, seg.text())) .collect(Collectors.toList()); // 调用重排模型API获取分数伪代码实际需集成具体SDK // ListFloat scores rerankerModelClient.predict(pairs); ListFloat scores mockRerankScores(pairs); // 模拟 // 根据分数对候选文档排序 ListIndexedScore indexedScores new ArrayList(); for (int i 0; i candidates.size(); i) { indexedScores.add(new IndexedScore(i, scores.get(i))); } indexedScores.sort((a, b) - Float.compare(b.score, a.score)); // 降序 // 返回重排后的文档列表 return indexedScores.stream() .map(is - candidates.get(is.index)) .collect(Collectors.toList()); } private static class IndexedScore { int index; float score; // ... constructor, getters } }3.4 第四步提示工程与答案生成将重排后的顶级相关文档作为上下文构造提示词调用LLM生成最终答案。关键服务类QAServiceService RequiredArgsConstructor public class QAService { private final HybridRetrievalService retrievalService; private final ChatLanguageModel chatModel; // 注入LLM如OpenAiChatModel或Ollama public String answerQuestion(String userQuestion) { // 1. 检索相关文档片段 ListTextSegment relevantSegments retrievalService.hybridSearch(userQuestion, 10); // 2. 构建提示词Prompt String context relevantSegments.stream() .map(TextSegment::text) .collect(Collectors.joining(\n\n---\n\n)); String promptTemplate 请基于以下上下文信息回答问题。如果上下文信息不足以回答问题请直接说“根据已知信息无法回答该问题”不要编造信息。 上下文 %s 问题%s 请用中文给出专业、准确的答案 ; String prompt String.format(promptTemplate, context, userQuestion); // 3. 调用LLM生成答案 ResponseAiMessage response chatModel.generate(prompt); return response.content().text(); } }配置LLMConfiguration public class LlmConfig { Bean ConditionalOnProperty(name llm.provider, havingValue openai) public ChatLanguageModel openAiChatModel(Value(${openai.api.key}) String apiKey) { return OpenAiChatModel.builder() .apiKey(apiKey) .modelName(gpt-3.5-turbo) .temperature(0.2) // 低温度使输出更确定 .build(); } Bean ConditionalOnProperty(name llm.provider, havingValue ollama) public ChatLanguageModel ollamaChatModel() { return OllamaChatModel.builder() .baseUrl(http://localhost:11434) .modelName(qwen:7b) .temperature(0.2) .build(); } }3.5 第五步组装与API暴露最后我们创建一个REST控制器来提供问答接口。RestController RequestMapping(/api/rag) RequiredArgsConstructor public class RagController { private final QAService qaService; PostMapping(/ask) public ResponseEntityAnswerResponse askQuestion(RequestBody QuestionRequest request) { try { String answer qaService.answerQuestion(request.getQuestion()); return ResponseEntity.ok(new AnswerResponse(answer)); } catch (Exception e) { return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) .body(new AnswerResponse(系统处理问题时出错 e.getMessage())); } } // 请求/响应DTO Data public static class QuestionRequest { private String question; } Data public static class AnswerResponse { private String answer; // 可以扩展如返回引用的文档片段ID public AnswerResponse(String answer) { this.answer answer; } } }启动Spring Boot应用后就可以通过POST /api/rag/ask接口进行提问了。4. 工程化落地关键问题与调优策略项目能运行只是第一步要让RAG系统在生产环境稳定、高效地工作还需要解决一系列工程问题。4.1 多知识库管理与路由当系统内有多个独立的知识库如产品手册、内部API文档、客服问答库时需要根据问题自动或手动选择正确的知识库进行检索。解决方案元数据过滤在存储向量时为每个文本块添加knowledge_base_id等元数据。检索时通过元数据过滤器限定搜索范围。路由模型训练一个轻量级分类模型根据用户问题判断其所属的知识库类别。前端选择在用户界面上让用户手动选择知识库。在Milvus中可以在创建集合时定义元数据字段并在搜索时通过expr参数进行过滤。4.2 检索结果冲突与去重混合检索或从不同来源召回的结果可能存在大量重复或高度相似的片段直接交给LLM会浪费上下文窗口并可能造成混淆。处理策略基于嵌入的去重计算召回片段之间的余弦相似度超过阈值则去重。基于内容的去重使用MinHash、SimHash等算法进行文本去重。多样化重排在重排模型中引入多样性惩罚避免返回内容过于同质化的结果。4.3 文档更新与增量索引知识库的内容是动态变化的。需要一套机制来处理文档的增、删、改。增量更新为每个文档块生成唯一ID如基于内容哈希。更新时先删除旧文档对应的所有块再插入新块。Milvus支持通过ID删除。版本管理更复杂的场景可能需要维护文档版本检索时指定版本号。定时任务设置定时任务扫描文档源如Git仓库、Confluence发现变更后触发索引更新。4.4 效果评估与监控没有评估就无法优化。需要建立一套评估体系。人工评估构建测试集QA对定期人工评估答案的准确性、相关性和流畅性。自动评估指标检索阶段计算召回率RecallK、平均精度MAP、归一化折损累计增益NDCG。生成阶段使用ROUGE、BLEU等指标对比生成答案与参考答案的相似度但需谨慎这些指标与人类判断并非完全一致。业务监控记录用户提问、检索到的文档、生成的答案、用户反馈如有。分析高频未命中问题、低满意度问题针对性优化切片策略或补充知识库。4.5 性能与成本优化索引优化根据数据规模和查询性能要求选择合适的Milvus索引类型如IVF_FLAT, HNSW和参数。缓存策略对高频或相同的问题及其检索结果进行缓存减少对向量数据库和LLM的调用。异步处理文档解析、向量化、索引构建等耗时操作应异步执行避免阻塞主请求链路。LLM调用优化合理设置上下文窗口大小对答案长度进行限制。考虑使用更经济的模型或对非关键查询使用缓存答案。5. 常见问题排查清单在开发和运维RAG系统时你会遇到各种问题。下面是一个快速排查清单。问题现象可能原因检查点与解决方案检索结果完全不相关1. 嵌入模型不匹配如用英文模型处理中文。2. 向量维度配置错误。3. 文档切片过大包含过多噪声。4. 查询本身歧义或太短。1. 确认嵌入模型是否针对你的语言和领域。2. 检查向量数据库集合的维度(dimension)是否与模型输出一致。3. 调整chunkSize尝试更小的值。4. 尝试对查询进行扩展或改写。LLM回答“根据已知信息无法回答”1. 知识库中确实没有相关信息。2. 检索召回的相关片段太少或质量差。3. 提示词Prompt设计不佳限制了模型。4. 上下文长度超限相关片段被截断。1. 检查检索日志看召回了哪些片段。2. 增加召回数量(maxResults)或优化检索/重排策略。3. 修改提示词鼓励模型基于上下文推理。4. 减少chunkSize或最终提交给LLM的片段数量。LLM生成幻觉答案1. 检索到的上下文不相关或包含错误信息。2. 提示词未明确要求“基于上下文”。3. LLM温度(temperature)参数过高。1. 提升检索精度加强重排使用混合检索。2. 在提示词中强化指令如“必须严格基于上下文”。3. 降低LLM的temperature值如0.1。系统响应速度慢1. 向量检索未建索引或索引类型不当。2. 网络延迟如调用远程Embedding/LLM API。3. 同步执行耗时操作如文档解析。4. 单次检索召回数量(K)太大。1. 在Milvus中为集合创建合适的索引如HNSW。2. 考虑本地部署嵌入模型和较小参数的LLM。3. 将索引构建等操作改为异步。4. 合理设置K值并在重排后只取Top N。新文档入库后检索不到1. 新文档的向量未成功插入数据库。2. 插入后索引未自动刷新/重建。3. 检索时使用了错误的集合或元数据过滤条件。1. 检查插入操作的返回状态和日志。2. Milvus中数据插入后索引可能需手动load到内存。检查集合的加载状态。3. 确认检索请求的参数是否正确。6. 进阶方向与最佳实践掌握了基础链路和问题排查后可以考虑以下方向进一步提升系统能力Self-RAG / Adaptive RAG让模型自己判断是否需要检索、何时检索、检索什么实现更智能的检索决策。多模态RAG支持图像、表格、音频等非文本知识的检索与生成。图增强检索利用知识图谱中的实体关系来改善检索路径解决复杂、多跳问题。Agentic RAG将RAG系统作为智能体Agent的工具之一使其能够自主规划、调用工具、完成复杂任务。端到端评估与持续学习建立自动化评估流水线利用用户反馈数据持续优化切片、检索和生成模型。构建一个高质量的RAG系统是一个持续迭代的过程。从简单的向量检索开始逐步引入更精细的文档处理、混合检索、重排序和提示工程同时建立完善的评估、监控和更新机制才能使其真正成为可靠的知识助手。本文提供的代码和思路是一个坚实的起点在实际项目中请务必根据你的具体数据、领域和性能要求进行深入的调优和测试。 
 运动的基于优化的简化两足动物模型，躯干灵活性、座椅高度、关节强度限制和运动速度如何影响关节运动学、扭矩和地面反作用力附matlab代码)
