计算机毕业设计springboot校园二手交易平台 Spring Boot框架下高校学生闲置物品交易系统 基于B/S架构的校园在线跳蚤市场平台

Agent Skills工作流从入门到实战前言在人工智能快速发展的今天Agent智能体技术正在改变我们构建应用的方式。

Agent Skills工作流作为连接智能体与具体能力的桥梁为开发者提供了一种灵活、可扩展的架构模式。

本文将从基础概念出发结合实际案例带你深入了解Agent Skills的设计与实现。

什么是Agent Skills

1 核心概念Agent智能体具有自主决策能力的实体能够理解任务、规划行动并执行操作。

Skill技能Agent可以调用的具体能力单元如文件读取、数据查询、文本分析等。

Agent Skills工作流Agent通过识别任务需求动态选择并调用合适的Skill最终完成用户目标的过程。

2 架构设计Agent Skills架构包含四个核心层次Agent Core智能体核心负责决策和协调Skill Registry技能注册中心管理所有可用技能Execution Engine执行引擎处理技能调用和错误重试Skill Implementations具体技能实现层这种分层设计确保了系统的可扩展性和可维护性。

核心组件实现

1 Agent接口设计package com.example.agent; import com.example.skills.Skill; import com.example.skills.SkillResult; import java.util.Map; /** * Agent智能体接口 * 定义Agent的基本行为和能力 * version

1.

0 */ public interface Agent { /** * 获取Agent名称 */ String getName(); /** * 获取Agent描述 */ String getDescription(); /** * 执行任务 * * param task 任务内容 * param context 执行上下文 * return 执行结果 */ AgentResult execute(String task, AgentContext context); /** * 注册技能 * * param skill 技能实例 */ void registerSkill(Skill skill); /** * 获取已注册的所有技能 */ java.util.CollectionSkill getSkills(); /** * Agent执行结果 */ class AgentResult { private final boolean success; private final String message; private final Object data; private final long executionTime; public AgentResult(boolean success, String message, Object data, long executionTime) { this.success success; this.message message; this.data data; this.executionTime executionTime; } public static AgentResult success(String message, Object data) { return new AgentResult(true, message, data,

; } public static AgentResult success(String message, Object data, long executionTime) { return new AgentResult(true, message, data, executionTime); } public static AgentResult failure(String message) { return new AgentResult(false, message, null,

; } public boolean isSuccess() { return success; } public String getMessage() { return message; } public Object getData() { return data; } public long getExecutionTime() { return executionTime; } Override public String toString() { return AgentResult{ success success , message message \ , data data , executionTime executionTime ms }; } } }Agent接口定义了智能体的基本行为其中最关键的是execute方法它接收任务和上下文返回执行结果。

2 Skill接口设计package com.example.skills; import java.util.Map; /** * Skill技能接口 * 定义Agent可以执行的具体技能 * version

1.

0 */ public interface Skill { /** * 获取技能名称 */ String getName(); /** * 获取技能描述 */ String getDescription(); /** * 获取技能版本 */ default String getVersion() { return

1.

0; } /** * 判断技能是否可以执行该任务 * * param task 任务内容 * return 是否可以执行 */ boolean canExecute(String task); /** * 执行技能 * * param task 任务内容 * param parameters 参数 * return 执行结果 */ SkillResult execute(String task, MapString, Object parameters); /** * 获取技能的超时时间毫秒 * 默认30秒 */ default long getTimeout() { return 30000; } /** * 技能执行前的验证 * * param task 任务内容 * param parameters 参数 * return 验证是否通过 */ default boolean validate(String task, MapString, Object parameters) { return task ! null !task.trim().isEmpty(); } /** * 技能执行后的清理 */ default void cleanup() { // 默认不需要清理 } }Skill接口采用策略模式每个技能实现独立的功能并通过canExecute方法声明自己能处理哪些任务。

3 技能调用流程完整的技能调用流程包括10个步骤接收用户请求解析任务意图匹配可用技能验证执行权限准备执行参数调用技能接口监控执行状态处理执行结果返回响应数据更新执行历史每个步骤都有其特定的职责确保任务能够安全、高效地执行。

基础技能实现

1 文件读取技能package com.example.skills.impl; import com.example.skills.Skill; import com.example.skills.SkillResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.IOException; import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.util.ArrayList; import java.util.List; import java.util.Map; /** * 文件读取技能 * 用于读取本地文件内容 * version

1.

0 */ public class FileReadSkill implements Skill { private static final Logger logger LoggerFactory.getLogger(FileReadSkill.class); Override public String getName() { return FileReadSkill; } Override public String getDescription() { return 读取本地文件内容支持文本文件、配置文件等; } Override public boolean canExecute(String task) { if (task null) { return false; } String lowerTask task.toLowerCase(); return lowerTask.contains(文件) (lowerTask.contains(读取) || lowerTask.contains(打开) || lowerTask.contains(查看)); } Override public boolean validate(String task, MapString, Object parameters) { if (!Skill.super.validate(task, parameters)) { return false; } // 检查文件路径参数 Object filePath parameters.get(filePath); if (filePath null) { logger.warn(filePath parameter is missing); return false; } Path path Paths.get(filePath.toString()); if (!Files.exists(path)) { logger.warn(File does not exist: {}, filePath); return false; } if (!Files.isReadable(path)) { logger.warn(File is not readable: {}, filePath); return false; } return true; } Override public SkillResult execute(String task, MapString, Object parameters) { long startTime System.currentTimeMillis(); try { String filePath parameters.get(filePath).toString(); logger.info(Reading file: {}, filePath); Path path Paths.get(filePath); // 读取文件内容 String content new String(Files.readAllBytes(path), StandardCharsets.UTF_

; // 获取文件信息 long fileSize Files.size(path); String fileName path.getFileName().toString(); // 构建元数据 MapString, Object metadata new java.util.HashMap(); metadata.put(filePath, filePath); metadata.put(fileName, fileName); metadata.put(fileSize, fileSize); metadata.put(lines, content.split(\n).length); long executionTime System.currentTimeMillis() - startTime; logger.info(File read successfully: {} ({} bytes), fileName, fileSize); return SkillResult.success( 文件读取成功: fileName, content, executionTime, metadata ); } catch (IOException e) { logger.error(Error reading file, e); return SkillResult.failure(文件读取失败: e.getMessage(), e.getMessage()); } } Override public long getTimeout() { return 10000; // 10秒超时 } /** * 读取文件行 */ public ListString readLines(String filePath) throws IOException { Path path Paths.get(filePath); return Files.readAllLines(path, StandardCharsets.UTF_

; } /** * 检查文件是否存在 */ public boolean exists(String filePath) { return Files.exists(Paths.get(filePath)); } /** * 获取文件大小 */ public long getFileSize(String filePath) throws IOException { return Files.size(Paths.get(filePath)); } }

2 数据查询技能public class DataQuerySkill implements Skill { private final MapString, ListMapString, Object database; public DataQuerySkill() { this.database new ConcurrentHashMap(); initializeSampleData(); } Override public boolean canExecute(String task) { String lowerTask task.toLowerCase(); return lowerTask.contains(查询) || lowerTask.contains(数据); } Override public SkillResult execute(String task, MapString, Object parameters) { String tableName parameters.get(tableName).toString(); String condition parameters.get(condition).toString(); ListMapString, Object results performQuery( tableName, condition, 100 ); return SkillResult.success( 查询成功找到 results.size() 条记录, results ); } }

3 文本分析技能public class TextAnalysisSkill implements Skill { Override public SkillResult execute(String task, MapString, Object parameters) { String text parameters.get(text).toString(); String operation parameters.get(operation).toString(); switch (operation) { case stats: return analyzeStats(text); case keywords: return extractKeywords(text); case sentiment: return analyzeSentiment(text); default: return fullAnalysis(text); } } }

Agent交互机制

1 时序交互Agent与Skills之间的交互遵循明确的时序关系用户向Agent发送任务请求Agent查询Skill Registry获取可用技能Registry返回匹配的技能列表Agent调用具体技能执行任务技能返回执行结果Agent整合结果并返回给用户

2 上下文管理AgentContext在执行过程中传递和存储数据package com.example.agent; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * Agent执行上下文 * 用于在Agent执行过程中传递和存储数据 * version

1.

0 */ public class AgentContext { private final String requestId; private final MapString, Object attributes; private final MapString, Object sessionData; private final long createdAt; public AgentContext(String requestId) { this.requestId requestId; this.attributes new ConcurrentHashMap(); this.sessionData new ConcurrentHashMap(); this.createdAt System.currentTimeMillis(); } /** * 获取请求ID */ public String getRequestId() { return requestId; } /** * 设置属性 */ public void setAttribute(String key, Object value) { attributes.put(key, value); } /** * 批量设置属性 */ public void setAttributes(MapString, Object attributes) { if (attributes ! null) { this.attributes.putAll(attributes); } } /** * 获取属性 */ public Object getAttribute(String key) { return attributes.get(key); } /** * 获取属性带类型转换 */ SuppressWarnings(unchecked) public T T getAttribute(String key, ClassT type) { Object value attributes.get(key); if (value ! null type.isInstance(value)) { return (T) value; } return null; } /** * 移除属性 */ public Object removeAttribute(String key) { return attributes.remove(key); } /** * 设置会话数据 */ public void setSessionData(String key, Object value) { sessionData.put(key, value); } /** * 获取会话数据 */ public Object getSessionData(String key) { return sessionData.get(key); } /** * 获取所有属性 */ public MapString, Object getAllAttributes() { return new HashMap(attributes); } /** * 清空属性 */ public void clear() { attributes.clear(); } /** * 获取上下文创建时间 */ public long getCreatedAt() { return createdAt; } /** * 获取上下文存活时间毫秒 */ public long getAge() { return System.currentTimeMillis() - createdAt; } /** * 创建新的上下文 */ public static AgentContext create() { return create(generateRequestId()); } /** * 创建带请求ID的上下文 */ public static AgentContext create(String requestId) { return new AgentContext(requestId); } /** * 生成请求ID */ private static String generateRequestId() { return req- System.currentTimeMillis() - Thread.currentThread().getId(); } Override public String toString() { return AgentContext{ requestId requestId \ , attributes attributes.size() , sessionData sessionData.size() , age getAge() ms }; } }上下文分为临时属性和会话数据临时属性在单次请求中有效会话数据可以跨请求共享。

JMComic1.8.1安装-JMComic1.8.1安装应用