当前位置: 首页 > news >正文

SpringBoot中使用MCP和通义千问来处理和分析数据-连接本地数据库并生成实体类

文章目录

  • 前言
  • 一、正文
    • 1.1 项目结构
    • 1.2 项目环境
    • 1.3 完整代码
      • 1.3.1 spring-mcp-demo的pom文件
      • 1.3.2 generate-code-server的pom文件
      • 1.3.3 ChatClientConfig
      • 1.3.4 FileTemplateConfig
      • 1.3.5 ServiceProviderConfig
      • 1.3.6 GenerateCodeController
      • 1.3.7 Columns
      • 1.3.8 Tables
      • 1.3.9 FileTemplateEnum
      • 1.3.10 InformationSchemaManager
      • 1.3.11 ColumnService
      • 1.3.12 ColumnServiceImpl
      • 1.3.13 GenerateCodeService
      • 1.3.14 GenerateCodeServiceImpl
      • 1.3.15 TableService
      • 1.3.16 TableServiceImpl
      • 1.3.17 GenerateCodeServerApplication
    • 1.4 完整配置
      • 1.4.1 entityTemplate.txt
      • 1.4.2 enumTemplate.txt
      • 1.4.3 application.yml
    • 1.5 页面示例
      • 1.5.1 页面展示
      • 1.5.2 index.html
  • 二、附录
    • 2.1 一些可能实现的功能推荐
    • 2.2 Srping-AI MCP的官方文档
    • 2.3 阿里百炼MCP服务

前言

最近在研究学习 SpringBoot 和 MCP + 通义千问的实际使用。
本篇文章主要是连接数据库,查表信息和字段信息,然后根据这些信息做一些操作,比如生成实体类,枚举等。

项目技术栈和同系列文章【SpringBoot中使用MCP和通义千问来处理和分析数据-入门,查寻和基本的分析】类似。

本篇的主要特点是使用了 webflux 的 starter,在控制器层采取流式输出,并做了一个简单的页面来展示结果。(主要原因是同步的方式会经常超时)

一、正文

1.1 项目结构

整体项目采取两部分,父模块和子模块,父级主要控制依赖版本。子级模块用于功能的实现。
在这里插入图片描述

1.2 项目环境

本次实践会真实连接mysql进行一些操作。使用了最简单的jdbc。
另外配置了代码示例,生成代码时会参考示例中的代码。

1.3 完整代码

1.3.1 spring-mcp-demo的pom文件

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.mcp</groupId><artifactId>spring-mcp-demo</artifactId><version>1.0-SNAPSHOT</version><packaging>pom</packaging><name>spring-mcp-demo</name><modules><module>generate-code-server</module></modules><properties><java.version>21</java.version><spring-boot.version>3.4.2</spring-boot.version><spring-ai.version>1.0.0-M6</spring-ai.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding></properties><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><repository><id>maven2</id><name>maven2</name><url>https://repo1.maven.org/maven2/</url><snapshots><enabled>false</enabled></snapshots></repository><repository><name>Central Portal Snapshots</name><id>central-portal-snapshots</id><url>https://central.sonatype.com/repository/maven-snapshots/</url><releases><enabled>false</enabled></releases><snapshots><enabled>true</enabled></snapshots></repository></repositories><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><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-starter</artifactId><version>${spring-ai.version}.1</version></dependency></dependencies></dependencyManagement></project>

