ReactAgent的Bean配置与组件装配
为什么要单独讲 Bean 配置?
在上一篇我们看到 ReactAgentExecutor 的构造函数注入了一个 ReactAgent businessChatReactAgent。这个 Bean 是整个开放式问答的"大脑"——它决定了 Agent 用什么模型推理、能调用哪些工具、最多能调几次、出错了怎么处理。
理解这个 Bean 的装配过程,就能理解 Agent 的能力边界和行为约束。
配置类全貌
@Configuration
@EnableConfigurationProperties({ChatAgentProperties.class, TavilySearchProperties.class})
public class ChatAgentConfiguration {
@Bean
public MysqlSaver mysqlCheckpointSaver(DataSource dataSource) {
return MysqlSaver.builder()
.dataSource(dataSource)
.createOption(CreateOption.CREATE_IF_NOT_EXISTS)
.build();
}
@Bean
public ToolCallback tavilySearchToolCallback(TavilySearchTool tavilySearchTool) {
return FunctionToolCallback
.builder("tavily_search", tavilySearchTool::search)
.description("联网搜索最新信息、事实资料和网页来源。调用时必须传 JSON 参数,且至少包含非空 query;可选 topic 和 maxResults,其中 topic 仅允许 general、news、finance。")
.inputType(TavilySearchRequest.class)
.build();
}
@Bean
public ReactAgent businessChatReactAgent(ChatModel chatModel,
MysqlSaver mysqlCheckpointSaver,
ToolCallback tavilySearchToolCallback,
ChatAgentProperties chatAgentProperties,
DashScopeCompatibilityInterceptor dashScopeCompatibilityInterceptor,
TavilyToolInputFallbackInterceptor tavilyToolInputFallbackInterceptor) {
return ReactAgent.builder()
.name("business_chat_agent")
.model(chatModel)
.instruction(chatAgentProperties.getSystemPrompt())
.tools(tavilySearchToolCallback)
.saver(mysqlCheckpointSaver)
.parallelToolExecution(true)
.maxParallelTools(4)
.hooks(
ModelCallLimitHook.builder()
.runLimit(chatAgentProperties.getMaxModelCallsPerRun())
.threadLimit(chatAgentProperties.getMaxModelCallsPerThread())
.exitBehavior(ModelCallLimitHook.ExitBehavior.END)
.build(),
ToolCallLimitHook.builder()
.toolName("tavily_search")
.runLimit(chatAgentProperties.getMaxToolCallsPerRun())
.threadLimit(chatAgentProperties.getMaxToolCallsPerThread())
.exitBehavior(ToolCallLimitHook.ExitBehavior.END)
.build()
)
.interceptors(
dashScopeCompatibilityInterceptor,
tavilyToolInputFallbackInterceptor,
ToolRetryInterceptor.builder()
.toolName("tavily_search")
.maxRetries(2)
.initialDelay(200L)
.maxDelay(1200L)
.jitter(true)
.onFailure(ToolRetryInterceptor.OnFailureBehavior.RETURN_MESSAGE)
.build(),
ToolErrorInterceptor.builder().build()
)
.build();
}
}
付费内容提示
该文档的全部内容仅对「JavaUp项目实战&技术讲解」知识星球用户开放
加入星球后,你可以获得:
- 超级八股文:100万+字的全栈技术知识库,涵盖技术核心、数据库、中间件、分布式等深度剖析的讲解
- 讲解文档:超级AI智能体、黑马点评Plus、大麦、大麦pro、大麦AI、流量切换、数据中台的从0到1的详细文档
- 讲解视频:超级AI智能体、黑马点评Plus、大麦、大麦pro、大麦AI、流量切换、数据中台的核心业务详细讲解
- 1 对 1 解答:可以对我进行1对1的问题提问,而不仅仅只限于项目
- 针对性服务:有没理解的地方,文档或者视频还没有讲到可以提出,本人会补充
- 面试与简历指导:提供面试回答技巧,项目怎样写才能在简历中具有独特的亮点
- 中间件环境:对于项目中需要使用的中间件,可直接替换成我提供的云环境
- 面试后复盘:小伙伴去面试后,如果哪里被面试官问住了,可以再找我解答
- 远程的解决:如果在启动项目遇到问题,本人可以帮你远程解决
进入星球后,即可享受上述所有服务,保证不会再有其他隐藏费用。
