SpringBoot集成MCP实现SSE实时通信功能
上周五，运营同事发来一句：“这个系统不能让我直接说句话就创建采购单吗？GPT 都能聊天了，你这么死板？”
好家伙，我一个智能生产管理系统 SPMS（Smart Production Management System），确实就是少了点“嘴和耳朵”嘛。
也正巧前段时间 MCP（Model Context Protocol）在圈里火了起来。它主打的就是让系统像 GPT 一样和用户自然对话，我们当然不能落后。
于是，我撸起袖子，决定给 SPMS 搭个「MCP 协议」的接口，还要支持 SSE 模式 —— 让系统开口说话、接住请求、智能响应！
01
传统系统没“嘴” 和****“耳朵”********
传统的后台系统，通常是 REST API + 前端页面 + 手动操作：
请求得写死流程；
交互不能说话；
智能化完全靠拼接流程图。
现在，AI 能力接进系统就像长了嘴和耳朵。但是：
怎么接住用户的问题？
怎么从系统里调用逻辑？
怎么把结果发回去？
尤其是我们要用 SSE/HTTP 模式的 MCP，不是大家熟悉的 stdio 模式，就更得好好设计一套交互体系。
02
怎么理解 SSE 模式？
MCP 协议，全称是 Model Context Protocol，简单说，它定义了一个 AI 和系统交互的标准。
我们这次采用的是 MCP 的 SSE（Server-Sent Events）/HTTP 模式，它和我们熟悉的 REST API 很不一样。
可以理解为：
| 类比 | 功能 | 解释 |
|---|---|---|
| 耳朵 | HTTP 接收端口 | 系统听见了用户的请求 |
| 嘴巴 | SSE 推送端口 | 系统开口回答用户 |
| 中枢大脑 | MCP 工具注册与调用 | 系统知道怎么做事 |
| SSE 模式最核心的点是——服务端主动推送消息给客户端，而不是等客户端轮询。 |
03
支持 SSE 的 SpringBoot 服务端架构
我们用 SpringBoot 搭了一个完整的 SSE 服务端，结构如下：
┌──────────────┐
│ MCP 客户端 │
└────┬────┬────┘
│ │
SSE连接 HTTP请求
│ │
┌────▼────┴────┐
│ MCP 控制器 │ ← 拦截器做权限校验
├──────────────┤
│ /sse/stream ← 建立 SSE 连接
│ /mcp/receive ← 接收 POST 请求
└────┬─────────┘
│
┌────▼──────┐
│ McpService │ ← 扫描方法 + 执行 + 推送
└───────────┘
SSE 端点
我们使用 /sse/stream 建立连接：
@GetMapping("/sse/stream")
public SseEmitter connect(@RequestParam String token) {
return sseManager.createEmitter(token);
}
HTTP 接收端
收到 MCP 客户端请求，进行工具调用：
@PostMapping("/mcp/receive")
public void handle(@RequestBody McpRequest req) {
mcpService.invoke(req.getToken(), req.getMethod(), req.getParams());
}
身份校验和权限控制
我们设计了一个 AccessToken -> 用户权限 的映射：
Map<String, Set<String>> tokenToTools = new ConcurrentHashMap<>();
tokenToTools.put("u123-token", Set.of("createOrder", "checkInventory"));
当客户端试图调用一个未授权的方法时，返回：
Error: You are not allowed to use tool 'createPurchaseOrder'
每个 token 拥有哪些 MCP 工具，是在服务初始化时通过注解扫描注册的。
04
扫描 MCP 工具 + 执行调用 + SSE 推送
工具注册
我们定义了一个 @McpMethod 注解：
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface McpMethod {
String name(); // 工具名
String desc(); // 工具描述
}
扫描工具的方法：
@PostConstruct
public void scanMcpMethods() {
// 反射扫描标注了 @McpMethod 的方法并注册
}
工具调用
根据 methodName 找到对应工具，再反射执行：
public Object invoke(String token, String method, Map<String, Object> params) {
if (!hasPermission(token, method)) {
throw new UnauthorizedException();
}
Method tool = toolRegistry.get(method);
Object result = tool.invoke(...);
sseManager.pushToClient(token, result);
return result;
}
SSE 推送消息
我们封装了一个 SseManager 工具类，用来管理连接与推送：
public void pushToClient(String token, Object msg) {
SseEmitter emitter = emitterMap.get(token);
emitter.send(SseEmitter.event().data(msg));
}
客户端接入（以 CherryStudio 为例）
配置 MCP 服务端地址与 AccessToken 即可：
进入 CherryStudio 的 MCP 工具配置面板：
输入服务端地址，格式如下：
http://your-server-host/mcp/sse/stream
注意 /sse/stream 是 MCP 的 Server-Sent Events 推流接口，必须开放访问。
获取 AccessToken：
token 是系统中分配的 AccessToken。
验证是否连接成功：
成功连接后，你将在 CherryStudio 的 MCP 工具栏中看到你定义的服务名称。
点击工具即可开始自然语言交互。
最后
到此这篇关于SpringBoot集成MCP实现SSE实时通信功能的文章就介绍到这了,更多相关SpringBoot MCP实现SSE通信内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Java应用服务器之tomcat部署,本文通过实例图文相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-07-07
在开发手机程序时，总是希望压缩网络传输的信息，以减少流量。本文仅以哈夫曼编码为引导，抛砖引玉，实现压缩功能2013-08-08
利用Springboot+Caffeine实现本地缓存实例代码
Caffeine是一个基于Java8开发的提供了近乎最佳命中率的高性能的缓存库,下面这篇文章主要给大家介绍了关于利用Springboot+Caffeine实现本地缓存的相关资料,需要的朋友可以参考下2023-01-01
SpringMVC中利用@InitBinder来对页面数据进行解析绑定的方法
本篇文章主要介绍了SpringMVC中利用@InitBinder来对页面数据进行解析绑定的方法，非常具有实用价值，需要的朋友可以参考下2018-03-03
java web项目里ehcache.xml介绍，需要的朋友可以参考一下2013-03-03
MyBatis在处理对象关系映射时,多对一关系是常见的场景,本文就来介绍了MyBatis高级映射及延迟加载的实现,感兴趣的可以了解一下2024-11-11
这篇文章主要为大家详细介绍了java泛型类定义与使用的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能给你带来帮助2021-07-07
Java注解是从Java5开始添加到Java的,这篇文章主要给大家介绍了关于Java如何获取属性的注释信息的相关资料,文中介绍的非常详细,需要的朋友可以参考下2021-07-07
Spring Boot 快速使用 HikariCP 连接池配置详解
Spring Boot 2.x 将其作为默认的连接池组件，项目中添加 spring-boot-starter-jdbc 或 spring-boot-starter-data-jpa 模块后，HikariCP 依赖会被自动引入，这篇文章主要介绍了Spring Boot使用HikariCP连接池配置详解,需要的朋友可以参考下2023-06-06
这篇文章主要介绍了Springboot常用注解及作用说明,Springboot开发中注解是非常重要的不可或缺的,那么Springboot中有哪些常用的注解呢,今天我们就来看一下这些注解和其作用,需要的朋友可以参考下2023-08-08
最新评论