1.3.2 generate-code-server的pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><groupId>org.mcp</groupId><artifactId>spring-mcp-demo</artifactId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>generate-code-server</artifactId><version>0.0.1-SNAPSHOT</version><name>generate-code-server</name><dependencies><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.34</version><optional>true</optional></dependency><!--  webflux的starter --><dependency><groupId>org.springframework.ai</groupId><artifactId>spring-ai-mcp-server-webflux-spring-boot-starter</artifactId></dependency><!-- 阿里ai的starter --><dependency><groupId>com.alibaba.cloud.ai</groupId><artifactId>spring-ai-alibaba-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jdbc</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version><scope>runtime</scope></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.8.1</version><inherited>true</inherited><configuration><source>${java.version}</source><target>${java.version}</target><parameters>true</parameters><showWarnings>true</showWarnings></configuration></plugin><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>${spring-boot.version}</version><configuration><mainClass>org.mcp.GenerateCodeServerApplication</mainClass><skip>true</skip></configuration><executions><execution><id>repackage</id><goals><goal>repackage</goal></goals></execution></executions></plugin></plugins></build></project>

1.3.3 ChatClientConfig

package org.mcp.config;import org.springframework.ai.chat.client.ChatClient;
import org.springframework.ai.chat.client.advisor.MessageChatMemoryAdvisor;
import org.springframework.ai.chat.memory.InMemoryChatMemory;
import org.springframework.ai.tool.ToolCallbackProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 聊天对话配置*/
@Configuration
public class ChatClientConfig {@Autowiredprivate ToolCallbackProvider toolCallbackProvider;/*** 配置ChatClient,注册系统指令和工具函数*/@Beanpublic ChatClient chatClient(ChatClient.Builder builder) {InMemoryChatMemory inMemoryChatMemory = new InMemoryChatMemory();return builder.defaultSystem("你是一个代码生成助手,可以根据读取配置信息,以及关键词、字段名等生成同样格式的Java代码。" +"你可以根据用户给的提示词,来指定对应的类名,文档注释等信息。注意,所有类或枚举都需要文档注释,所有public或比较关键的方法也都需要文档注释,特殊算法的代码上需要行注释。"+"生成枚举时,根据用户给的提示信息,使用英文单词作为枚举变量名,并按指定的枚举代码示例来生成类似的枚举类。" +"在生成代码时,你可以查数据库的表信息,包括并不限于表字段,备注,字段类型等。" +"生成代码时使用java1.8版本。并且生成实体的日期类型数据,采用java.util.Date类。" +"回复时,请使用简洁友好的语言。代码中不需要转义符,需要能直接粘贴来用的格式。")// 注册工具方法.defaultTools(toolCallbackProvider)// 支持多轮对话.defaultAdvisors(new MessageChatMemoryAdvisor(inMemoryChatMemory)).build();}
}

1.3.4 FileTemplateConfig

package org.mcp.config;import jakarta.annotation.PostConstruct;
import org.mcp.enums.FileTemplateEnum;
import org.springframework.context.annotation.Configuration;import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;/*** 文件模版配置** @author mcp* @version 1.0* @since 2025-05-07 10:34*/
@Configuration
public class FileTemplateConfig {private static final Map<FileTemplateEnum, String> TEMPLATE_CONTENT_MAP = new HashMap<>();@PostConstructprivate void init() throws IOException {ClassLoader classLoader = FileTemplateConfig.class.getClassLoader();for (FileTemplateEnum fileTemplateEnum : FileTemplateEnum.values()) {InputStream resourceAsStream = classLoader.getResourceAsStream("code-templates/" + fileTemplateEnum.getTemplateName());assert resourceAsStream != null;String content = new String(resourceAsStream.readAllBytes());TEMPLATE_CONTENT_MAP.put(fileTemplateEnum, content);}}public static String getTemplateContent(FileTemplateEnum fileTemplateEnum) {return TEMPLATE_CONTENT_MAP.get(fileTemplateEnum);}
}

1.3.5 ServiceProviderConfig

package org.mcp.config;import org.mcp.service.ColumnService;
import org.mcp.service.GenerateCodeService;
import org.mcp.service.TableService;
import org.springframework.ai.tool.ToolCallbackProvider;
import org.springframework.ai.tool.method.MethodToolCallbackProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 服务提供者配置*/
@Configuration
public class ServiceProviderConfig {@Autowiredprivate GenerateCodeService generateCodeService;@Autowiredprivate TableService tableService;@Autowiredprivate ColumnService columnService;@Beanpublic ToolCallbackProvider serverTools() {return MethodToolCallbackProvider.builder()// 可以注册多个服务.toolObjects(generateCodeService, tableService, columnService).build();}
}

1.3.6 GenerateCodeController

package org.mcp.controller;import jakarta.annotation.Resource;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.ai.chat.client.ChatClient;
import org.springframework.ai.chat.client.advisor.AbstractChatMemoryAdvisor;
import org.springframework.http.MediaType;
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.RequestParam;
import reactor.core.publisher.Flux;/*** 代码生成控制器** @author mcp* @version 1.0* @since 2025-05-07 10:21*/
@Controller
@Slf4j
@RequestMapping("/api/chat")
public class GenerateCodeController {@Resourceprivate ChatClient chatClient;@GetMapping(value = "/generateCode", produces = MediaType.TEXT_EVENT_STREAM_VALUE)@SneakyThrowspublic Flux<String> generateCode(@RequestParam("conversationId") String conversationId, @RequestParam("message") String message) {log.info("GenerateCodeController.generateCode(), conversationId:{},message:{}", conversationId, message);return chatClient.prompt().advisors(spec -> spec.param(AbstractChatMemoryAdvisor.CHAT_MEMORY_CONVERSATION_ID_KEY, conversationId).param(AbstractChatMemoryAdvisor.CHAT_MEMORY_RETRIEVE_SIZE_KEY, 50)).user(message).stream().content();}
}

1.3.7 Columns

package org.mcp.entity;import lombok.Data;/*** 列信息** @author mcp* @version 1.0* @since 2025-05-07 14:07*/
@Data
public class Columns {/*** 列名*/private String columnName;/*** 数据类型*/private String dataType;/*** 列备注*/private String columnComment;
}

1.3.8 Tables

package org.mcp.entity;import lombok.Data;/*** 表信息** @author mcp* @version 1.0* @since 2025-05-07 13:54*/
@Data
public class Tables {/*** 表名*/private String tableName;/*** 表注释*/private String tableComment;
}

1.3.9 FileTemplateEnum

package org.mcp.enums;import lombok.AllArgsConstructor;
import lombok.Getter;/*** 文件模版名枚举** @author mcp* @version 1.0* @since 2025-05-07 10:41*/
@Getter
@AllArgsConstructor
public enum FileTemplateEnum {ENTITY_TEMPLATE("entityTemplate.txt"),ENUM_TEMPLATE("enumTemplate.txt");private final String templateName;
}

1.3.10 InformationSchemaManager

package org.mcp.manager;import jakarta.annotation.Resource;
import org.mcp.entity.Columns;
import org.mcp.entity.Tables;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;import java.util.List;
import java.util.Map;/*** 数据库信息结构管理器** @author mcp* @version 1.0* @since 2025-05-07 11:27*/
@Component
public class InformationSchemaManager {@Resourceprivate JdbcTemplate jdbcTemplate;/*** 查找所有可用的的表名*/public List<Tables> findAllTableNames(String tableSchema) {String sql = "SELECT TABLE_NAME,TABLE_COMMENT FROM information_schema.TABLES WHERE TABLE_SCHEMA = ?";return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Tables.class), tableSchema);}/*** 查找所有可用的列名*/public List<Columns> findAllColumns(String tableSchema, String tableName) {String sql = "SELECT COLUMN_NAME,DATA_TYPE,COLUMN_COMMENT FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = ? AND TABLE_NAME = ?";return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Columns.class), tableSchema, tableName);}}

