跳到主要内容

Agent Teams 全量 API 参考(类/函数/变量 + Demo + 预期)

本页覆盖 io.github.lnyocly.ai4j.agent.teamio.github.lnyocly.ai4j.agent.team.tool 包中所有源码类, 并按“类 -> 变量 -> 函数”展开说明,方便排查与二次开发。

文档由脚本从源码生成,建议在 Agent Teams 代码变更后重新执行: python docs-site/scripts/generate_agent_teams_api_docs.py

1. 快速 Demo

Agent lead = Agents.react()
.modelClient(new ResponsesModelClient(responsesService))
.model("doubao-seed-1-8-251228")
.systemPrompt("你是团队负责人,先规划再汇总")
.build();

Agent backend = Agents.react()
.modelClient(new ResponsesModelClient(responsesService))
.model("doubao-seed-1-8-251228")
.build();

Agent frontend = Agents.react()
.modelClient(new ResponsesModelClient(responsesService))
.model("doubao-seed-1-8-251228")
.build();

AgentTeam team = Agents.team()
.leadAgent(lead)
.member(AgentTeamMember.builder().id("backend").name("后端").agent(backend).build())
.member(AgentTeamMember.builder().id("frontend").name("前端").agent(frontend).build())
.options(AgentTeamOptions.builder()
.parallelDispatch(true)
.continueOnMemberError(true)
.maxRounds(64)
.build())
.build();

AgentTeamResult result = team.run("输出本周交付计划");
System.out.println(result.getOutput());

2. 预期行为(用于验收)

  • 预期 1:Planner 先产出 tasks,任务进入 PENDING/READY
  • 预期 2:并发开启时,多成员任务会并行执行;串行模式则按批次单线程执行。
  • 预期 3:成员成功后任务转为 COMPLETED;异常转 FAILED,依赖任务可能转 BLOCKED
  • 预期 4:continueOnMemberError=true 时,失败任务不会中断整个团队,最终仍会尝试汇总。
  • 预期 5:启用 enableMemberTeamTools 后,成员可调用 team_send_message/team_claim_task/... 完成主动协作。

3. 类/变量/函数全量说明

class AgentTeam

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeam.java:26
  • 职责:Agent Teams 的总调度器。负责规划、任务派发、并发执行、消息协作、最终汇总。

变量(字段)

