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

news2025/7/9 20:42:31

文章目录

  • 前言
  • 一、正文
    • 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 {

    @Autowired
    private ToolCallbackProvider toolCallbackProvider;

    /**
     * 配置ChatClient,注册系统指令和工具函数
     */
    @Bean
    public 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<>();


    @PostConstruct
    private 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 {

    @Autowired
    private GenerateCodeService generateCodeService;
    @Autowired
    private TableService tableService;
    @Autowired
    private ColumnService columnService;

    @Bean
    public 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 {


    @Resource
    private ChatClient chatClient;


    @GetMapping(value = "/generateCode", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    @SneakyThrows
    public 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 {

    @Resource
    private 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 {

    @Resource
    private 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 {

    @Resource
    private 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: 8081
  tomcat:
    uri-encoding: UTF-8
    keep-alive-timeout: 30000
    max-connections: 100
  servlet:
    encoding:
      charset: UTF-8
      force: true
      enabled: true
  compression:
    enabled: false # 禁用压缩(否则流式数据可能被缓冲)

spring:
  main:
    allow-bean-definition-overriding: true
  application:
    name: mcp-server

  datasource:
    url: jdbc:mysql://localhost:3306/test1?useSSL=false&serverTimezone=UTC
    username: eqq
    password: 111
    driver-class-name: com.mysql.cj.jdbc.Driver
  ai:
    mcp:
      server:
        stdio: false
        enabled: true
        name: mcp-server # MCP服务器名称
        type: ASYNC
        version: 1.0.0   # 服务器版本号
    # 配置阿里的密钥,模型
    dashscope:
      api-key: sk-ba8xxx你自己的key
      chat:
        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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2373006.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

实现滑动选择器从离散型的数组中选择

1.使用原生的input 详细代码如下&#xff1a; <template><div class"slider-container"><!-- 滑动条 --><inputtype"range"v-model.number"sliderIndex":min"0":max"customValues.length - 1"step&qu…

基于Credit的流量控制

流量控制(Flow Control)&#xff0c;也叫流控&#xff0c;它是控制组件之间发送和接收信息的过程。在总线中&#xff0c;流控的基本单位称为flit。 在标准同步接口中(比如AXI协议接口)&#xff0c;握手信号如果直接采用寄存器打拍的方式容易导致信号在不同的方向上出现偏离。因…

【金仓数据库征文】金仓数据库KingbaseES: 技术优势与实践指南(包含安装)

目录 前言 引言 一 : 关于KingbaseES,他有那些优势呢? 核心特性 典型应用场景 政务信息化 金融核心系统&#xff1a; 能源通信行业&#xff1a; 企业级信息系统&#xff1a; 二: 下载安装KingbaseES 三:目录一览表: 四:常用SQL语句 创建表&#xff1a; 修改表结构…

金丝猴食品:智能中枢AI-COP构建全链路数智化运营体系

“金丝猴奶糖”&#xff0c;这个曾藏在无数人童年口袋里的甜蜜符号&#xff0c;如今正经历一场数智焕新。当传统糖果遇上数字浪潮&#xff0c;这家承载着几代人味蕾记忆的企业&#xff0c;选择以数智化协同运营平台为“新配方”&#xff0c;将童年味道酿成智慧管理的醇香——让…

java的输入输出模板(ACM模式)

文章目录 1、前置准备2、普通输入输出API①、输入API②、输出API 3、快速输入输出API①、BufferedReader②、BufferedWriter 案例题目描述代码 面试有时候要acm模式&#xff0c;刷惯leetcode可能会手生不会acm模式&#xff0c;该文直接通过几个题来熟悉java的输入输出模板&…

鸿蒙 所有API缩略图鉴

从HarmonyOS NEXT Developer Preview1&#xff08;API 11&#xff09;版本开始&#xff0c;HarmonyOS SDK以 Kit 维度提供丰富、完备的开放能力&#xff0c;涵盖应用框架、应用服务、系统、媒体、AI、图形在内的六大领域&#xff0c;共计30000个API

【Docker系列】使用格式化输出与排序技巧

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

基础语法(二)

Mysql基础语法&#xff08;二&#xff09; Mysql基础语法&#xff08;二&#xff09;主要介绍Mysql中稍微进阶一点的内容&#xff0c;会稍微有一些难度&#xff08;博主个人认为&#xff09;。学习完基础语法&#xff08;一&#xff09;和基础语法&#xff08;二&#xff09;之…

TOA的定位,建模与解算的步骤、公式推导

TOA(到达时间)定位的核心是通过测量信号从目标到多个基站的传播时间,将其转换为距离信息,并利用几何关系解算目标位置。本文给出具体的建模与解算步骤及公式推导 文章目录 通用模型建立非线性方程组构建线性化处理(最小二乘法)最大似然估计(ML)高斯-牛顿迭代法误差分析…

2025年PMP 学习七 -第5章 项目范围管理 (5.4,5.5,5.6 )

2025年PMP 学习七 -第5章 项目范围管理 5.4 创建 WBS 1.定义与作用 定义把项目可交付成果和项目工作分解成较小的&#xff0c;更易于管理的组件作用对所要交付的内容提供一个结构化的视图 2.输入&#xff0c;输出&#xff0c;工具与技术 3. 创建WBS的依据&#xff08;输入&…

CAD属性图框值与Excel联动(CAD块属性导出Excel、excel更新CAD块属性)——CAD c#二次开发

CAD插件实现块属性值与excel的互动&#xff0c;效果如下&#xff1a; 加载dll插件&#xff08;CAD 命令行输入netload &#xff0c;运行xx即可导出Excel&#xff0c;运行xx1即可根据excel更新dwg块属性值。&#xff09; 部分代码如下 // 4. 开启事务更新CAD数据using (Transact…

【HarmonyOS 5】鸿蒙中进度条的使用详解

【HarmonyOS 5】鸿蒙中进度条的使用详解 一、HarmonyOS中Progress进度条的类型 HarmonyOS的ArkUI框架为开发者提供了多种类型的进度条&#xff0c;每种类型都有其独特的样式&#xff0c;以满足不同的设计需求。以下是几种常见的进度条类型&#xff1a; 线性进度条&#xff08;…

Spring Cloud: Nacos

Nacos Nacos是阿里巴巴开源的一个服务发现&#xff0c;配置管理和服务管理平台。只要用于分布式系统中的微服务注册&#xff0c;发现和配置管理&#xff0c;nacos是一个注册中心的组件 官方仓库&#xff1a;https://nacos.io/ Nacos的下载 Releases alibaba/nacos 在官网中…

Win11安装APK方法详解

1、官方win11系统 预览版 开发版 正式版 都行 2、同时你还需要开启主板 BIOS 虚拟化选项&#xff08;具体名称不同主板略有不同&#xff09; 这一步自行百度 开始&#xff1a;先去确定有没有开启虚拟化 任务管理器检查—— 虚拟化是否已经开启&#xff0c;如果没有自己去BIO…

SSH终端登录与网络共享

SSH 是较可靠&#xff0c;专为远程登录会话和其他网络服务提供安全性的协议 注意 SSH终端登录的前提是&#xff1a;电脑和板卡都能够通过网络相连接及通信 与连接互联网不一样&#xff0c;SSH可以不用互联网&#xff0c;只要电脑和板卡组成一个小型网络即可 网络方案 如果您…

Android 13 默认打开 使用屏幕键盘

原生设置里&#xff0c;系统-语言和输入法-实体键盘-使用屏幕键盘 选项&#xff0c; 关闭时&#xff0c;外接物理键盘&#xff0c;如USB键盘&#xff0c;输入时不会弹出软键盘。 打开时&#xff0c;外接物理键盘&#xff0c;如USB键盘&#xff0c;输入时会弹出软键盘。 这个选…

操作系统学习笔记第2章 (竟成)

第 2 章 进程管理 【考纲内容】 1.进程与线程&#xff1a; (1) 进程 / 线程的基本概念&#xff1b; (2) 进程 / 线程的状态与转换&#xff1b; (3) 线程的实现&#xff1a;内核支持的线程&#xff1b;线程库支持的线程&#xff1b; (4) 进程与线程的组织与控制&#xff1b; (5)…

复合机器人案例启示:富唯智能如何以模块化创新引领工业自动化新标杆

在国产工业机器人加速突围的浪潮中&#xff0c;富唯智能复合机器人案例凭借其高精度焊接与智能控制技术&#xff0c;成为行业标杆。然而&#xff0c;随着制造业对柔性化、全场景协作需求的升级&#xff0c;复合机器人正从单一功能向多模态协同进化。作为这一领域的创新者&#…

Linux在web下http加密和配置虚拟主机及动态页面发布

web服务器的数据加密 1.简介&#xff1a;由于http协议以明文方式发送&#xff0c;不提供任何方式的数据加密&#xff0c;也不适合传输一些重要的信息&#xff0c;如银行卡号、密码等&#xff0c;解决该缺陷设计了安全套接字层超文本传输协议https&#xff1b; 2.https的握手流…

C++ learning day 02

目录 引言 编译定义&#xff1a; 查看obj文件 1. 禁用预处理 2. CTRL F7 编译math.cpp 3. 查看obj文件 4. 查看.asm文件&#xff08;汇编程序&#xff09; 引言 今天介绍C中&#xff0c;一个Cpp文件经过汇编后得到obj文件&#xff0c;以及obj文件的内容&a…