1.3.11 ColumnService

package org.mcp.service;import org.mcp.entity.Columns;import java.util.List;/*** 列服务** @author mcp* @version 1.0* @since 2025-05-07 14:11*/
public interface ColumnService {List<Columns> findAllColumns(String tableSchema, String tableName);
}

1.3.12 ColumnServiceImpl

package org.mcp.service.impl;import jakarta.annotation.Resource;
import org.mcp.entity.Columns;
import org.mcp.manager.InformationSchemaManager;
import org.mcp.service.ColumnService;
import org.springframework.ai.tool.annotation.Tool;
import org.springframework.ai.tool.annotation.ToolParam;
import org.springframework.stereotype.Service;import java.util.List;/*** 列服务实现** @author 01434188* @version 1.0* @since 2025-05-07 14:11*/
@Service
public class ColumnServiceImpl implements ColumnService {@Resourceprivate InformationSchemaManager informationSchemaManager;@Override@Tool(name = "findAllColumns", description = "根据schema和表名,查询当前数据库下的对应数据库表字段信息,包含字段名,字段类型,字段备注。")public List<Columns> findAllColumns(@ToolParam(description = "表的schema,即数据库名") String tableSchema, @ToolParam(description = "表名") String tableName) {return informationSchemaManager.findAllColumns(tableSchema, tableName);}
}

