AgentScope Java 入门到进阶

Ne0inhk

— 11 min read

一、什么是 AgentScope Java？

AgentScope Java 是一个面向智能体的编程框架，用于构建基于大语言模型(LLM)的应用。它提供了构建智能体所需的一切功能：ReAct 推理、工具调用、记忆管理、多智能体协作等，让你能够快速开发生产级的 AI 智能体应用。

二、环境准备

1. 系统要求

  • JDK 17 或更高版本
  • Maven 或 Gradle 构建工具

2. 添加依赖

在你的 pom.xml 中添加以下依赖：

<dependency><groupId>io.agentscope</groupId><artifactId>agentscope</artifactId><version>1.0.1</version></dependency>

三、快速入门：创建第一个智能体

1. 最简单的智能体示例

下面是一个基础的智能体示例，它可以响应用户的问候：

importio.agentscope.core.ReActAgent;importio.agentscope.core.message.Msg;importio.agentscope.core.model.DashScopeChatModel;publicclassFirstAgentExample{publicstaticvoidmain(String[] args){// 获取API密钥（实际开发中建议使用环境变量）String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建智能体ReActAgent agent =ReActAgent.builder().name("MyFirstAgent").sysPrompt("你是一个友好的AI助手，总是用简洁的语言回答问题。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).build();// 发送消息并获取响应Msg userMessage =Msg.builder().name("User")// 设置发送者名称.role(MsgRole.USER)// 指定角色为用户.content(TextBlock.builder().text("你好，我叫小明，很高兴认识你！")// 设置消息内容.build()).build();// 发送消息并获取响应Msg response = agent.call(userMessage).block();// 输出响应assert response !=null;System.out.println("智能体回复："+ response.getTextContent());}}

2. 代码解释

  • ReActAgent.builder()：使用建造者模式创建智能体
  • name()：设置智能体名称
  • sysPrompt()：设置系统提示，定义智能体的角色和行为
  • model()：配置底层LLM模型，这里使用了阿里云的DashScope服务
  • agent.call()：发送消息给智能体并获取响应

四、基础功能：智能体与工具

1. 创建自定义工具

工具是智能体与外部世界交互的桥梁。下面创建一个简单的计算器工具：

importio.agentscope.core.tool.Tool;importio.agentscope.core.tool.ToolParam;importreactor.core.publisher.Mono;publicclassCalculatorTool{@Tool(name ="calculator", description ="进行数学计算，支持加减乘除")publicMono<String>calculate(@ToolParam(name ="expression", description ="数学表达式，如1+2*3")String expression ){try{// 简单的表达式计算逻辑double result =evaluateExpression(expression);returnMono.just(expression +" = "+ result);}catch(Exception e){returnMono.just("计算错误: "+ e.getMessage());}}privatedoubleevaluateExpression(String expr){// 实际项目中可以使用更完善的表达式解析库 expr = expr.replaceAll("\\s+","");// 简化实现，仅处理加减乘除// ... 实现计算逻辑 ...return0;// 实际计算结果}}

2. 在智能体中使用工具

importio.agentscope.core.ReActAgent;importio.agentscope.core.tool.Toolkit;publicclassAgentWithToolExample{publicstaticvoidmain(String[] args){String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建工具集并注册工具Toolkit toolkit =newToolkit(); toolkit.registerTool(newCalculatorTool());// 创建带工具的智能体ReActAgent agent =ReActAgent.builder().name("CalculatorAgent").sysPrompt("你是一个计算器助手，当需要进行数学计算时，使用calculator工具。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).toolkit(toolkit)// 配置工具集.build();Msg userMessage =Msg.builder().name("User")// 设置发送者名称.role(MsgRole.USER)// 指定角色为用户.content(TextBlock.builder().text("请计算：(25 + 75) * 3 / 2")// 设置消息内容.build()).build();// 测试计算功能Msg response = agent.call(userMessage).block();assert response !=null;System.out.println("计算结果："+ response.getTextContent());}}

五、进阶功能：多智能体协作

1. 顺序管道（Sequential Pipeline）

顺序管道让多个智能体按顺序处理任务，前一个智能体的输出作为后一个的输入：

importio.agentscope.core.pipeline.SequentialPipeline;importio.agentscope.core.ReActAgent;importio.agentscope.core.message.Msg;publicclassSequentialPipelineExample{publicstaticvoidmain(String[] args){String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建三个不同功能的智能体ReActAgent translator =createTranslator(apiKey);ReActAgent summarizer =createSummarizer(apiKey);ReActAgent sentimentAnalyzer =createSentimentAnalyzer(apiKey);// 构建顺序管道SequentialPipeline pipeline =SequentialPipeline.builder().addAgent(translator).addAgent(summarizer).addAgent(sentimentAnalyzer).build();// 输入文本String inputText ="Artificial Intelligence has revolutionized the technology industry...";Msg userMessage =Msg.builder().name("User")// 设置发送者名称.role(MsgRole.USER)// 指定角色为用户.content(TextBlock.builder().text(inputText)// 设置消息内容.build()).build();// 执行管道Msg result = pipeline.execute(userMessage).block();// 输出最终结果System.out.println("最终分析结果："+ result.getTextContent());}// 创建翻译智能体privatestaticReActAgentcreateTranslator(String apiKey){returnReActAgent.builder().name("Translator").sysPrompt("将输入的英文文本准确翻译成中文，只输出翻译结果。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).build();}// 创建摘要智能体privatestaticReActAgentcreateSummarizer(String apiKey){returnReActAgent.builder().name("Summarizer").sysPrompt("将输入文本总结为2-3句话，保留核心信息。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).build();}// 创建情感分析智能体privatestaticReActAgentcreateSentimentAnalyzer(String apiKey){returnReActAgent.builder().name("SentimentAnalyzer").sysPrompt("分析输入文本的情感倾向，分为积极、消极、中性或混合。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).build();}}

2. 并行管道（Fanout Pipeline）

并行管道让多个智能体同时处理同一输入，适用于需要多视角分析的场景：

importio.agentscope.core.pipeline.FanoutPipeline;importio.agentscope.core.ReActAgent;importio.agentscope.core.message.Msg;importjava.util.List;publicclassFanoutPipelineExample{publicstaticvoidmain(String[] args){String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建三个专家智能体ReActAgent techExpert =createTechExpert(apiKey);ReActAgent uxExpert =createUXExpert(apiKey);ReActAgent bizAnalyst =createBusinessAnalyst(apiKey);// 构建并行管道FanoutPipeline pipeline =FanoutPipeline.builder().addAgent(techExpert).addAgent(uxExpert).addAgent(bizAnalyst).concurrent()// 并行执行.build();// 产品创意String productIdea ="一个使用AI分析日常照片并自动生成个性化视频日记的移动应用...";Msg userMessage =Msg.builder().name("User")// 设置发送者名称.role(MsgRole.USER)// 指定角色为用户.content(TextBlock.builder().text(productIdea)// 设置消息内容.build()).build();// 执行管道List<Msg> results = pipeline.execute(userMessage).block();// 输出结果for(Msg result : results){System.out.println("=== "+ result.getName()+" 分析 ===");System.out.println(result.getTextContent()+"\n");}}// 创建技术专家智能体privatestaticReActAgentcreateTechExpert(String apiKey){// 实现与前面类似// ...}// 创建UX专家智能体privatestaticReActAgentcreateUXExpert(String apiKey){// 实现与前面类似// ...}// 创建业务分析师智能体privatestaticReActAgentcreateBusinessAnalyst(String apiKey){// 实现与前面类似// ...}}

六、高级功能：计划与记忆

1. 使用 PlanNotebook 进行任务规划

FileTool：操作文件的工具

/** * 这是一个文件工具类，用于处理文件相关的功能 */publicclassFileTool{/** * 读取文件内容 */@Tool(name ="readFile", description ="读取指定文件的内容")publicStringreadFile(@ToolParam(name ="filePath", description ="文件路径")String filePath){try{Path path =Paths.get(filePath);// 使用BufferedReader进行缓冲读取，提高大文件读取效率StringBuilder content =newStringBuilder();try(BufferedReader reader =Files.newBufferedReader(path,StandardCharsets.UTF_8)){String line;while((line = reader.readLine())!=null){ content.append(line).append(System.lineSeparator());}}return content.toString();}catch(IOException e){return"读取文件失败: "+ e.getMessage();}}/** * 写入文件内容 */@Tool(name ="writeFile", description ="写入文件内容")publicStringwriteFile(@ToolParam(name ="filePath", description ="文件路径")String filePath,@ToolParam(name ="content", description ="文件内容")String content){try{Path path =Paths.get(filePath);// 确保父目录存在if(path.getParent()!=null&&!Files.exists(path.getParent())){Files.createDirectories(path.getParent());}// 使用BufferedWriter进行缓冲写入，提高写入效率try(BufferedWriter writer =Files.newBufferedWriter(path,StandardCharsets.UTF_8,StandardOpenOption.CREATE,StandardOpenOption.WRITE,StandardOpenOption.TRUNCATE_EXISTING)){ writer.write(content);}return"文件写入成功";}catch(IOException e){return"写入文件失败: "+ e.getMessage();}}}

PlanNotebook 帮助智能体分解复杂任务并跟踪执行进度：

importio.agentscope.core.ReActAgent;importio.agentscope.core.plan.PlanNotebook;importio.agentscope.core.tool.Toolkit;publicclassPlanNotebookExample{publicstaticvoidmain(String[] args){String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建工具集Toolkit toolkit =newToolkit(); toolkit.registerTool(newFileTool());// 创建计划笔记本PlanNotebook planNotebook =PlanNotebook.builder().build();// 创建带计划能力的智能体ReActAgent agent =ReActAgent.builder().name("PlannerAgent").sysPrompt("你是一个有条理的助手，对于多步骤任务，先创建计划再执行。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-plus").build()).toolkit(toolkit).planNotebook(planNotebook)// 配置计划笔记本.build();// 发送多步骤任务Msg userMessage =Msg.builder().name("User")// 设置发送者名称.role(MsgRole.USER)// 指定角色为用户.content(TextBlock.builder().text(task)// 设置消息内容.build()).build();Msg response = agent.call(userMessage).block();System.out.println("任务结果："+ response.getTextContent());}}

2. 检索增强生成（RAG）

RAG 技术让智能体能够利用外部知识库回答问题：

packageorg.example.agentScope.test;importio.agentscope.core.ReActAgent;importio.agentscope.core.message.Msg;importio.agentscope.core.message.MsgRole;importio.agentscope.core.message.TextBlock;importio.agentscope.core.model.DashScopeChatModel;importio.agentscope.core.rag.Knowledge;importio.agentscope.core.rag.RAGMode;importio.agentscope.core.rag.knowledge.SimpleKnowledge;importio.agentscope.core.embedding.dashscope.DashScopeTextEmbedding;importio.agentscope.core.rag.store.InMemoryStore;importio.agentscope.core.rag.model.Document;importio.agentscope.core.rag.reader.ReaderInput;importio.agentscope.core.rag.reader.SplitStrategy;importio.agentscope.core.rag.reader.TextReader;importjava.util.List;publicclassRAGExample{publicstaticvoidmain(String[] args){String apiKey =System.getenv("DASHSCOPE_API_KEY");// 创建嵌入模型var embeddingModel =DashScopeTextEmbedding.builder().apiKey(apiKey).modelName("text-embedding-v3").dimensions(1024).build();// 创建向量存储var vectorStore =InMemoryStore.builder().dimensions(1024).build();// 创建知识库Knowledge knowledge =SimpleKnowledge.builder().embeddingModel(embeddingModel).embeddingStore(vectorStore).build();// 向知识库添加文档addDocumentsToKnowledge(knowledge);// 创建带RAG能力的智能体ReActAgent agent =ReActAgent.builder().name("RAGAgent").sysPrompt("你是一个知识丰富的助手，使用提供的知识库回答问题。").model(DashScopeChatModel.builder().apiKey(apiKey).modelName("qwen-max").build()).knowledge(knowledge)// 配置知识库.ragMode(RAGMode.AGENTIC)// 智能体自主决定何时检索.build();// 测试RAG功能// 快速创建用户消息Msg userMsg =Msg.builder().role(MsgRole.USER)// 明确指定角色为用户.content(TextBlock.builder().text("AgentScope有哪些核心功能？")// 设置消息内容.build()).build();Msg response = agent.call(userMsg).block();System.out.println("回答："+ response.getTextContent());}privatestaticvoidaddDocumentsToKnowledge(Knowledge knowledge){// 1. 创建文本阅读器（设置分块参数：最大长度512，按段落分割，重叠长度50）TextReader reader =newTextReader(512,SplitStrategy.PARAGRAPH,50);// 2. 准备示例文档内容（可替换为实际文档）String[] documentTexts ={"AgentScope 是一个多智能体框架，支持同步和异步通信，"+"提供统一的接口用于构建和管理多智能体应用。框架支持多种智能体类型，"+"包括 ReActAgent 等实现了推理与行动循环的智能体。","RAG（检索增强生成）技术通过从知识库中检索相关信息来增强语言模型的生成能力，"+"帮助模型获取最新信息并减少幻觉。AgentScope 中的 RAG 模块支持多种向量存储，"+"包括内存存储和外部向量数据库。"};// 3. 处理并添加每个文档到知识库for(String text : documentTexts){try{// 将文本转换为阅读器输入ReaderInput input =ReaderInput.fromString(text);// 读取并分块文档（block() 用于同步获取结果）List<Document> documents = reader.read(input).block();if(documents !=null&&!documents.isEmpty()){// 向知识库添加文档（block() 用于同步等待完成） knowledge.addDocuments(documents).block();System.out.println("成功添加文档："+ text.substring(0,Math.min(50, text.length()))+"...");}}catch(Exception e){System.err.println("添加文档失败："+ e.getMessage());}}}}

七、调试与监控

AgentScope 提供了 Studio 工具用于可视化调试,但要安装Studio ，详情可查看
https://github.com/agentscope-ai/agentscope-studio

importio.agentscope.core.ReActAgent;importio.agentscope.core.message.Msg;importio.agentscope.core.model.DashScopeChatModel;importio.agentscope.core.studio.StudioManager;importio.agentscope.core.studio.StudioMessageHook;importio.agentscope.core.studio.StudioUserAgent;importjava.util.List;publicclassStudioDebugExample{publicstaticvoidmain(String[] args){// 1. 初始化 Studio 连接（默认端口 5173）StudioManager.init().studioUrl("http://localhost:5173")// Studio 服务地址.project("MyFirstProject")// 项目名称（用于分类调试记录）.runName("debug_run_"+System.currentTimeMillis())// 本次运行名称（建议唯一）.initialize().block();// 同步等待初始化完成try{// 2. 创建带 Studio 钩子的智能体（自动上报消息）ReActAgent agent =ReActAgent.builder().name("Assistant").sysPrompt("你是一个调试助手").model(DashScopeChatModel.builder()// 配置实际使用的模型.apiKey(System.getenv("DASHSCOPE_API_KEY")).modelName("qwen-plus").build()).hooks(List.of(newStudioMessageHook(StudioManager.getClient())))// 绑定 Studio 钩子.build();// 3. 创建 Studio 用户代理（通过 Web UI 输入消息）StudioUserAgent user =StudioUserAgent.builder().name("User").studioClient(StudioManager.getClient()).webSocketClient(StudioManager.getWebSocketClient()).build();// 4. 运行交互循环（通过 Studio Web UI 输入消息）Msg msg =null;while(true){ msg = user.call(msg).block();// 等待 Web UI 输入if(msg ==null||"exit".equalsIgnoreCase(msg.getTextContent())){break;// 输入 exit 退出} msg = agent.call(msg).block();// 智能体处理消息}}finally{// 5. 关闭 Studio 连接StudioManager.shutdown();}}}

八、总结与进阶学习

通过本教程，你已经了解了 AgentScope Java 的核心能：

  1. 基础智能体创建与使用
  2. 工具开发与集成
  3. 多智能体协作（顺序与并行）
  4. 任务规划与记忆管理
  5. 检索增强生成（RAG）
  6. 调试与监控

进阶学习资源

尝试扩展本教程中的示例，例如：

  • 创建更复杂的工具集成外部API
  • 构建多智能体协作系统解决复杂问题
  • 集成自己的知识库实现领域专家智能体

Read more

模仿淘宝购物系统的Java Web前端项目（开源项目）

模仿淘宝购物系统的Java Web前端项目（开源项目）

提示：此项目仅作为本博主的学习笔记记录，不作为商品售卖，资源往下翻看源码获取 文章目录 * 前言 * Web端功能设计 * 首页 * 热销商品 * 新到商品 * 商品分类 * 商品详情 * 购物车 * 添加地址 * 提交订单 * 部分代码展示 * 可能会出现的错误 * 如果拿到项目后发现图片不显示 * 源码获取 前言 提示：这里可以添加本文要记录的大概内容： 本项目要求完成Java Web的开发环境准备，以及项目开发框架的搭建 Web开发环境准备，包括eclipse、MySQL、tomcat Web项目框架搭建，涉及jsp、servlet、MVC等技术 运行网址：http://localhost:8080/eshop0/index.action 提示：以下是本篇文章正文内容，下面案例可供参考 Web端功能设计 首页 热销商品 新到商品 商品分类 商品详情 ![在这里

By Ne0inhk
JAVA IO流：从基础原理到实战应用

JAVA IO流：从基础原理到实战应用

JAVA IO流：从基础原理到实战应用 1.1 本章学习目标与重点 💡 掌握IO流的核心概念与分类，理解字节流与字符流的区别和适用场景。 💡 熟练使用字节流完成文件的读取与写入操作，解决文件拷贝等实际问题。 💡 掌握字符流的使用方法，处理文本文件的编码与解码问题。 💡 了解缓冲流、转换流、对象流等高级IO流的原理，提升IO操作效率。 ⚠️ 本章重点是 字节流与字符流的核心用法 和 高级IO流的实战应用，这是JAVA文件操作的必备技能。 1.2 IO流核心概念与分类 1.2.1 什么是IO流 💡 IO流（Input/Output Stream）是JAVA中用于处理设备之间数据传输的技术，主要负责数据的读取（Input）和写入（Output）。 常见的IO操作包括文件读写、网络通信数据传输等。IO流的核心思想是以流的方式处理数据，数据像水流一样从一个设备流向另一个设备，实现数据的传输与处理。 1.2.2 IO流的分类标准 JAVA中的IO流体系庞大，可按照不同标准进行分类，核心分类方式有以下三种： 1.

By Ne0inhk

jdk 国内下载镜像站

以下是一些常用的JDK国内下载镜像： * 华为云镜像： * 地址：https://repo.huaweicloud.com/java/jdk/。 * 特点：提供多种版本的JDK下载，速度快，无需注册登录，镜像内容全面，能满足不同用户对不同JDK版本的需求。 * 清华大学TUNA镜像： * 地址：https://mirrors.tuna.tsinghua.edu.cn/Adoptium/。 * 特点：提供AdoptOpenJDK的镜像下载，对于需要使用OpenJDK相关版本进行开发的用户来说，是一个很好的选择，下载速度相比从国外源下载有较大提升。 * 阿里云开源镜像站： * 地址：https://mirrors.aliyun.com/openjdk/。 * 特点：提供多种开源软件的镜像下载，包括Java JDK，依托阿里云的技术和资源支持，稳定性和下载速度都有保障。 * 网易开源镜像站： * 地址：未明确给出特定JDK镜像地址，但通常在其开源镜像体系中有Java JDK相关镜像，可通过官网查找具体路径。 * 特点：提供多种开源软件

By Ne0inhk
【Java 开发日记】为什么要有 time _wait 状态，服务端这个状态过多是什么原因？

【Java 开发日记】为什么要有 time _wait 状态，服务端这个状态过多是什么原因？

目录 为什么要有 TIME_WAIT 状态？ 原因一：可靠地终止TCP连接（确保最后的ACK能到达对方） 原因二：让旧连接的重复报文段在网络中自然消失（防止影响新连接） 服务端 TIME_WAIT 状态过多是什么原因？ 原因一：服务端使用了短连接，并且是它主动关闭连接 原因二：客户端的非正常行为 原因三：负载均衡器的健康检查 总结 面试回答 为什么要有 TIME_WAIT 状态？ TIME_WAIT，俗称2MSL等待状态，是TCP连接主动关闭一方（通常是客户端，但也可能是服务端）在发送最后一次ACK确认报文后，会进入的一个状态。它需要等待2倍的最大报文段生存时间后，才会最终进入CLOSED状态，释放连接资源。 设计TIME_WAIT状态主要有两个核心原因，它们是确保TCP协议可靠性的基石： 原因一：可靠地终止TCP连接（确保最后的ACK能到达对方） 这是最主要的原因。让我们回顾一下TCP四次挥手的正常流程： 1. 主动关闭方（假设为A）

By Ne0inhk