Spring AI 全新会话 API支持结构化、可压缩、支持多智能体

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()); // 可直接传入大模型

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();

@BeanSessionMemoryAdvisor 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();}@BeanChatClient 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();

// 调研智能体可见：根事件 + 主调度事件 + 自身分支事件// 自动屏蔽同级写稿智能体的私有事件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();

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

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

<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>

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

@BeanSessionMemoryAdvisor sessionMemoryAdvisor(SessionService sessionService) {    return SessionMemoryAdvisor.builder(sessionService)        .defaultUserId("alice")        .compactionTrigger(new TurnCountTrigger(20))        .compactionStrategy(SlidingWindowCompactionStrategy.builder().maxEvents(10).build())        .build();}@BeanChatClient 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();

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

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