亚洲无码人妻少妇精品无码,梦乃爱华无码AV在线,理论片年轻的母亲

Spring AI 系列三RAG 開發必知——兩種 Advisor 到底怎么選附完整代碼實現Spring AI 提供了對常見 RAG 流程的開箱支持通過 Advisor API 實現向量數據庫存儲著AI模型所不知道的數據當用戶提問時Advisor 會向向量數據庫查詢與用戶問題相關的文檔將檢索結果附加到用戶文本中然后通過 AI 大模型推理生成最終回答。在 RAG 流程中有兩種 AdvisorQuestionAnswerAdvisor 和 RetrievalAugmentationAdvisor。QuestionAnswerAdvisor當用戶提出問題時QuestionAnswerAdvisor 會幫助系統從已有的知識庫或數據庫中檢索答案并將其返回給用戶其核心目的是將用戶的問題與知識庫中的答案進行匹配提供答案。QuestionAnswerAdvisor 側重問答處理通過理解和分析用戶的問題找到最合適的答案。RetrievalAugmentationAdvisor當需要從大型數據庫或知識庫中檢索信息時RetrievalAugmentationAdvisor 會在檢索請求前后插入增強邏輯。例如在查詢過程中RetrievalAugmentationAdvisor 可以自動加入額外的上下文信息如用戶的歷史查詢、偏好、領域知識等以提高檢索結果的相關性和準確性。RetrievalAugmentationAdvisor 側重信息檢索通過增強檢索條件和上下文信息來優化查詢過程。備注Advisor顧問是 Spring AI 中用于增強方法執行邏輯的組件類似于一個攔截器通過 Advisor可以在方法執行前后插入自定義邏輯從而提升代碼的可擴展性與靈活性常用于任務增強、數據預處理等場景。使用以上兩種Advisor時需要在項目maven pom.xml導入如下依賴!-- QuestionAnswerAdvisor 依賴包--dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-advisors-vector-store/artifactId/dependency!-- RetrievalAugmentationAdvisor 依賴包--dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-rag/artifactId/dependency下面通過SpringBoot程序演示兩種Advisor的使用方式該案例中我們將固定的文檔片段存入到Milvus向量庫然后通過chatClient 輸入問題分別使用兩種Advisor進行檢索向量庫進行回答。1. 創建SpringBoot項目SpringBoot項目命名為SpringAIRAGWithAdvisor設置使用的JDK為17版本。2. 在項目中加入如下Maven依賴?xml version1.0 encodingUTF-8?projectxmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.5.3/versionrelativePath/!-- lookup parent from repository --/parentgroupIdcom.example/groupIdartifactIdSpringAIRAGWithAdvisor/artifactIdversion0.0.1-SNAPSHOT/versionnameSpringAIRAGWithAdvisor/namedescriptionSpringAIRAGWithAdvisor/descriptionpropertiesjava.version17/java.version/properties!-- 導入 Spring AI BOM用于統一管理 Spring AI 依賴的版本引用每個 Spring AI 模塊時不用再寫 version只要依賴什么模塊 Mavens 自動使用 BOM 推薦的版本 --dependencyManagementdependenciesdependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-bom/artifactIdversion1.0.0-SNAPSHOT/versiontypepom/typescopeimport/scope/dependency/dependencies/dependencyManagementdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependency!-- Deepseek AI 依賴 --dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-starter-model-deepseek/artifactId/dependency!-- 智普AI 依賴 --dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-starter-model-zhipuai/artifactId/dependency!-- QuestionAnswerAdvisor 依賴包--dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-advisors-vector-store/artifactId/dependency!-- RetrievalAugmentationAdviso 依賴包--dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-rag/artifactId/dependency!-- Milvus VectorStore 依賴包--dependencygroupIdorg.springframework.ai/groupIdartifactIdspring-ai-starter-vector-store-milvus/artifactId/dependency/dependencies!-- 聲明倉庫用于獲取 Spring AI 以及相關預發布版本--repositoriesrepositoryidspring-snapshots/idnameSpring Snapshots/nameurlhttps://repo.spring.io/snapshot/urlreleasesenabledfalse/enabled/releases/repositoryrepositorynameCentral Portal Snapshots/nameidcentral-portal-snapshots/idurlhttps://central.sonatype.com/repository/maven-snapshots//urlreleasesenabledfalse/enabled/releasessnapshotsenabledtrue/enabled/snapshots/repository/repositories/project注意在該 pom.xml 中引入了spring-ai-starter-model-zhipuai依賴包用于文檔片段轉換成向量存入向量庫在該 pom.xml 中引入了spring-ai-starter-model-deepseek依賴包用于 chatClient 聊天。在該 pom.xml 中引入了spring-ai-advisors-vector-store和spring-ai-rag依賴包兩個依賴包分別為 QuestionAnswerAdvisor 和 RetrievalAugmentationAdvisor 依賴。在該 pom.xml 中引入了spring-ai-starter-vector-store-milvus依賴包該依賴為 Milvus VectorStore 依賴包。3. 配置resources/application.propertiesspring.application.nameSpringAIRAGWithAdvisor server.port8080 ## 使用智普AI Embedding 模型需要在pom.xml中引入對應依賴 spring.ai.zhipuai.api-keyd...4 spring.ai.zhipuai.base-urlhttps://open.bigmodel.cn/api/paas spring.ai.zhipuai.embedding.options.modelembedding-2 ## 配置 Chat Model:Deepseek的基礎URL、密鑰和使用模型 spring.ai.deepseek.base-urlhttps://api.deepseek.com spring.ai.deepseek.api-keysk-8...1 spring.ai.deepseek.chat.options.modeldeepseek-chat ## Milvus 配置 spring.ai.vectorstore.milvus.client.hostnode2 spring.ai.vectorstore.milvus.client.port19530 # 默認用戶名和密碼為 root 和 Milvus spring.ai.vectorstore.milvus.client.tokenroot:Milvus # 要使用的 Milvus 數據庫的名稱 spring.ai.vectorstore.milvus.database-namedefault # 用于存儲 vector 的 Milvus 集合名稱 spring.ai.vectorstore.milvus.collection-namevector_store #是否自動初始化 schema如vector_store如果沒有會自動創建 spring.ai.vectorstore.milvus.initialize-schematrue # Milvus 集合中要存儲的 vector 的維度默認為1536要與所使用的 embedding 模型的維度匹配如DeepSeek、ZhiPuAI 或其他都是1024維 spring.ai.vectorstore.milvus.embedding-dimension10244. 構建兩個Rag Advisor和Chat Client在項目中創建config/AIConfig.java 該類標記為Configuration類。類中注入QuestionAnswerAdvisor、RetrievalAugmentationAdvisor以及ChatClient并且每次運行SpringBoot項目時向Milvus中插入指定文檔向量數據如果已存在則不重復插入。packagecom.example.springairagwithadvisor.config;importio.milvus.client.MilvusServiceClient;importio.milvus.grpc.GetCollectionStatisticsResponse;importio.milvus.param.R;importio.milvus.param.collection.FlushParam;importio.milvus.param.collection.GetCollectionStatisticsParam;importio.milvus.response.GetCollStatResponseWrapper;importjakarta.annotation.PostConstruct;importorg.springframework.ai.chat.client.ChatClient;importorg.springframework.ai.chat.client.advisor.vectorstore.QuestionAnswerAdvisor;importorg.springframework.ai.deepseek.DeepSeekChatModel;importorg.springframework.ai.document.Document;importorg.springframework.ai.rag.advisor.RetrievalAugmentationAdvisor;importorg.springframework.ai.rag.generation.augmentation.ContextualQueryAugmenter;importorg.springframework.ai.rag.retrieval.search.VectorStoreDocumentRetriever;importorg.springframework.ai.vectorstore.SearchRequest;importorg.springframework.ai.vectorstore.VectorStore;importorg.springframework.ai.vectorstore.milvus.MilvusVectorStore;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importjava.util.List;ConfigurationpublicclassAIConfig{// 注入 MilvusVectorStore 實例AutowiredprivateMilvusVectorStorevectorStore;// 從配置文件中讀取 Milvus 集合名稱Value(${spring.ai.vectorstore.milvus.collection-name})privateStringcollectionName;//配置 QuestionAnswerAdvisor用于問答任務BeanpublicQuestionAnswerAdvisorquestionAnswerAdvisor(){returnQuestionAnswerAdvisor.builder(vectorStore)// 配置向量搜索的參數這里設置了相似度閾值為 0.5返回前 6 個結果.searchRequest(SearchRequest.builder().similarityThreshold(0.5d).topK(6).build()).build();}//配置 RetrievalAugmentationAdvisor用于增強檢索任務BeanpublicRetrievalAugmentationAdvisorretrievalAugmentationAdvisor(){//VectorStoreDocumentRetriever 負責在向量數據庫中根據查詢獲取最相關的文檔//支持根據相似度閾值、top-K返回前K個最相關文檔和過濾表達式等方式進行精確檢索VectorStoreDocumentRetrieverretrieverVectorStoreDocumentRetriever.builder().vectorStore(vectorStore)// 設置向量存儲對象.similarityThreshold(0.5)//設置相似度閾值.topK(6)//設置返回前K個最相關文檔.build();//ContextualQueryAugmenter 用于增強查詢根據上下文信息生成更具體的查詢//支持基于上下文的查詢增強例如根據用戶輸入的上下文信息生成更具體的查詢提高檢索的準確性和效率ContextualQueryAugmentercqaContextualQueryAugmenter.builder().allowEmptyContext(true)//允許空上下文.build();//返回 RetrievalAugmentationAdvisor 對象用于增強檢索任務returnRetrievalAugmentationAdvisor.builder().documentRetriever(retriever)// 設置文檔檢索器.queryAugmenter(cqa)// 設置查詢增強器.build();}//配置 ChatClient初始化聊天客戶端BeanpublicChatClientchatClient(DeepSeekChatModelchatModel){returnChatClient.builder(chatModel).defaultSystem(你是一個助手回答用戶問題是不要提及回復是從上下文信息中獲取的不要回答你不知道的問題如果你不知道答案就回答抱歉我不清楚這個問題。).build();}/** * PostConstruct 注解的方法會在 Spring 容器完成依賴注入后自動調用一次常用于執行初始化邏輯。 */PostConstructpublicvoidinitVectorData(){System.out.println(初始化向量數據寫入到 Milvus 數據庫中...);// 獲取 Milvus 客戶端實例MilvusServiceClientclient(MilvusServiceClient)vectorStore.getNativeClient().get();// 獲取集合統計信息查詢集合的記錄數量RGetCollectionStatisticsResponserespclient.getCollectionStatistics(GetCollectionStatisticsParam.newBuilder().withCollectionName(collectionName).build());// 獲取實體數量即數據行數longrowCountnewGetCollStatResponseWrapper(resp.getData()).getRowCount();System.out.println(Milvus vector_store 中數據數量rowCount);//如果集合沒有數據就寫入if(rowCount0){System.out.println(Milvus vector_store 中沒有數據寫入...);ListDocumentdocsList.of(newDocument(Spring AI 是一個開源 AI 集成項目),newDocument(Milvus 是一款高性能向量數據庫),newDocument(DeepSeek 是一個開源大語言模型));//vectorStore.add(docs) 調用時Spring AI 的 MilvusVectorStore 會使用注入的 EmbeddingModel 將每個 Document 中的文本內容轉換成向量并寫入vectorStore.add(docs);// 獲取 Milvus 客戶端并手動調用 flush刷新索引確保數據被持久化到 Milvus 數據庫中System.out.println(Milvus vector_store 刷新索引...);client.flush(FlushParam.newBuilder().withCollectionNames(List.of(collectionName))// 設置刷新操作的集合名稱.build());}}}5. 創建RagController.javapackagecom.example.springairagwithadvisor.controller;importorg.springframework.ai.chat.client.ChatClient;importorg.springframework.ai.chat.client.advisor.vectorstore.QuestionAnswerAdvisor;importorg.springframework.ai.rag.advisor.RetrievalAugmentationAdvisor;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.web.bind.annotation.GetMapping;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RequestParam;importorg.springframework.web.bind.annotation.RestController;importjava.util.List;RestControllerRequestMapping(/ai)publicclassRagController{AutowiredprivateChatClientchatClient;AutowiredprivateQuestionAnswerAdvisorqaAdvisor;AutowiredprivateRetrievalAugmentationAdvisorragAdvisor;GetMapping(/chat1)publicStringask1(RequestParamStringmessage){returnchatClient.prompt().user(message)//設置使用 QuestionAnswerAdvisor.advisors(List.of(qaAdvisor)).call().content();}GetMapping(/chat2)publicStringask2(RequestParamStringmessage){returnchatClient.prompt().user(message)//設置使用 RetrievalAugmentationAdvisor.advisors(List.of(ragAdvisor)).call().content();}}6. 啟動Milvus在linux node2 節點啟動Milvus#進入 milvus目錄cd/software/milvus#啟動 Milvusdockercompose up-d7. 啟動項目并測試啟動SpringAiRAGWithAdvisor項目運行主應用類SpringAiragWithAdvisorApplication.java啟動該項目。在瀏覽器中輸入如下內容進行測試# http://localhost:8080/ai/chat1?messageMilvus是什么 Milvus是一款高性能向量數據庫。 # http://localhost:8080/ai/chat1?message今天天氣如何抱歉我不清楚這個問題。 # http://localhost:8080/ai/chat2?messageSpring AI是什么 Spring AI 是一個開源 AI 集成項目。 # http://localhost:8080/ai/chat2?message今天天氣如何抱歉我不清楚這個問題。