名称类型可见性修饰符说明
SYSTEM_MEMBERStringprivatestatic final成员相关字段,描述团队角色或成员映射。
LEAD_MEMBERStringprivatestatic final成员相关字段,描述团队角色或成员映射。
plannerAgentTeamPlannerprivatefinal规划相关字段,保存 planner 输入/输出。
synthesizerAgentTeamSynthesizerprivatefinal运行期状态或配置字段,参与该类的核心行为。
optionsAgentTeamOptionsprivatefinal运行配置对象,影响行为和策略。
orderedMembersList<RuntimeMember>privatefinal成员相关字段,描述团队角色或成员映射。
membersByIdMap<String, RuntimeMember>privatefinal唯一标识/关联标识字段,用于实体定位或引用。
messageBusAgentTeamMessageBusprivatefinal消息相关字段,承载协作通信数据。
planApprovalAgentTeamPlanApprovalprivatefinal规划相关字段,保存 planner 输入/输出。
hooksList<AgentTeamHook>privatefinal集合字段,用于维护批量数据或索引映射。
teamToolRegistryAgentTeamToolRegistryprivatefinal运行期状态或配置字段,参与该类的核心行为。
activeBoardAgentTeamTaskBoardprivatevolatile运行期状态或配置字段,参与该类的核心行为。
activeObjectiveStringprivatevolatile运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
builder()AgentTeamBuilderpublicstatic构建入口方法,用于创建并返回目标对象。
registerMember(AgentTeamMember member)voidpublic-内部辅助方法,服务于该类的核心执行逻辑。
unregisterMember(String memberId)booleanpublic-布尔判定方法,返回条件是否满足。
listMembers()List<AgentTeamMember>public-查询方法,读取当前快照或历史记录。
listMessages()List<AgentTeamMessage>public-查询方法,读取当前快照或历史记录。
listMessagesFor(String memberId, int limit)List<AgentTeamMessage>public-查询方法,读取当前快照或历史记录。
publishMessage(AgentTeamMessage message)voidpublic-消息发布方法,向单成员或全体广播协作信息。
sendMessage(String fromMemberId, String toMemberId, String type, String taskId, String content)voidpublic-消息发布方法,向单成员或全体广播协作信息。
broadcastMessage(String fromMemberId, String type, String taskId, String content)voidpublic-消息发布方法,向单成员或全体广播协作信息。
listTaskStates()List<AgentTeamTaskState>public-查询方法,读取当前快照或历史记录。
claimTask(String taskId, String memberId)booleanpublic-任务认领/释放/重分配方法,维护任务所有权。
releaseTask(String taskId, String memberId, String reason)booleanpublic-任务认领/释放/重分配方法,维护任务所有权。
reassignTask(String taskId, String fromMemberId, String toMemberId)booleanpublic-任务认领/释放/重分配方法,维护任务所有权。
heartbeatTask(String taskId, String memberId)booleanpublic-运行保活与恢复方法,用于检测超时并回收任务。
run(String objective)AgentTeamResultpublic-执行入口方法,驱动主流程并返回执行结果。
run(AgentRequest request)AgentTeamResultpublic-执行入口方法,驱动主流程并返回执行结果。
ensurePlanApproved(String objective, AgentTeamPlan plan, List<AgentTeamMember> members)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
dispatchTasks(String objective, AgentTeamTaskBoard board)DispatchOutcomeprivate-任务派发方法,负责轮次调度与执行分配。
call()AgentTeamMemberResultpublic-内部辅助方法,服务于该类的核心执行逻辑。
waitForFuture(Future<AgentTeamMemberResult> future)AgentTeamMemberResultprivate-内部辅助方法,服务于该类的核心执行逻辑。
runMemberTask(PreparedDispatch dispatch, String input)AgentResultprivate-执行入口方法,驱动主流程并返回执行结果。
buildDispatchInput(String objective, RuntimeMember member, AgentTeamTask task)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
publishMessageInternal(AgentTeamMessage message)voidprivate-消息发布方法,向单成员或全体广播协作信息。
resolveMember(String requestedId)RuntimeMemberprivate-规范化与校验方法,保证输入可用和行为一致。
snapshotMembers()List<AgentTeamMember>private-查询方法,读取当前快照或历史记录。
currentBoard()AgentTeamTaskBoardprivate-内部辅助方法,服务于该类的核心执行逻辑。
rememberTaskStates(List<AgentTeamTaskState> taskStates)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
currentObjective()Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
resolveMemberView(String memberId)AgentTeamMemberprivate-规范化与校验方法,保证输入可用和行为一致。
fireTaskStateChanged(AgentTeamTaskState state, AgentTeamMember member, String detail)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
validateKnownMemberId(String memberId, boolean allowReserved, String fieldName)voidprivate-规范化与校验方法,保证输入可用和行为一致。
isReservedMember(String memberId)booleanprivate-布尔判定方法,返回条件是否满足。
fireBeforePlan(String objective, List<AgentTeamMember> members)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
fireAfterPlan(String objective, AgentTeamPlan plan)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
fireBeforeTask(String objective, AgentTeamTask task, AgentTeamMember member)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
fireAfterTask(String objective, AgentTeamMemberResult result)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
fireAfterSynthesis(String objective, AgentResult synthesis)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
normalize(String raw)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
safe(String value)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
firstNonBlank(String... values)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
safeShort(String value)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
toText(Object value)Stringprivate-转换方法,在内部对象与公开对象之间映射。

class AgentTeam.DispatchOutcome

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeam.java:874
  • 职责:AgentTeam 内部派发汇总对象,记录成员结果和轮次数。

变量(字段)

名称类型可见性修饰符说明
resultsList<AgentTeamMemberResult>privatefinal结果字段,存储执行输出或汇总产物。
roundsintprivatefinal运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
DispatchOutcome(List<AgentTeamMemberResult> results, int rounds)(constructor)private-构造函数,初始化该类型的必要依赖与默认状态。