1.3.13 GenerateCodeService

package org.mcp.service;/*** 代码生成服务** @author mcp* @version 1.0* @since 2025-05-07 10:18*/
public interface GenerateCodeService {/*** 获取枚举代码模板*/String getEnumCodeTemplate();/*** 获取实体代码模板*/String getEntityCodeTemplate();
}

1.3.14 GenerateCodeServiceImpl

package org.mcp.service.impl;import org.mcp.config.FileTemplateConfig;
import org.mcp.enums.FileTemplateEnum;
import org.mcp.service.GenerateCodeService;
import org.springframework.ai.tool.annotation.Tool;
import org.springframework.stereotype.Service;/*** 代码生成服务实现** @author mcp* @version 1.0* @since 2025-05-07 10:19*/
@Service
public class GenerateCodeServiceImpl implements GenerateCodeService {@Override@Tool(name = "getEnumCodeTemplate", description = "根据枚举名和描述、给定的java枚举类示例,生成java枚举类的代码了;例如枚举描述的格式是:单据状态:1=正常,2=已关闭,3=已作废,4=已冻结")public String getEnumCodeTemplate() {// 获取模版内容return FileTemplateConfig.getTemplateContent(FileTemplateEnum.ENUM_TEMPLATE);}@Override@Tool(name = "getEntityCodeTemplate", description = "根据实体名和描述、给定的java实体类示例,生成java实体类的代码,特别注意,实体如果有创建人,创建人ID,创建时间,修改人,修改人ID,修改时间,则需要继承EntityBase类。"+ "如果存在枚举属性,则同时需要根据描述生成对应的枚举")public String getEntityCodeTemplate() {// 获取模版内容return FileTemplateConfig.getTemplateContent(FileTemplateEnum.ENTITY_TEMPLATE);}
}

1.3.15 TableService

package org.mcp.service;import org.mcp.entity.Tables;import java.util.List;/*** 表服务** @author mcp* @version 1.0* @since 2025-05-07 14:01*/
public interface TableService {List<Tables> findAllTableNames(String tableSchema);
}

1.3.16 TableServiceImpl

package org.mcp.service.impl;import jakarta.annotation.Resource;
import org.mcp.entity.Tables;
import org.mcp.manager.InformationSchemaManager;
import org.mcp.service.TableService;
import org.springframework.ai.tool.annotation.Tool;
import org.springframework.ai.tool.annotation.ToolParam;
import org.springframework.stereotype.Service;import java.util.List;/*** 表服务实现** @author mcp* @version 1.0* @since 2025-05-07 14:01*/
@Service
public class TableServiceImpl implements TableService {@Resourceprivate InformationSchemaManager informationSchemaManager;@Override@Tool(name = "findAllTableNames", description = "根据schema或数据库名,查询当前数据库下的所有可用的表名和表备注")public List<Tables> findAllTableNames(@ToolParam(description = "表的schema,即数据库名") String tableSchema) {return informationSchemaManager.findAllTableNames(tableSchema);}
}

1.3.17 GenerateCodeServerApplication

package org.mcp;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.CrossOrigin;@SpringBootApplication
@CrossOrigin(origins = "*",allowedHeaders = "*",exposedHeaders = {"Cache-Control", "Connection"}  // 暴露必要头
)
public class GenerateCodeServerApplication {public static void main(String[] args) {SpringApplication.run(GenerateCodeServerApplication.class, args);}
}

1.4 完整配置

1.4.1 entityTemplate.txt

package org.pine.entity;import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.pine.api.enums.DeliveryStatusEnum;
import org.pine.api.enums.OrderStatusEnum;import java.util.Date;/*** 出库单** @author 01434188* @version 1.0* @since 2025-04-29 10:46*/
@EqualsAndHashCode(callSuper = true)
@Data
@Accessors(chain = true)
public class OutboundOrder extends EntityBase {/*** 主键id*/private Long id;/*** 出库单号*/private String outboundNo;/*** 出库通知单号*/private String outboundNoticeNo;/*** 出库通知明细流水号*/private String outboundNoticeDetailNo;/*** 出库作业号*/private String outboundTaskNo;/*** 出库作业明细号*/private String outboundTaskDetailNo;/*** 出库状态:1=未出库,3=全部出库*/private DeliveryStatusEnum deliveryStatus;/*** 单据状态:1=正常,2=已关闭,3=已作废,4=已冻结*/private OrderStatusEnum status;/*** 出库日期*/private Date outboundDate;/*** 物料名称*/private String materialName;/*** 物料代码*/private String materialCode;
}

1.4.2 enumTemplate.txt

package org.pine.api.enums;import lombok.AllArgsConstructor;
import lombok.Getter;import java.util.Arrays;
import java.util.Objects;/*** 单据状态枚举** @author mcp* @version 1.0* @since 2025-04-29 11:18*/
@AllArgsConstructor
@Getter
public enum OrderStatusEnum {// 单据状态:1=正常,2=已关闭,3=已作废,4=已冻结NORMAL(1, "正常"),CLOSED(2, "已关闭"),INVALID(3, "已作废"),FROZEN(4, "已冻结");private final Integer code;private final String message;public static OrderStatusEnum getInstance(Integer code) {if (Objects.isNull(code)) {return null;}return Arrays.stream(OrderStatusEnum.values()).filter(e -> Objects.equals(e.getCode(), code)).findFirst().orElse(null);}
}

1.4.3 application.yml

server:port: 8081tomcat:uri-encoding: UTF-8keep-alive-timeout: 30000max-connections: 100servlet:encoding:charset: UTF-8force: trueenabled: truecompression:enabled: false # 禁用压缩(否则流式数据可能被缓冲)spring:main:allow-bean-definition-overriding: trueapplication:name: mcp-serverdatasource:url: jdbc:mysql://localhost:3306/test1?useSSL=false&serverTimezone=UTCusername: eqqpassword: 111driver-class-name: com.mysql.cj.jdbc.Driverai:mcp:server:stdio: falseenabled: truename: mcp-server # MCP服务器名称type: ASYNCversion: 1.0.0   # 服务器版本号# 配置阿里的密钥,模型dashscope:api-key: sk-ba8xxx你自己的keychat:options:model: qwen-plus

1.5 页面示例

1.5.1 页面展示

启动springboot项目后,访问地址:http://localhost:8081/
在这里插入图片描述

第一个输入框中输入你的想法,例如,查看一下数据库表xxx.xxx的信息,并生成java实体类代码,涉及到枚举的话,也生成一下。第二个输入框是对话ID,同一个对话ID可以进行多轮对话。

得到的结果如下(页面没渲染markdown,也没做代码高亮):
在这里插入图片描述

1.5.2 index.html

<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title>流式 Markdown 展示</title><style>#output {border: 1px solid #ccc;padding: 15px;margin-top: 10px;min-height: 200px;white-space: pre-wrap;}</style>
</head><body>
<input type="text" id="promptInput" placeholder="输入提示..." style="width: 80%; padding: 10px;">
<input type="text" id="conversationIdInput" placeholder="输入conversationId..." style="width: 80%; padding: 10px;">
<button onclick="sendPrompt()">发送</button>
<button onclick="disconnectAiServer()">断开连接</button>
<h2>流式 Markdown 输出:</h2>
<div id="output"></div><div style="height: 100px">&nbsp;</div>
<script>let eventSource;function connectAiServer(url) {eventSource = new EventSource(url);}function disconnectAiServer() {if (eventSource) {eventSource.close()}autoCloseAlert("已经断开sse连接!", 1500);}const outputDiv = document.getElementById('output');function sendPrompt() {outputDiv.textContent = '';const prompt = document.getElementById('promptInput').value;const conversationId = document.getElementById('conversationIdInput').value;try {connectAiServer(`http://localhost:8081/api/chat/generateCode?conversationId=${encodeURIComponent(conversationId)}&message=${encodeURIComponent(prompt)}`);autoCloseAlert("已经建立sse连接!", 1500);eventSource.onmessage = function(event) {try {const content = event.data || '';outputDiv.textContent += (content);} catch (e) {console.error('解析失败:', e);disconnectAiServer();}};} catch (e) {outputDiv.textContent = '请求失败' + e.message;disconnectAiServer();}eventSource.onerror = function(err) {console.error("SSE 错误:", err);disconnectAiServer();};}function autoCloseAlert(message, duration = 2000) {const alertBox = document.createElement('div');alertBox.style.position = 'fixed';alertBox.style.top = '20px';alertBox.style.left = '50%';alertBox.style.transform = 'translateX(-50%)';alertBox.style.backgroundColor = '#ff4d4d';alertBox.style.color = '#fff';alertBox.style.padding = '10px 20px';alertBox.style.borderRadius = '5px';alertBox.style.zIndex = '9999';alertBox.innerText = message;document.body.appendChild(alertBox);setTimeout(() => {alertBox.remove();}, duration);}</script>
</body>
</html>

二、附录

2.1 一些可能实现的功能推荐

以下内容来自kimi。

Spring Boot + MCP 可实现的应用方向及示例:智能对话系统
应用场景:打造一个能与用户进行智能对话的系统,如客服机器人、聊天助手等,可集成到网页、移动应用等多渠道,为用户提供更便捷的服务。
实现要点:利用 Spring Boot 搭建基础服务架构,引入 MCP 相关依赖,例如 spring-ai-core、spring-ai-anthropic-spring-boot-starter 等,通过在服务方法上添加 @Tool 注解等配置,将业务逻辑与 AI 对话功能集成,实现对用户输入的智能理解和自动回复。智能代码助手
应用场景:为开发者提供代码编写建议、代码片段、技术文档等辅助信息,提高开发效率和代码质量。
实现要点:结合 Spring Boot 构建服务,借助 MCP 的能力,利用现有的代码库、技术文档等资源训练 AI 模型,使其理解代码逻辑和开发场景,为用户提供服务。私密知识库问答
应用场景:为个人或团队建立专属的知识库,用户可通过自然语言提问获取知识库中的信息,满足企业内部知识管理、个人学习笔记整理等需求。
实现要点:使用 Spring Boot + MCP 构建应用,将知识库的内容进行数据化处理,并利用 AI 模型进行语义理解和知识检索,实现精准的知识问答。智能数据分析助手
应用场景:帮助用户分析数据,如销售数据、财务数据、市场调研数据等,提供数据可视化、趋势预测等功能。
实现要点:在 Spring Boot 服务中集成数据分析库和工具,如 Apache POI 等,再通过 MCP 将其与 AI 功能整合,使用户能以对话的形式进行数据分析操作。智能内容创作助手
应用场景:辅助用户创作文本内容,如撰写文章、生成文案、创作故事等,为内容创作者提供灵感和便利。
实现要点:利用 Spring Boot 搭建平台,结合 MCP 调用 AI 文本生成模型,根据用户输入的主题、关键词等要求生成相应的内容。智能教育辅导
应用场景:针对教育领域,为学生提供个性化学习辅导、问题解答、作业批改等功能。
实现要点:收集整合教育资源,如教材、题库、知识点讲解等,构建教育知识图谱,通过 Spring Boot + MCP 为学生提供智能辅导服务。智能健康助手
应用场景:为用户提供必须的健康咨询、症状分析、健康建议等服务。
实现要点:整合医疗健康知识库和用户健康数据,利用 AI 模型进行症状分析和健康风险评估,通过 Spring Boot 构建应用并用 MCP 实现智能对话功能。智能旅行规划助手
应用场景:帮助用户规划旅行行程,包括目的地推荐、景点介绍、行程安排、酒店预订等。
实现要点:收集旅游数据,如景点信息、交通时刻表、酒店资源等,结合用户的偏好和需求,通过 Spring Boot + MCP 提供个性化的旅行规划建议。智能音乐推荐助手
应用场景:根据用户的音乐喜好和听歌历史,为其推荐符合口味的音乐、歌单等。
实现要点:分析用户的音乐数据,建立音乐推荐模型,利用 Spring Boot + MCP 为用户提供准确的音乐推荐服务。智能汽车助手
应用场景:为汽车用户提供一个智能助手,实现车辆信息查询、远程控制、驾驶辅助等功能,提升车主的驾驶体验。
实现要点:借助汽车的物联网技术获取车辆数据,通过 Spring Boot + MCP 构建智能助手应用,实现与车主的智能交互。

2.2 Srping-AI MCP的官方文档

https://docs.spring.io/spring-ai/reference/1.0/api/mcp/mcp-overview.html

2.3 阿里百炼MCP服务

mcp介绍:
https://help.aliyun.com/zh/model-studio/mcp-introduction

mcp服务:
https://bailian.console.aliyun.com/?spm=a2c4g.11186623.0.0.60907980b9Eirh&tab=mcp#/mcp-market

百炼说明文档:
https://help.aliyun.com/zh/model-studio/what-is-model-studio?spm=a2c4g.11174283.0.i0

相关文章:

  • 15前端项目----用户信息/导航守卫
  • SNMP 协议介绍、开发方法及示例
  • 【造包工具】【Xcap】精讲Xcap构造分片包(IPv4、ipv6、4G\5G等pcap均可),图解超赞超详细!!!
  • 投资逻辑与未来风险:高端PCB的黄金周期能持续多久?
  • 【Linux网络】网络命令
  • mongodb升级、改单节点模式
  • 矢量网络分析仪测驻波比:从原理到实战操作全解析
  • Nacos源码—6.Nacos升级gRPC分析一
  • 【redis】分片方案
  • 数据结构(二)——线性表的链式表示和实现
  • 关键字where
  • STM32智能刷卡消费系统(uC/OS-III)
  • LeetCode 11.盛最多水的容器 (Java)
  • CBO和HBO区别及介绍
  • 【软件测试学习day7】Junit5
  • 抛物线法(二次插值法)
  • C++卡特兰数讲解
  • 避免数据丢失:在存储测试数据之前,要做好Redis持久化
  • 牙科CBCT性能检测模体的革新价值
  • springmvc的入门案例
  • 陕西澄城樱桃在上海推介,向长三角消费者发出“甜蜜之邀”
  • 多人称华为手机忽现拍照模糊疑存缺陷,售后回应:主摄像头故障
  • 调节负面情绪可以缓解慢性疼痛
  • 黄晨光任中科院空间应用工程与技术中心党委书记、副主任
  • 公募基金改革八大要点:建立浮动管理费收取机制、降低规模排名考核权重
  • 上海营商环境的“分寸”感:底线之上不断拓宽自由,底线之下雷霆制止