Spring博客更新了《SpringAI智能体模式》系列的第七篇

Spring博客更新了《Spring AI智能体模式》系列的第七篇，Spring AI 全新会话 API支持结构化、可压缩、支持多智能体，将用来替代版聊天内存（ChatMemory），下面是Spring AI会话API的主要内容。

版本规划

会话 API 架构

Spring AI 会话 API 核心类

会话（Session）与会话事件（SessionEvent）

• Session：不可变的纯元数据对象，仅存储会话 ID、用户 ID、过期时间（TTL）及自定义元数据。事件日志统一持久化至仓储层，按需加载。

• SessionEvent：封装 Spring AI 消息，并补充原生消息缺失的核心信息：唯一 UUID、会话 ID、时间戳、适配多智能体层级的分支标签、框架内置标识（如合成标记元数据）。

SessionService service = new DefaultSessionService(InMemorySessionRepository.builder().build());

Session session = service.create(
    CreateSessionRequest.builder().userId("alice").build()
);

service.appendMessage(session.id(), new UserMessage("What is Spring AI?"));
service.appendMessage(session.id(), new AssistantMessage("Spring AI is..."));

List<Message> history = service.getMessages(session.id()); // 可直接传入大模型

对话轮次（Turn）

轮次 1：[用户消息「Spring AI 是什么？」] → [助手回复] 轮次 2：[用户消息「它可以调用工具吗？」] → [助手工具调用] → [工具返回数据] → [助手最终回答]

上下文压缩

压缩触发器

new TurnCountTrigger(20);                                   // 轮次超过20次触发压缩
TokenCountTrigger.builder().threshold(4000).build();        // 预估Token达到4000触发压缩

// 组合触发器：满足任一条件即触发
CompositeCompactionTrigger.anyOf(
    new TurnCountTrigger(20),
    TokenCountTrigger.builder().threshold(4000).build()
);

压缩策略

RecursiveSummarizationCompactionStrategy.builder(chatClient)
    .maxEventsToKeep(10)
    .overlapSize(2)   // 携带最近2条活跃事件作为摘要上下文
    .build();

注意：触发器与压缩策略必须成对配置，仅配置单一项会在初始化时抛出非法参数异常；若需关闭压缩功能，可同时省略两项配置。

整合聊天客户端（ChatClient）

@Bean
SessionMemoryAdvisor sessionMemoryAdvisor(SessionService sessionService,
        ChatClient.Builder chatClientBuilder) {

    return SessionMemoryAdvisor.builder(sessionService)
        .defaultUserId("alice")
        .compactionTrigger(new TurnCountTrigger(20))
        .compactionStrategy(
            RecursiveSummarizationCompactionStrategy.builder(chatClientBuilder.build())
                .maxEventsToKeep(10)
                .build()
        )
        .build();
}

@Bean
ChatClient chatClient(ChatClient.Builder chatClientBuilder, SessionMemoryAdvisor advisor) {
    return chatClientBuilder.defaultAdvisors(advisor).build();
}

String response = chatClient.prompt()
    .user("Hello!")
    .advisors(a -> a.param(SessionMemoryAdvisor.SESSION_ID_CONTEXT_KEY, "session-abc"))
    .call()
    .content();

多智能体分支隔离

• 主调度智能体：分支 = "orch"

• 调研子智能体：分支 = "orch.researcher"

• 写稿子智能体：分支 = "orch.writer"

// 调研智能体可见：根事件 + 主调度事件 + 自身分支事件
// 自动屏蔽同级写稿智能体的私有事件
SessionMemoryAdvisor researcherAdvisor = SessionMemoryAdvisor.builder(sessionService)
    .defaultSessionId(sharedSessionId)
    .eventFilter(EventFilter.forBranch("orch.researcher"))
    .build();

历史回溯存储

ChatClient client = ChatClient.builder(chatModel)
    .defaultTools(SessionEventTools.builder(sessionService).build())
    .defaultAdvisors(advisor)
    .build();

JDBC 持久化

<dependency>
    <groupId>org.springaicommunity</groupId>
    <artifactId>spring-ai-starter-session-jdbc</artifactId>
</dependency>

spring:
  ai:
    session:
      repository:
        jdbc:
          initialize-schema: always

快速入门

环境要求

1. 引入依赖版本管理

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springaicommunity</groupId>
            <artifactId>spring-ai-session-bom</artifactId>
            <version>0.2.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

2. 引入启动器 生产环境选用 JDBC 版本，本地开发可仅引入内存版会话管理：

<dependency>
    <groupId>org.springaicommunity</groupId>
    <artifactId>spring-ai-starter-session-jdbc</artifactId>
</dependency>

3. 注册组件并使用

@Bean
SessionMemoryAdvisor sessionMemoryAdvisor(SessionService sessionService) {
    return SessionMemoryAdvisor.builder(sessionService)
        .defaultUserId("alice")
        .compactionTrigger(new TurnCountTrigger(20))
        .compactionStrategy(SlidingWindowCompactionStrategy.builder().maxEvents(10).build())
        .build();
}

@Bean
ChatClient chatClient(ChatModel chatModel, SessionMemoryAdvisor advisor) {
    return ChatClient.builder(chatModel).defaultAdvisors(advisor).build();
}

Session session = sessionService.create(
    CreateSessionRequest.builder().userId("alice").build()
);

String response = chatClient.prompt()
    .user("What is Spring AI?")
    .advisors(a -> a.param(SessionMemoryAdvisor.SESSION_ID_CONTEXT_KEY, session.id()))
    .call()
    .content();

从 ChatMemory 迁移至会话 API

MessageWindowChatMemory.builder().maxMessages(20).build()

SessionMemoryAdvisor.builder(sessionService)
    .compactionTrigger(new TurnCountTrigger(20))
    .compactionStrategy(SlidingWindowCompactionStrategy.builder().maxEvents(20).build())
    .build();