夜雨聆风学习资料网

ARTICLE · 1158419

langgraph4j原理源码分析图 II图编译

langgraph4j原理源码分析图 II图编译

  简介

    langgraph4j是java技术栈ai agent框架,深入掌握其源码与原理,指导agent的开发,重构/改造框架,增加特性,快速定位和修复bug,发布私有版本

系列内容:

> 架构,包括逻辑架构,运行架构,集成架构

> 状态图

>> 状态和序列化

>> StatGraph分析

>> 推理框架

> 编译图

> 执行图

>> 检查点

>> aync-generator

>> 执行分析

>>> 中断/恢复

>>> 取消执行

> agent和集成

>> 简单agent

>> 多agent

> 观测

> studio

本文分析图编译

本文基于langgraph4j v1.8.20

 关键词

agent

graph

 缩写

spring ai 缩写sa

spring ai alibaba 缩写saa

 参考资料

Overview - LangGraph4j  langgraph4j官网

mp.weixin.qq.com/mp/appmsgalbum?action=getalbum&album_id=4540202703779627014

spring ai Alibaba原理源码分析,包括spring ai部分

 lg4j概览

上图 lg4j的逻辑架构图,逻辑架构展示lg4j功能模块,描述其职责,模块通过精密的协作,共同支撑起复杂 Agent 的构建与运行。

逻辑架构解构为以下四个核心域:图编排、执行与状态、基础设施扩展、集成外部能力生态、开发支持

1. 核心编排层:图的蓝图与引擎

StateGraph (状态图):这是开发者构建 Agent 的核心抽象。它代表了整个工作流的“蓝图”,开发者在这里定义有哪些节点(Node)以及它们之间的流转规则(Edge)。

CompiledGraph (编译图):当 StateGraph 被构建完成后,经过 compile() 方法转化而来。编译图重整了状态图的数据结构,支持高效的图执行;编译图包含了流执行逻辑、状态机引擎和调度策略的“可运行实例”。

2. 执行与状态层:原子动作与数据流转

3. 基础设施扩展层:持久化、异步与可观测

4. agent,agent有两部分,core内agent包是lg4j提供;  core外的agent框架,spring ai alibaba移植,提供完整的agent框架,也包括基于core内agent重构的agent builder组件

5. 外部能力生态层:AI 核心能力

这一层是LangGraph4j 与 AI 生态对接。

  • Spring AI
    作为底层的能力供给层,Spring AI 提供了 Agent 所需的原子能力,包括 LLM model(大语言模型)、RAG(检索增强生成)、prompt(提示词工程)、memory(长期记忆)、mcp&tool&skills(工具调用与技能扩展)等。
  • LangGraph4j
    也集成了langchain4j

5. 开发工具

Studio (可视化开发工具):lg4j的Studio模块提供了一套完整的可视化调试和开发界面,让开发者能够直观地看到图的执行路径和状态流转,极大地降低了复杂 Agent 的开发门槛。

 graph

lg4j是workflow框架,以图的结构,节点,边构建处理流程,节点执行动作实现逻辑,边决定下一个节点。agentic是另一种模式,整个流程大模型自主编排,agentic省心省事,但同时agentic容易失控,纯粹看大模型心情,因此,目前比较好的方案,主体使用flowable,需要的时候使用agentic节点。

在lg4j, agent的推理框架映射成graph,以图的节点承载执行逻辑,边决定下一节点,支持检查点保存执行状态,实现执行的暂停和恢复

编译图

上篇分析了状态图,状态图是图的结构,目的是为了方便构建图;而编译图数据结构,目的是为了高效执行

上图是编译图类图,编译把整个图,包括子图的数据结构转换为扁平化的邻接表结构。并行分支,使用并行节点,节点内处理并行,执行器无需处理并行。

nodes 图的节点集,类型Map<String, AsyncNodeActionWithConfig<State>>

edges 图的边集,类型Map<String, EdgeValue<State>>

结构是变种的邻接表,与正常邻接表不同,编译图有默认起始节点START,节点Id获取EdgeValue计算出后续的连接的节点

EdgeValue: 封装了边的信息,二选一

    • 字符串: 节点的id,简单路由,指向一个节点
    • EdgeCondition: 条件
  • EdgeCondition: 条件,决定走哪条边。
    • AsyncCommandAction: 返回命令 (Command)。
    • 动作 (acton): 条件的判断逻辑
    • 映射关系 (mappings): 条件和节点的映射关系集,例如,X:_x_, EdgeCondition返回‘X’,边走’_x_’节点

下面分析编译的原理和源码

扁平化邻接表

ProcessedNodesEdgesAndConfig 负责扁平化状态图数据结构,以示例解释代码逻辑

介绍一下连接表,

'A': ['B'],

'B': ['C'],

'C': []

连接点结构,左是head节点,’A’,’B’,’C’; 右是数组,代表head节点连接的节点

对应的图

进一步,假设B是子图节点,其子图 D->E, D->F,E->G,F->G

ProcessedNodesEdgesAndConfig处理过后

'A': ['B-D'],

'B-D': ['B-E', 'B-F'],

'B-E': ['B-G'],

'B-F': ['B-G'],

'B-G': ['C'],

 'C': []

图的数据结构扁平化,合并到一个邻接表结构,主图与子图节点(B)的连接重定向到子图的节点,子图节点名称修改,格式%s-%s

最后,返回子图的Node写入到nodes,节点id为key,action为value的map

CompiledGraph.CompiledGraph()

nodes是最终的邻接表head节点集

!lg4j子图节点有两种,一种是StateGraph,状态图,另一种CompiledGraph,编译图,只有状态图编译打平,编译图是保留独立的执行,用在多agent的子agent

边和并行处理

ProcessedNodesEdgesAndConfig处理后,返回边(edges)是list,图遍历按节点找边需要遍历list,因此边数据需要转为map,以sourceNodeId为key,List<Edge>类型转为Map<String, EdgeValue>,另外,图有并行分支,编译使用并行节点替代,并行执行action完成在并行节点内完成,不需要执行器介入

下图,边处理分多targes和单个target

elements是list类型,下面是编译图的数据结构,Map类型

nodes 图的节点集,类型Map<String, AsyncNodeActionWithConfig<State>>

edges 图的边集,类型Map<String, EdgeValue<State>>

上图,target=1,直接put入edges,虽然target=1,可以是只有一个边,也可以是多个边,当EdgeValue是EdgeCondition,AsyncCommandAction<S>和边mappings,支持多个边选一

上图 target>1,并行分支,上图的代码逻辑是从A找到[A1, A2, A3],再找到B,分支的聚合点

上图 图的约束,规定并行分支只能聚合到同一个节点,如上图B,否则报错illegalMultipleTargetsOnParallelNode

还有一个约束,分支的边的值类型不能是条件,也就是只能是字符串,nodeId

上图 并行分支action合并到并行节点执行,并行节点写入nodes

原分支节点前后节点连到新的并行节点,到此图结构编译完成

总结:

编译前

其中节点B是子图

编译中,扁平的邻接点

编译后

上图是示例编译后的图,可以理解为是一个”降维”的处理,”摆平”多层的主图子图结构,”摆平”并行处理,降低执行器复杂度,提高执行效率

相关学习资料