快捷導(dǎo)航

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

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

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

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

03

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

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

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

SSE 端點(diǎn)

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

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

HTTP 接收端

收到 MCP 客戶(hù)端請(qǐng)求，進(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)限控制

我們?cè)O(shè)計(jì)了一個(gè) AccessToken -> 用戶(hù)權(quán)限的映射：

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

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

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

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

04

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

工具注冊(cè)

我們定義了一個(gè) @McpMethod 注解：

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

掃描工具的方法：

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

工具調(diào)用

根據(jù) methodName 找到對(duì)應(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 推送消息

我們封裝了一個(gè) SseManager 工具類(lèi)，用來(lái)管理連接與推送：

public void pushToClient(String token, Object msg) {
    SseEmitter emitter = emitterMap.get(token);
    emitter.send(SseEmitter.event().data(msg));
}

客戶(hù)端接入（以 CherryStudio 為例）

配置 MCP 服務(wù)端地址與 AccessToken 即可：

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

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

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

注意 /sse/stream 是 MCP 的 Server-Sent Events 推流接口，必須開(kāi)放訪問(wèn)。

獲取 AccessToken：

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

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

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

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

最后

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

您可能感興趣的文章: