快捷導(dǎo)航

SpringBoot集成MCP實(shí)現(xiàn)SSE實(shí)時通信功能

更新時間：2025年05月13日 10:23:24 作者：架構(gòu)師沉默

本文詳細(xì)介紹了如何在智能生產(chǎn)管理系統(tǒng)SPMS中集成MCP協(xié)議,并支持SSE模式,以實(shí)現(xiàn)系統(tǒng)與用戶的自然對話和智能響應(yīng),通過使用SpringBoot搭建SSE服務(wù)端,實(shí)現(xiàn)了服務(wù)端主動推送消息給客戶端的功能,需要的朋友可以參考下

類比	功能	解釋
耳朵	HTTP 接收端口	系統(tǒng)聽見了用戶的請求
嘴巴	SSE 推送端口	系統(tǒng)開口回答用戶
中樞大腦	MCP 工具注冊與調(diào)用	系統(tǒng)知道怎么做事
SSE 模式最核心的點(diǎn)是——服務(wù)端主動推送消息給客戶端，而不是等客戶端輪詢。

03

支持 SSE 的 SpringBoot 服務(wù)端架構(gòu)

我們用 SpringBoot 搭了一個完整的 SSE 服務(wù)端，結(jié)構(gòu)如下：

┌──────────────┐
│ MCP 客戶端   │
└────┬────┬────┘
     │    │
SSE連接 HTTP請求
     │    │
┌────▼────┴────┐
│ MCP 控制器   │ ← 攔截器做權(quán)限校驗(yàn)
├──────────────┤
│ /sse/stream   ← 建立 SSE 連接
│ /mcp/receive  ← 接收 POST 請求
└────┬─────────┘
     │
┌────▼──────┐
│ McpService │ ← 掃描方法 + 執(zhí)行 + 推送
└───────────┘

SSE 端點(diǎn)

我們使用 /sse/stream 建立連接：

@GetMapping("/sse/stream")
public SseEmitter connect(@RequestParam String token) {
    return sseManager.createEmitter(token);
}

HTTP 接收端

收到 MCP 客戶端請求，進(jìn)行工具調(diào)用：

@PostMapping("/mcp/receive")
public void handle(@RequestBody McpRequest req) {
    mcpService.invoke(req.getToken(), req.getMethod(), req.getParams());
}

身份校驗(yàn)和權(quán)限控制

我們設(shè)計了一個 AccessToken -> 用戶權(quán)限的映射：

Map<String, Set<String>> tokenToTools = new ConcurrentHashMap<>();
tokenToTools.put("u123-token", Set.of("createOrder", "checkInventory"));

當(dāng)客戶端試圖調(diào)用一個未授權(quán)的方法時，返回：

Error: You are not allowed to use tool 'createPurchaseOrder'

每個 token 擁有哪些 MCP 工具，是在服務(wù)初始化時通過注解掃描注冊的。

04

掃描 MCP 工具 + 執(zhí)行調(diào)用 + SSE 推送

工具注冊

我們定義了一個 @McpMethod 注解：

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface McpMethod {
    String name(); // 工具名
    String desc(); // 工具描述
}

掃描工具的方法：

@PostConstruct
public void scanMcpMethods() {
    // 反射掃描標(biāo)注了 @McpMethod 的方法并注冊
}

工具調(diào)用

根據(jù) methodName 找到對應(yīng)工具，再反射執(zhí)行：

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 服務(wù)端地址與 AccessToken 即可：

進(jìn)入 CherryStudio 的 MCP 工具配置面板：

輸入服務(wù)端地址，格式如下：

http://your-server-host/mcp/sse/stream

注意 /sse/stream 是 MCP 的 Server-Sent Events 推流接口，必須開放訪問。

獲取 AccessToken：

token 是系統(tǒng)中分配的 AccessToken。

驗(yàn)證是否連接成功：

成功連接后，你將在 CherryStudio 的 MCP 工具欄中看到你定義的服務(wù)名稱。

點(diǎn)擊工具即可開始自然語言交互。

最后

到此這篇關(guān)于SpringBoot集成MCP實(shí)現(xiàn)SSE實(shí)時通信功能的文章就介紹到這了,更多相關(guān)SpringBoot MCP實(shí)現(xiàn)SSE通信內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: