feat(jmanus): feat jmanus support memory (alibaba#2089)

* 记忆功能支持

* 优化

* 添加内存支持

* 添加页面选择记忆能力，待优化前后端交互数据

* 去除无效依赖

* 排除冲突依赖

* 优化页面展示

* 优化记忆能力

* 添加h2数据库内存支持

* 国际化支持

* 添加注释

* 优化页面图标

* 优化页面样式

* 去除中文

* 格式化代码

* 文件尾添加空行

* 去除无效依赖

* 优化页面展示

* 调整页面样式，优化功能

* 格式化和添加协议

* 去除无效依赖

* 优化记忆内容

* 优化前端写法

* 优化参数写法

* 前端编译后提交

* 记忆id构建从前端改为后端，优化重复任务会多次存储记忆问题

* 重新打包前端页面

* 优化home页对话失败问题

* 重新编译前端页面

* 优化页面显示

* 优化页面样式

* 优化样式，去除无用代码

* merge and build

* 格式化代码

Author: 970263611

pom.xml

@@ -37,7 +37,6 @@
         <maven-checkstyle-plugin.failOnViolation>true</maven-checkstyle-plugin.failOnViolation>
         <puppycrawl-tools-checkstyle.version>9.3</puppycrawl-tools-checkstyle.version>
 
-
     </properties>
 
     <dependencyManagement>
@@ -105,6 +104,10 @@
                     <artifactId>spring-ai-autoconfigure-model-openai</artifactId>
                     <groupId>org.springframework.ai</groupId>
                 </exclusion>
+                <exclusion>
+                    <artifactId>spring-ai-autoconfigure-model-chat-memory</artifactId>
+                    <groupId>org.springframework.ai</groupId>
+                </exclusion>
             </exclusions>
         </dependency>
         <dependency>
@@ -248,10 +251,11 @@
             <artifactId>h2</artifactId>
             <scope>runtime</scope>
         </dependency>
+
         <!-- MySQL Database -->
         <dependency>
-            <groupId>mysql</groupId>
-            <artifactId>mysql-connector-java</artifactId>
+            <groupId>com.mysql</groupId>
+            <artifactId>mysql-connector-j</artifactId>
             <version>8.0.33</version>
             <scope>runtime</scope>
         </dependency>

src/main/java/com/alibaba/cloud/ai/example/manus/config/MemoryConfig.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.cloud.ai.example.manus.config;
+
+import com.alibaba.cloud.ai.example.manus.dynamic.memory.repository.H2ChatMemoryRepository;
+import com.alibaba.cloud.ai.example.manus.dynamic.memory.repository.MysqlChatMemoryRepository;
+import com.alibaba.cloud.ai.example.manus.dynamic.memory.repository.PostgresChatMemoryRepository;
+import org.springframework.ai.chat.memory.ChatMemory;
+import org.springframework.ai.chat.memory.ChatMemoryRepository;
+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;
+import org.springframework.jdbc.core.JdbcTemplate;
+
+/**
+ * @author dahua
+ * @time 2025/8/5
+ * @desc memory config for manus
+ */
+@Configuration
+public class MemoryConfig {
+
+	// import memory auto configuration
+	// jmanus only support memory for mysql and postgresql now
+	@Value("${spring.ai.memory.mysql.enabled:false}")
+	private boolean mysqlEnabled;
+
+	@Value("${spring.ai.memory.postgres.enabled:false}")
+	private boolean postgresEnabled;
+
+	@Value("${spring.ai.memory.h2.enabled:false}")
+	private boolean h2Enabled;
+
+	@Bean
+	public ChatMemory chatMemory(ChatMemoryRepository chatMemoryRepository) {
+		return MessageWindowChatMemory.builder().chatMemoryRepository(chatMemoryRepository).build();
+	}
+
+	@Bean
+	public ChatMemoryRepository chatMemoryRepository(JdbcTemplate jdbcTemplate) {
+		ChatMemoryRepository chatMemoryRepository = null;
+		if (mysqlEnabled) {
+			chatMemoryRepository = MysqlChatMemoryRepository.mysqlBuilder().jdbcTemplate(jdbcTemplate).build();
+		}
+		else if (postgresEnabled) {
+			chatMemoryRepository = PostgresChatMemoryRepository.postgresBuilder().jdbcTemplate(jdbcTemplate).build();
+		}
+		else if (h2Enabled) {
+			chatMemoryRepository = H2ChatMemoryRepository.h2Builder().jdbcTemplate(jdbcTemplate).build();
+		}
+		if (chatMemoryRepository == null) {
+			throw new RuntimeException("Please enable mysql or postgres or h2 memory");
+		}
+		return chatMemoryRepository;
+	}
+
+}

src/main/java/com/alibaba/cloud/ai/example/manus/dynamic/agent/service/AgentService.java

@@ -39,7 +39,7 @@ public interface AgentService {
 	 * Create and return a usable BaseAgent object, similar to the
 	 * createPlanningCoordinator method in PlanningFactory
 	 * @param name Agent name
-	 * @param planId Plan ID, used to identify the plan the agent belongs to
+	 * @param currentPlanId Plan ID, used to identify the plan the agent belongs to
 	 * @return Created BaseAgent object
 	 */
 	BaseAgent createDynamicBaseAgent(String name, String currentPlanId, String rootPlanId,

src/main/java/com/alibaba/cloud/ai/example/manus/dynamic/memory/advisor/CustomMessageChatMemoryAdvisor.java

@@ -0,0 +1,212 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.cloud.ai.example.manus.dynamic.memory.advisor;
+
+import org.springframework.ai.chat.client.ChatClientMessageAggregator;
+import org.springframework.ai.chat.client.ChatClientRequest;
+import org.springframework.ai.chat.client.ChatClientResponse;
+import org.springframework.ai.chat.client.advisor.api.*;
+import org.springframework.ai.chat.memory.ChatMemory;
+import org.springframework.ai.chat.messages.Message;
+import org.springframework.ai.chat.messages.UserMessage;
+import org.springframework.util.Assert;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Scheduler;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 2025/8/7 auth: dahua
+ */
+public class CustomMessageChatMemoryAdvisor implements BaseChatMemoryAdvisor {
+
+	private final ChatMemory chatMemory;
+
+	private final String defaultConversationId;
+
+	private final int order;
+
+	private final Scheduler scheduler;
+
+	private String userRequest;
+
+	private AdvisorType advisorType;
+
+	private CustomMessageChatMemoryAdvisor(ChatMemory chatMemory, String defaultConversationId, int order,
+			Scheduler scheduler, String userRequest, AdvisorType advisorType) {
+		Assert.notNull(chatMemory, "chatMemory cannot be null");
+		Assert.hasText(defaultConversationId, "defaultConversationId cannot be null or empty");
+		Assert.notNull(scheduler, "scheduler cannot be null");
+		this.chatMemory = chatMemory;
+		this.defaultConversationId = defaultConversationId;
+		this.order = order;
+		this.scheduler = scheduler;
+		this.userRequest = userRequest;
+		this.advisorType = advisorType;
+	}
+
+	@Override
+	public int getOrder() {
+		return this.order;
+	}
+
+	@Override
+	public Scheduler getScheduler() {
+		return this.scheduler;
+	}
+
+	@Override
+	public ChatClientRequest before(ChatClientRequest chatClientRequest, AdvisorChain advisorChain) {
+		String conversationId = getConversationId(chatClientRequest.context(), this.defaultConversationId);
+
+		// 1. Retrieve the chat memory for the current conversation.
+		List<Message> memoryMessages = this.chatMemory.get(conversationId);
+
+		// 2. Advise the request messages list.
+		List<Message> processedMessages = new ArrayList<>(memoryMessages);
+		processedMessages.addAll(chatClientRequest.prompt().getInstructions());
+
+		// 3. Create a new request with the advised messages.
+		ChatClientRequest processedChatClientRequest = chatClientRequest.mutate()
+			.prompt(chatClientRequest.prompt().mutate().messages(processedMessages).build())
+			.build();
+
+		if (this.advisorType == AdvisorType.AFTER) {
+			return processedChatClientRequest;
+		}
+
+		// 4. Add the new user message to the conversation memory.
+		UserMessage userMessage = processedChatClientRequest.prompt().getUserMessage();
+
+		// 5. The user's question needs to be re-placed here because the default message
+		// body contains template information,
+		// which can be misleading when displayed on the front end.
+		// Re-placement of the user's actual question does not affect the model's ability
+		// to process new requests after loading memory and can also reduce token
+		// consumption in the model.
+		UserMessage customMessage = UserMessage.builder()
+			.text(userRequest)
+			.media(userMessage.getMedia())
+			.metadata(userMessage.getMetadata())
+			.build();
+		this.chatMemory.add(conversationId, customMessage);
+
+		return processedChatClientRequest;
+	}
+
+	@Override
+	public ChatClientResponse after(ChatClientResponse chatClientResponse, AdvisorChain advisorChain) {
+		if (this.advisorType == AdvisorType.BEFORE) {
+			return chatClientResponse;
+		}
+		List<Message> assistantMessages = new ArrayList<>();
+		if (chatClientResponse.chatResponse() != null) {
+			assistantMessages = chatClientResponse.chatResponse()
+				.getResults()
+				.stream()
+				.map(g -> (Message) g.getOutput())
+				.toList();
+		}
+		this.chatMemory.add(this.getConversationId(chatClientResponse.context(), this.defaultConversationId),
+				assistantMessages);
+		return chatClientResponse;
+	}
+
+	@Override
+	public Flux<ChatClientResponse> adviseStream(ChatClientRequest chatClientRequest,
+			StreamAdvisorChain streamAdvisorChain) {
+		// Get the scheduler from BaseAdvisor
+		Scheduler scheduler = this.getScheduler();
+
+		// Process the request with the before method
+		return Mono.just(chatClientRequest)
+			.publishOn(scheduler)
+			.map(request -> this.before(request, streamAdvisorChain))
+			.flatMapMany(streamAdvisorChain::nextStream)
+			.transform(flux -> new ChatClientMessageAggregator().aggregateChatClientResponse(flux,
+					response -> this.after(response, streamAdvisorChain)));
+	}
+
+	public static CustomMessageChatMemoryAdvisor.Builder builder(ChatMemory chatMemory, String userRequest,
+			AdvisorType advisorType) {
+		return new CustomMessageChatMemoryAdvisor.Builder(chatMemory, userRequest, advisorType);
+	}
+
+	public static final class Builder {
+
+		private String conversationId = ChatMemory.DEFAULT_CONVERSATION_ID;
+
+		private int order = Advisor.DEFAULT_CHAT_MEMORY_PRECEDENCE_ORDER;
+
+		private Scheduler scheduler = BaseAdvisor.DEFAULT_SCHEDULER;
+
+		private ChatMemory chatMemory;
+
+		private String userRequest;
+
+		private AdvisorType advisorType;
+
+		private Builder(ChatMemory chatMemory, String userRequest, AdvisorType advisorType) {
+			this.chatMemory = chatMemory;
+			this.userRequest = userRequest;
+			this.advisorType = advisorType;
+		}
+
+		/**
+		 * Set the conversation id.
+		 * @param conversationId the conversation id
+		 * @return the builder
+		 */
+		public CustomMessageChatMemoryAdvisor.Builder conversationId(String conversationId) {
+			this.conversationId = conversationId;
+			return this;
+		}
+
+		/**
+		 * Set the order.
+		 * @param order the order
+		 * @return the builder
+		 */
+		public CustomMessageChatMemoryAdvisor.Builder order(int order) {
+			this.order = order;
+			return this;
+		}
+
+		public CustomMessageChatMemoryAdvisor.Builder scheduler(Scheduler scheduler) {
+			this.scheduler = scheduler;
+			return this;
+		}
+
+		/**
+		 * Build the advisor.
+		 * @return the advisor
+		 */
+		public CustomMessageChatMemoryAdvisor build() {
+			return new CustomMessageChatMemoryAdvisor(this.chatMemory, this.conversationId, this.order, this.scheduler,
+					this.userRequest, this.advisorType);
+		}
+
+	}
+
+	public enum AdvisorType {
+
+		BEFORE, AFTER, ALL
+
+	}
+
+}

src/main/java/com/alibaba/cloud/ai/example/manus/dynamic/memory/controller/MemoryController.java

@@ -0,0 +1,60 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.cloud.ai.example.manus.dynamic.memory.controller;
+
+import com.alibaba.cloud.ai.example.manus.dynamic.memory.entity.MemoryEntity;
+import com.alibaba.cloud.ai.example.manus.dynamic.memory.service.MemoryService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @author dahua
+ * @time 2025/8/5
+ * @desc memory controller
+ */
+@RestController
+@RequestMapping("/api/memories")
+@CrossOrigin(origins = "*") // Add cross-origin support
+public class MemoryController {
+
+	@Autowired
+	private MemoryService memoryService;
+
+	@GetMapping
+	public ResponseEntity<List<MemoryEntity>> getAllModels() {
+		return ResponseEntity.ok(memoryService.getMemories());
+	}
+
+	@GetMapping("/single")
+	public ResponseEntity<MemoryEntity> singleMemory(String memoryId) {
+		return ResponseEntity.ok(memoryService.singleMemory(memoryId));
+	}
+
+	@PostMapping("/update")
+	public ResponseEntity<MemoryEntity> updateMemory(@RequestBody MemoryEntity memoryEntity) {
+		return ResponseEntity.ok(memoryService.updateMemory(memoryEntity));
+	}
+
+	@GetMapping("/delete")
+	public ResponseEntity<Void> deleteMemory(String memoryId) {
+		memoryService.deleteMemory(memoryId);
+		return ResponseEntity.ok().build();
+	}
+
+}