class AgentTeam.PreparedDispatch

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeam.java:862
  • 职责:AgentTeam 内部派发单元,绑定 task/member 用于执行轮次。

变量(字段)

名称类型可见性修饰符说明
taskIdStringprivatefinal唯一标识/关联标识字段,用于实体定位或引用。
taskAgentTeamTaskprivatefinal任务相关字段,保存任务定义或运行态信息。
memberRuntimeMemberprivatefinal成员相关字段,描述团队角色或成员映射。

函数(方法)

方法返回可见性修饰符说明
PreparedDispatch(String taskId, AgentTeamTask task, RuntimeMember member)(constructor)private-构造函数,初始化该类型的必要依赖与默认状态。

class AgentTeam.RuntimeMember

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeam.java:824
  • 职责:AgentTeam 内部成员运行态对象,包装成员定义并缓存执行引用。

变量(字段)

名称类型可见性修饰符说明
idStringprivatefinal唯一标识/关联标识字段,用于实体定位或引用。
nameStringprivatefinal运行期状态或配置字段,参与该类的核心行为。
descriptionStringprivatefinal运行期状态或配置字段,参与该类的核心行为。
agentAgentprivatefinalAgent 执行实例引用。

函数(方法)

方法返回可见性修饰符说明
RuntimeMember(String id, String name, String description, Agent agent)(constructor)private-构造函数,初始化该类型的必要依赖与默认状态。
from(AgentTeamMember member)RuntimeMemberprivatestatic内部辅助方法,服务于该类的核心执行逻辑。
toPublicMember()AgentTeamMemberprivate-转换方法,在内部对象与公开对象之间映射。

class AgentTeamAgentRuntime

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamAgentRuntime.java:14
  • 职责:该类型用于 Agent Teams 运行链路中的结构定义或执行逻辑。

变量(字段)

