ChatmemoryRedis 历史对话存【REDIS】20260512
1、pom
<properties>
<java.version>17</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<spring-boot.version>3.2.0</spring-boot.version>
<spring-ai.version>1.0.0</spring-ai.version>
<spring-ai-alibaba.version>1.0.0.2</spring-ai-alibaba.version>
<jedis.version>5.2.0</jedis.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 阿里云通义千问（DashScope）starter -->
<dependency>
<groupId>com.alibaba.cloud.ai</groupId>
<artifactId>spring-ai-alibaba-starter-dashscope</artifactId>
</dependency>
<!--对话记忆 chat-memory-->
<dependency>
<groupId>org.springframework.ai</groupId>
<artifactId>spring-ai-autoconfigure-model-chat-memory</artifactId>
</dependency>
<!-- Spring AI JDBC 聊天记忆核心依赖 -->
<dependency>
<groupId>org.springframework.ai</groupId>
<artifactId>spring-ai-starter-model-chat-memory-repository-jdbc</artifactId>
</dependency>
<!-- Spring Boot JDBC Starter -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!-- MySQL 驱动 -->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
<!-- Spring AI Alibaba Redis 记忆 Starter -->
<dependency>
<groupId>com.alibaba.cloud.ai</groupId>
<artifactId>spring-ai-alibaba-starter-memory-redis</artifactId>
</dependency>
<!-- Jedis 客户端依赖 -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>${jedis.version}</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- 统一管理Spring AI依赖版本 -->
<dependency>
<groupId>org.springframework.ai</groupId>
<artifactId>spring-ai-bom</artifactId>
<version>${spring-ai.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud.ai</groupId>
<artifactId>spring-ai-alibaba-bom</artifactId>
<version>${spring-ai-alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<!-- Spring AI 里程碑/快照仓库（必须配置，否则依赖无法下载） -->
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/snapshot</url>
<releases>
<enabled>false</enabled>
</releases>
</repository>
</repositories>
2、yml
server:
port: 18081
spring:
ai:
dashscope:
api-key: sk-8718a83408d7443b9544cXXXXXXXX
chat:
memory:
repository:
jdbc:
initialize-schema: always
schema: classpath:/sql/schema-mysql.sql
memory:
# Redis 配置必须放在 spring.ai 下，层级要和你的 @Value 匹配
redis:
host: 192.168.91.165 # 你的 Redis 地址
port: 6379
timeout: 5000
# password: 123456 # 有密码再打开
datasource:
url: jdbc:mysql://192.168.91.165:3306/springai?useSSL=false&serverTimezone=UTC
username: root
password: root
driver-class-name: com.mysql.cj.jdbc.Driver
logging:
level:
org.springframework.ai.chat.client.advisor.SimpleLoggerAdvisor: debug
#org.springframework.ai.chat.client.advisor: debug
3、config
import com.alibaba.cloud.ai.memory.redis.RedisChatMemoryRepository;
import org.springframework.ai.chat.memory.ChatMemory;
import org.springframework.ai.chat.memory.MessageWindowChatMemory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class config {
@Value("${spring.ai.memory.redis.host}")
private String redisHost;
@Value("${spring.ai.memory.redis.port}")
private int redisPort;
@Value("${spring.ai.memory.redis.password:}")
private String redisPassword;
@Value("${spring.ai.memory.redis.timeout}")
private int redisTimeout;
// @Bean
// ChatMemory chatMemoryMax(ChatMemoryRepository chatMemoryRepository) {
// return MessageWindowChatMemory
// .builder()
// // 自定义最大消息数，覆盖默认的20条 （2 轮用户 + 助手对话）
// //保留最近 2 条消息。若超出则删除最早的消息
// .maxMessages(2)
// // 绑定持久化仓库（支持多用户会话隔离）
// .chatMemoryRepository(chatMemoryRepository)
// .build();
// }
//
// @Bean
// ChatMemory chatMemoryJdbc(JdbcChatMemoryRepository chatMemoryRepository) {
// return MessageWindowChatMemory
// .builder()
// // 自定义最大消息数，覆盖默认的20条 （2 轮用户 + 助手对话）
// //保留最近 4 条消息。若超出则删除最早的消息
// .maxMessages(4)
// // 绑定JDBC持久化仓库（支持多用户会话隔离）
// .chatMemoryRepository(chatMemoryRepository)
// .build();
// }
@Bean
RedisChatMemoryRepository redisChatMemoryRepository() {
return RedisChatMemoryRepository
.builder()
.host(redisHost)
.port(redisPort)
// 无密码时注释该行
//.password(redisPassword)
.timeout(redisTimeout)
.build();
}
@Bean
ChatMemory chatMemoryRedis(RedisChatMemoryRepository chatMemoryRepository) {
return MessageWindowChatMemory
.builder()
// 自定义最大消息数，覆盖默认的20条 （2 轮用户 + 助手对话）
//保留最近 4 条消息。若超出则删除最早的消息
.maxMessages(4)
// 绑定JDBC持久化仓库（支持多用户会话隔离）
.chatMemoryRepository(chatMemoryRepository)
.build();
}
}
4、tool
package com.sb.dashscope18081.tool;
import org.springframework.ai.chat.client.ChatClientRequest;
import org.springframework.ai.chat.client.ChatClientResponse;
import org.springframework.ai.chat.client.advisor.api.AdvisorChain;
import org.springframework.ai.chat.client.advisor.api.BaseAdvisor;
import org.springframework.ai.chat.prompt.Prompt;
import org.springframework.ai.chat.prompt.PromptTemplate;
import java.util.Map;
/**
* 自定义拦截器（Advisor，重读提示词
*/
public class ReReadingAdvisor implements BaseAdvisor {
// 重读提示词模板
private static final String DEFAULT_USER_TEXT_ADVISE = """
{re2_input_query}
Read the question again: {re2_input_query}
""";
@Override
public ChatClientRequest before(ChatClientRequest chatClientRequest, AdvisorChain advisorChain) {
// 1. 用户提示词
String contents = chatClientRequest.prompt().getContents();
String re2InputQuery=PromptTemplate.builder().template(DEFAULT_USER_TEXT_ADVISE).build()
.render(Map.of("re2_input_query", contents));
ChatClientRequest clientRequest = chatClientRequest.mutate()
.prompt(Prompt.builder()
.content(re2InputQuery)
.build())
.build();
return clientRequest;
}
@Override
public ChatClientResponse after(ChatClientResponse chatClientResponse, AdvisorChain advisorChain) {
return chatClientResponse;
}
@Override
public int getOrder() {
return 0;
}
}
5、controller
import com.alibaba.cloud.ai.dashscope.chat.DashScopeChatModel;
import com.sb.dashscope18081.tool.ReReadingAdvisor;
import org.springframework.ai.chat.client.ChatClient;
import org.springframework.ai.chat.client.advisor.PromptChatMemoryAdvisor;
import org.springframework.ai.chat.memory.ChatMemory;
import org.springframework.ai.chat.memory.MessageWindowChatMemory;
import org.springframework.ai.chat.messages.Message;
import org.springframework.ai.chat.messages.UserMessage;
import org.springframework.ai.chat.model.ChatResponse;
import org.springframework.ai.chat.prompt.Prompt;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.List;
@RequestMapping("/openai")
@ResponseBody
@Controller
public class ChatMemoryController {
@Autowired
private ChatClient.Builder chatClientBuilder;
@Autowired
private ChatMemory chatMemory; // 自动注入的MessageWindowChatMemory
@Autowired
DashScopeChatModel chatModel;
@Autowired
//保留最近 10 条消息。若超出则删除最早的消息
private ChatMemory chatMemoryMax;
@Autowired
//保留最近 10 条消息。若超出则删除最早的消息
//JDBC chatMemoryJdbc
private ChatMemory chatMemoryJdbc;
@Autowired
//Redis chatMemoryRedis
private ChatMemory chatMemoryRedis;
/**
* 基于 ChatMemoryredis 历史对话
*/
@GetMapping("/simple/chatmemoryredis")
public String chatmemoryredis () {
String conversationId = "redis001";
ChatClient chatClient = ChatClient.builder(chatModel)
.defaultAdvisors(
PromptChatMemoryAdvisor.builder(chatMemoryRedis).build()
)
.build();
String content= chatClient.prompt()
.user("你好，我叫杨坚!")
.advisors(new ReReadingAdvisor())
.advisors(advisorSpec->advisorSpec.param(ChatMemory.CONVERSATION_ID,conversationId))
.call()
.content();
System.out.println("content：" + content);
String content2= chatClient.prompt()
.user("我叫什么？")
.advisors(new ReReadingAdvisor())
.advisors(advisorSpec->advisorSpec.param(ChatMemory.CONVERSATION_ID,conversationId))
.call()
.content();
System.out.println("content2：" + content2);
return "【ChatMemoryredis历史对话】content：" +content+" content2：" +content2;
}
}
6、http://localhost:18081/openai/simple/chatmemoryredis