名称类型可见性修饰符说明
templateAgentTeamBuilderprivatefinal运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
AgentTeamAgentRuntime(AgentTeamBuilder template)(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
run(AgentContext context, AgentRequest request)AgentResultpublic-执行入口方法,驱动主流程并返回执行结果。
runStream(AgentContext context, AgentRequest request, AgentListener listener)voidpublic-执行入口方法,驱动主流程并返回执行结果。
prepareTeam(AgentListener listener)AgentTeamprivate-内部辅助方法,服务于该类的核心执行逻辑。
copyBuilder(AgentTeamBuilder source)AgentTeamBuilderprivate-转换方法,在内部对象与公开对象之间映射。
toAgentResult(AgentTeamResult result)AgentResultprivate-转换方法,在内部对象与公开对象之间映射。

class AgentTeamBuilder

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamBuilder.java:12
  • 职责:构建 AgentTeam 的入口,组装 lead/planner/synthesizer/member/options。

变量(字段)

名称类型可见性修饰符说明
leadAgentAgentprivate-Agent 执行实例引用。
plannerAgentAgentprivate-规划相关字段,保存 planner 输入/输出。
synthesizerAgentAgentprivate-Agent 执行实例引用。
plannerAgentTeamPlannerprivate-规划相关字段,保存 planner 输入/输出。
synthesizerAgentTeamSynthesizerprivate-运行期状态或配置字段,参与该类的核心行为。
optionsAgentTeamOptionsprivate-运行配置对象,影响行为和策略。
messageBusAgentTeamMessageBusprivate-消息相关字段,承载协作通信数据。
planApprovalAgentTeamPlanApprovalprivate-规划相关字段,保存 planner 输入/输出。

函数(方法)

方法返回可见性修饰符说明
builder()AgentTeamBuilderpublicstatic构建入口方法,用于创建并返回目标对象。
getLeadAgent()Agentpublic-内部辅助方法,服务于该类的核心执行逻辑。
getPlannerAgent()Agentpublic-内部辅助方法,服务于该类的核心执行逻辑。
getSynthesizerAgent()Agentpublic-内部辅助方法,服务于该类的核心执行逻辑。
getPlanner()AgentTeamPlannerpublic-内部辅助方法,服务于该类的核心执行逻辑。
getSynthesizer()AgentTeamSynthesizerpublic-内部辅助方法,服务于该类的核心执行逻辑。
getMembers()List<AgentTeamMember>public-内部辅助方法,服务于该类的核心执行逻辑。
getOptions()AgentTeamOptionspublic-内部辅助方法,服务于该类的核心执行逻辑。
getMessageBus()AgentTeamMessageBuspublic-内部辅助方法,服务于该类的核心执行逻辑。
getPlanApproval()AgentTeamPlanApprovalpublic-内部辅助方法,服务于该类的核心执行逻辑。
getHooks()List<AgentTeamHook>public-内部辅助方法,服务于该类的核心执行逻辑。
leadAgent(Agent leadAgent)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
plannerAgent(Agent plannerAgent)AgentTeamBuilderpublic-规划方法,根据目标/成员生成任务计划。
synthesizerAgent(Agent synthesizerAgent)AgentTeamBuilderpublic-汇总方法,将多成员结果合并为最终输出。
planner(AgentTeamPlanner planner)AgentTeamBuilderpublic-规划方法,根据目标/成员生成任务计划。
synthesizer(AgentTeamSynthesizer synthesizer)AgentTeamBuilderpublic-汇总方法,将多成员结果合并为最终输出。
member(AgentTeamMember member)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
members(List<AgentTeamMember> members)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
options(AgentTeamOptions options)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
messageBus(AgentTeamMessageBus messageBus)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
planApproval(AgentTeamPlanApproval planApproval)AgentTeamBuilderpublic-规划方法,根据目标/成员生成任务计划。
hook(AgentTeamHook hook)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
hooks(List<AgentTeamHook> hooks)AgentTeamBuilderpublic-内部辅助方法,服务于该类的核心执行逻辑。
build()AgentTeampublic-构建入口方法,用于创建并返回目标对象。
buildAgent()Agentpublic-内部辅助方法,服务于该类的核心执行逻辑。
get()AgentMemorypublic-内部辅助方法,服务于该类的核心执行逻辑。

interface AgentTeamControl

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamControl.java:5
  • 职责:团队运行期控制接口,统一成员、任务、消息操作能力。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamEventHook

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamEventHook.java:12
  • 职责:该类型用于 Agent Teams 运行链路中的结构定义或执行逻辑。

变量(字段)

名称类型可见性修饰符说明
listenerAgentListenerprivatefinal集合字段,用于维护批量数据或索引映射。

函数(方法)

方法返回可见性修饰符说明
AgentTeamEventHook()(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
AgentTeamEventHook(AgentListener listener)(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
afterPlan(String objective, AgentTeamPlan plan)voidpublic-内部辅助方法,服务于该类的核心执行逻辑。
beforeTask(String objective, AgentTeamTask task, AgentTeamMember member)voidpublic-内部辅助方法,服务于该类的核心执行逻辑。
afterTask(String objective, AgentTeamMemberResult result)voidpublic-内部辅助方法,服务于该类的核心执行逻辑。
onMessage(AgentTeamMessage message)voidpublic-内部辅助方法,服务于该类的核心执行逻辑。
buildTaskSummary(AgentTeamTask task, String status)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
normalizeStatus(AgentTeamTaskStatus status)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
resolvePercent(String status, Integer statePercent)intprivate-规范化与校验方法,保证输入可用和行为一致。
emit(AgentEventType type, String message, Map<String, Object> payload)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
firstNonBlank(String... values)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
isBlank(String value)booleanprivate-布尔判定方法,返回条件是否满足。

interface AgentTeamHook

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamHook.java:7
  • 职责:生命周期钩子接口,支持在规划/任务/汇总阶段埋点与审计。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamMember

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamMember.java:9
  • 职责:成员定义对象,包含成员身份与绑定 Agent 实例。

变量(字段)

名称类型可见性修饰符说明
idStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
nameStringprivate-运行期状态或配置字段,参与该类的核心行为。
descriptionStringprivate-运行期状态或配置字段,参与该类的核心行为。
agentAgentprivate-Agent 执行实例引用。

函数(方法)

方法返回可见性修饰符说明
resolveId()Stringpublic-规范化与校验方法,保证输入可用和行为一致。
normalize(String raw)Stringprivate-规范化与校验方法,保证输入可用和行为一致。

class AgentTeamMemberResult

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamMemberResult.java:9
  • 职责:单个任务执行结果对象,记录产出、耗时、错误和状态。

变量(字段)

名称类型可见性修饰符说明
taskIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
memberIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
memberNameStringprivate-成员相关字段,描述团队角色或成员映射。
taskAgentTeamTaskprivate-任务相关字段,保存任务定义或运行态信息。
taskStatusAgentTeamTaskStatusprivate-任务相关字段,保存任务定义或运行态信息。
outputStringprivate-结果字段,存储执行输出或汇总产物。
errorStringprivate-运行期状态或配置字段,参与该类的核心行为。
rawResultAgentResultprivate-结果字段,存储执行输出或汇总产物。
durationMillislongprivate-运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
isSuccess()booleanpublic-布尔判定方法,返回条件是否满足。

class AgentTeamMessage

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamMessage.java:8
  • 职责:团队消息模型,承载 from/to/type/taskId/content。

变量(字段)

名称类型可见性修饰符说明
idStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
fromMemberIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
toMemberIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
typeStringprivate-运行期状态或配置字段,参与该类的核心行为。
taskIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
contentStringprivate-运行期状态或配置字段,参与该类的核心行为。
createdAtlongprivate-运行期状态或配置字段,参与该类的核心行为。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

interface AgentTeamMessageBus

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamMessageBus.java:5
  • 职责:消息总线抽象,定义 publish/snapshot/historyFor/clear。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamOptions

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamOptions.java:8
  • 职责:团队运行配置对象,控制并发、容错、消息注入、超时回收等行为。

变量(字段)

名称类型可见性修饰符说明
parallelDispatchbooleanprivate-运行期状态或配置字段,参与该类的核心行为。
maxConcurrencyintprivate-并发或阈值配置字段,影响调度上限。
continueOnMemberErrorbooleanprivate-成员相关字段,描述团队角色或成员映射。
broadcastOnPlannerFailurebooleanprivate-规划相关字段,保存 planner 输入/输出。
failOnUnknownMemberbooleanprivate-成员相关字段,描述团队角色或成员映射。
includeOriginalObjectiveInDispatchbooleanprivate-运行期状态或配置字段,参与该类的核心行为。
includeTaskContextInDispatchbooleanprivate-任务相关字段,保存任务定义或运行态信息。
includeMessageHistoryInDispatchbooleanprivate-消息相关字段,承载协作通信数据。
messageHistoryLimitintprivate-消息相关字段,承载协作通信数据。
enableMessageBusbooleanprivate-布尔开关字段,控制功能启用或治理策略。
allowDynamicMemberRegistrationbooleanprivate-布尔开关字段,控制功能启用或治理策略。
requirePlanApprovalbooleanprivate-布尔开关字段,控制功能启用或治理策略。
maxRoundsintprivate-并发或阈值配置字段,影响调度上限。
taskClaimTimeoutMillislongprivate-超时配置字段,用于控制等待和回收策略。
enableMemberTeamToolsbooleanprivate-布尔开关字段,控制功能启用或治理策略。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamPlan

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamPlan.java:10
  • 职责:Planner 输出后的计划模型,包含任务列表。

变量(字段)

名称类型可见性修饰符说明
tasksList<AgentTeamTask>private-任务相关字段,保存任务定义或运行态信息。
rawPlanTextStringprivate-规划相关字段,保存 planner 输入/输出。
fallbackbooleanprivate-运行期状态或配置字段,参与该类的核心行为。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

interface AgentTeamPlanApproval

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamPlanApproval.java:5
  • 职责:计划审批回调,允许在派发前人为/策略拦截。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

interface AgentTeamPlanner

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamPlanner.java:5
  • 职责:规划器接口,输入目标和成员,输出任务计划。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamResult

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamResult.java:11
  • 职责:一次团队运行的完整结果快照,含计划、成员结果、任务状态、消息、轮次。

变量(字段)

名称类型可见性修饰符说明
objectiveStringprivate-运行期状态或配置字段,参与该类的核心行为。
planAgentTeamPlanprivate-规划相关字段,保存 planner 输入/输出。
memberResultsList<AgentTeamMemberResult>private-成员相关字段,描述团队角色或成员映射。
taskStatesList<AgentTeamTaskState>private-任务相关字段,保存任务定义或运行态信息。
messagesList<AgentTeamMessage>private-消息相关字段,承载协作通信数据。
roundsintprivate-运行期状态或配置字段,参与该类的核心行为。
outputStringprivate-结果字段,存储执行输出或汇总产物。
synthesisResultAgentResultprivate-结果字段,存储执行输出或汇总产物。
totalDurationMillislongprivate-运行期状态或配置字段,参与该类的核心行为。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

interface AgentTeamSynthesizer

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamSynthesizer.java:7
  • 职责:汇总器接口,将成员结果整合为最终输出。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamTask

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamTask.java:10
  • 职责:任务定义模型,包含 id/memberId/task/context/dependsOn。

变量(字段)

名称类型可见性修饰符说明
idStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
memberIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
taskStringprivate-任务相关字段,保存任务定义或运行态信息。
contextStringprivate-运行期状态或配置字段,参与该类的核心行为。
dependsOnList<String>private-集合字段,用于维护批量数据或索引映射。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class AgentTeamTaskBoard

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamTaskBoard.java:11
  • 职责:任务状态机与依赖调度核心,实现 READY/IN_PROGRESS/COMPLETED 等流转。

变量(字段)

名称类型可见性修饰符说明
PERCENT_PLANNEDintprivatestatic final规划相关字段,保存 planner 输入/输出。
PERCENT_READYintprivatestatic final运行期状态或配置字段,参与该类的核心行为。
PERCENT_IN_PROGRESSintprivatestatic final运行期状态或配置字段,参与该类的核心行为。
PERCENT_TERMINALintprivatestatic final运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
AgentTeamTaskBoard(List<AgentTeamTask> tasks)(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
initialize(List<AgentTeamTask> tasks)voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
normalizedTasks()List<AgentTeamTask>publicsynchronized规范化与校验方法,保证输入可用和行为一致。
nextReadyTasks(int maxCount)List<AgentTeamTaskState>publicsynchronized内部辅助方法,服务于该类的核心执行逻辑。
getTaskState(String taskId)AgentTeamTaskStatepublicsynchronized内部辅助方法,服务于该类的核心执行逻辑。
claimTask(String taskId, String memberId)booleanpublicsynchronized任务认领/释放/重分配方法,维护任务所有权。
releaseTask(String taskId, String memberId, String reason)booleanpublicsynchronized任务认领/释放/重分配方法,维护任务所有权。
reassignTask(String taskId, String fromMemberId, String toMemberId)booleanpublicsynchronized任务认领/释放/重分配方法,维护任务所有权。
heartbeatTask(String taskId, String memberId)booleanpublicsynchronized运行保活与恢复方法,用于检测超时并回收任务。
recoverTimedOutClaims(long timeoutMillis, String reason)intpublicsynchronized运行保活与恢复方法,用于检测超时并回收任务。
markInProgress(String taskId, String claimedBy)voidpublicsynchronized状态写入方法,推进任务状态机到下一个阶段。
markCompleted(String taskId, String output, long durationMillis)voidpublicsynchronized状态写入方法,推进任务状态机到下一个阶段。
markFailed(String taskId, String error, long durationMillis)voidpublicsynchronized状态写入方法,推进任务状态机到下一个阶段。
markStalledAsBlocked(String reason)voidpublicsynchronized状态写入方法,推进任务状态机到下一个阶段。
hasWorkRemaining()booleanpublicsynchronized布尔判定方法,返回条件是否满足。
hasFailed()booleanpublicsynchronized布尔判定方法,返回条件是否满足。
snapshot()List<AgentTeamTaskState>publicsynchronized查询方法,读取当前快照或历史记录。
size()intpublicsynchronized内部辅助方法,服务于该类的核心执行逻辑。
refreshStatuses()voidprivate-内部辅助方法,服务于该类的核心执行逻辑。
resolveTaskKey(String taskId)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
normalizeDependencies(List<String> dependencies)List<String>private-规范化与校验方法,保证输入可用和行为一致。
normalizeId(String raw)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
normalizeMemberId(String memberId)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
isSameMember(String currentClaimedBy, String expectedMemberId)booleanprivate-布尔判定方法,返回条件是否满足。
copy(AgentTeamTaskState state)AgentTeamTaskStateprivate-转换方法,在内部对象与公开对象之间映射。
percentOf(AgentTeamTaskState state)intprivate-内部辅助方法,服务于该类的核心执行逻辑。
selectUpdatedAt(AgentTeamTaskState state)longprivate-内部辅助方法,服务于该类的核心执行逻辑。
trimToNull(String value)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
firstNonBlank(String... values)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。

class AgentTeamTaskState

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamTaskState.java:8
  • 职责:任务运行态对象,记录 claim、heartbeat、输出、错误、耗时。

变量(字段)

名称类型可见性修饰符说明
taskIdStringprivate-唯一标识/关联标识字段,用于实体定位或引用。
taskAgentTeamTaskprivate-任务相关字段,保存任务定义或运行态信息。
statusAgentTeamTaskStatusprivate-运行期状态或配置字段,参与该类的核心行为。
claimedByStringprivate-运行期状态或配置字段,参与该类的核心行为。
startTimelongprivate-运行期状态或配置字段,参与该类的核心行为。
endTimelongprivate-运行期状态或配置字段,参与该类的核心行为。
durationMillislongprivate-运行期状态或配置字段,参与该类的核心行为。
lastHeartbeatTimelongprivate-运行期状态或配置字段,参与该类的核心行为。
phaseStringprivate-运行期状态或配置字段,参与该类的核心行为。
detailStringprivate-运行期状态或配置字段,参与该类的核心行为。
percentIntegerprivate-运行期状态或配置字段,参与该类的核心行为。
updatedAtEpochMslongprivate-运行期状态或配置字段,参与该类的核心行为。
heartbeatCountintprivate-运行期状态或配置字段,参与该类的核心行为。
outputStringprivate-结果字段,存储执行输出或汇总产物。
errorStringprivate-运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
isTerminal()booleanpublic-布尔判定方法,返回条件是否满足。

enum AgentTeamTaskStatus

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/AgentTeamTaskStatus.java:3
  • 职责:任务状态枚举。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

  • 无显式方法(或主要由 Lombok 生成 getter/setter/builder)。

class InMemoryAgentTeamMessageBus

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/InMemoryAgentTeamMessageBus.java:7
  • 职责:内存消息总线实现,适合单进程场景。

变量(字段)

  • 无显式字段(或仅由 Lombok/编译器生成)。

函数(方法)

方法返回可见性修饰符说明
publish(AgentTeamMessage message)voidpublicsynchronized消息发布方法,向单成员或全体广播协作信息。
snapshot()List<AgentTeamMessage>publicsynchronized查询方法,读取当前快照或历史记录。
historyFor(String memberId, int limit)List<AgentTeamMessage>publicsynchronized查询方法,读取当前快照或历史记录。
clear()voidpublicsynchronized内部辅助方法,服务于该类的核心执行逻辑。

class LlmAgentTeamPlanner

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/LlmAgentTeamPlanner.java:11
  • 职责:基于 Agent 的默认规划器实现,模型输出计划,失败时可回退简单计划。

变量(字段)

名称类型可见性修饰符说明
plannerAgentAgentprivatefinal规划相关字段,保存 planner 输入/输出。

函数(方法)

方法返回可见性修饰符说明
LlmAgentTeamPlanner(Agent plannerAgent)(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
plan(String objective, List<AgentTeamMember> members, AgentTeamOptions options)AgentTeamPlanpublic-规划方法,根据目标/成员生成任务计划。
buildPlannerPrompt(String objective, List<AgentTeamMember> members)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
fallbackTasks(String objective, List<AgentTeamMember> members)List<AgentTeamTask>private-内部辅助方法,服务于该类的核心执行逻辑。

class LlmAgentTeamSynthesizer

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/LlmAgentTeamSynthesizer.java:11
  • 职责:基于 Agent 的默认汇总器实现,汇总成员结果为最终答复。

变量(字段)

名称类型可见性修饰符说明
synthesizerAgentAgentprivatefinalAgent 执行实例引用。

函数(方法)

方法返回可见性修饰符说明
LlmAgentTeamSynthesizer(Agent synthesizerAgent)(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。

class AgentTeamToolExecutor

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/tool/AgentTeamToolExecutor.java:13
  • 职责:team_* 工具执行器,将成员工具调用路由到 AgentTeamControl。

变量(字段)

名称类型可见性修饰符说明
controlAgentTeamControlprivatefinal运行期状态或配置字段,参与该类的核心行为。
memberIdStringprivatefinal唯一标识/关联标识字段,用于实体定位或引用。
defaultTaskIdStringprivatefinal唯一标识/关联标识字段,用于实体定位或引用。
delegateToolExecutorprivatefinal运行期状态或配置字段,参与该类的核心行为。

函数(方法)

方法返回可见性修饰符说明
execute(AgentToolCall call)Stringpublic-执行入口方法,驱动主流程并返回执行结果。
handleSendMessage(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleBroadcast(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleListTasks()Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleClaimTask(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleReleaseTask(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleReassignTask(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
handleHeartbeatTask(JSONObject args)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
parseArguments(String raw)JSONObjectprivate-解析方法,将文本/参数转换为结构化对象。
resolveTaskId(JSONObject args, boolean required)Stringprivate-规范化与校验方法,保证输入可用和行为一致。
findTaskState(String taskId)AgentTeamTaskStateprivate-内部辅助方法,服务于该类的核心执行逻辑。
firstString(JSONObject args, String... keys)Stringprivate-内部辅助方法,服务于该类的核心执行逻辑。
baseResult(String action, boolean ok)JSONObjectprivate-内部辅助方法,服务于该类的核心执行逻辑。

class AgentTeamToolRegistry

  • 源码:ai4j-agent/src/main/java/io/github/lnyocly/ai4j/agent/team/tool/AgentTeamToolRegistry.java:15
  • 职责:team_* 工具注册表,定义并暴露团队内置协作工具。

变量(字段)

名称类型可见性修饰符说明
TOOL_SEND_MESSAGEStringpublicstatic final消息相关字段,承载协作通信数据。
TOOL_BROADCASTStringpublicstatic final运行期状态或配置字段,参与该类的核心行为。
TOOL_LIST_TASKSStringpublicstatic final任务相关字段,保存任务定义或运行态信息。
TOOL_CLAIM_TASKStringpublicstatic final任务相关字段,保存任务定义或运行态信息。
TOOL_RELEASE_TASKStringpublicstatic final任务相关字段,保存任务定义或运行态信息。
TOOL_REASSIGN_TASKStringpublicstatic final任务相关字段,保存任务定义或运行态信息。
TOOL_HEARTBEAT_TASKStringpublicstatic final任务相关字段,保存任务定义或运行态信息。
toolsList<Object>privatefinal集合字段,用于维护批量数据或索引映射。

函数(方法)

方法返回可见性修饰符说明
AgentTeamToolRegistry()(constructor)public-构造函数,初始化该类型的必要依赖与默认状态。
getTools()List<Object>public-内部辅助方法,服务于该类的核心执行逻辑。
supports(String toolName)booleanpublicstatic能力探测方法,判断是否支持某个功能或工具。
buildTools()List<Object>private-内部辅助方法,服务于该类的核心执行逻辑。
createSendMessageTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createBroadcastTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createListTasksTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createClaimTaskTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createReleaseTaskTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createReassignTaskTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
createHeartbeatTaskTool()Toolprivate-内部辅助方法,服务于该类的核心执行逻辑。
stringProperty(String description)Tool.Function.Propertyprivate-内部辅助方法,服务于该类的核心执行逻辑。