如何給自研 MCP 服務，加上安全認證？

作者：小傅哥 2025-05-27 01:10:00

Spring AI 是有意提供基于自家的 OAuth2 框架，完成 MCP 服務的多樣性權限校驗的。不過目前提供的方案能用，但不算成熟。

一、舉例，對接高德地圖 MCP

高德地圖 MCP Server；

{
  "mcpServers": {
    "amap-amap-sse": {
      "url": "https://mcp.amap.com/sse?key=您在高德官網上申請的key"
    }
  }
}

官網：https://lbs.amap.com/api/mcp-server/gettingstarted - 官網提供了創建對接 Key

1. 代碼使用示例

@Configuration
publicclass McpConfig {

    @Bean
    public List<NamedClientMcpTransport> mcpClientTransport() {
        McpClientTransport transport = HttpClientSseClientTransport
                .builder("https://mcp.amap.com")
                .sseEndpoint("/sse?key=<your_key>")
                .objectMapper(new ObjectMapper())
                .build();

        return Collections.singletonList(new NamedClientMcpTransport("amap", transport));
    }
    
}

對接時，需要設定 sseEndpoint 如果不設定個，Spring AI 默認是對 builder 的 baseUrl 值添加 /sse 的。
所以，如果你要對接外部帶有驗證權限的 MCP 服務，需要手動設置下 sseEndpoint 值。

2. 項目中的配置

小傅哥，帶著大家做的 Ai Agent，也支持了外部的這些帶有權限校驗的 MCP 服務。你可以，以多種方式進行配置。如；

{
 "baseUri":"https://mcp.amap.com",
        "sseEndpoint":"/sse?key=801aabf79ed0ff78603cfe85****"
}

{
 "baseUri":"https://mcp.amap.com",
        "sseEndpoint":"/sse?key=801aabf79ed0ff78603cfe85****"
}

以上兩種配置方式，在 ai-agent-station 都做了兼容處理。以下是兼容代碼，學習這部分項目的伙伴，可以直接閱讀課程代碼。

@Slf4j
@Component
publicclass AiClientToolMcpNode extends AbstractArmorySupport {

   // ... 省略部分代碼

    protected McpSyncClient createMcpSyncClient(AiClientToolMcpVO aiClientToolMcpVO) {
        String transportType = aiClientToolMcpVO.getTransportType();

        switch (transportType) {
            case"sse" -> {
                AiClientToolMcpVO.TransportConfigSse transportConfigSse = aiClientToolMcpVO.getTransportConfigSse();
                // http://127.0.0.1:9999/sse?apikey=DElk89iu8Ehhnbu
                String originalBaseUri = transportConfigSse.getBaseUri();
                String baseUri;
                String sseEndpoint;

                int queryParamStartIndex = originalBaseUri.indexOf("sse");
                if (queryParamStartIndex != -1) {
                    baseUri = originalBaseUri.substring(0, queryParamStartIndex - 1);
                    sseEndpoint = originalBaseUri.substring(queryParamStartIndex - 1);
                } else {
                    baseUri = originalBaseUri;
                    sseEndpoint = transportConfigSse.getSseEndpoint();
                }

                sseEndpoint = StringUtils.isBlank(sseEndpoint) ? "/sse" : sseEndpoint;

                HttpClientSseClientTransport sseClientTransport = HttpClientSseClientTransport
                        .builder(baseUri) // 使用截取后的 baseUri
                        .sseEndpoint(sseEndpoint) // 使用截取或默認的 sseEndpoint
                        .build();

                McpSyncClient mcpSyncClient = McpClient.sync(sseClientTransport).requestTimeout(Duration.ofMinutes(aiClientToolMcpVO.getRequestTimeout())).build();
                var init_sse = mcpSyncClient.initialize();
                log.info("Tool SSE MCP Initialized {}", init_sse);
                return mcpSyncClient;
            }
            case"stdio" -> {
                AiClientToolMcpVO.TransportConfigStdio transportConfigStdio = aiClientToolMcpVO.getTransportConfigStdio();
                Map<String, AiClientToolMcpVO.TransportConfigStdio.Stdio> stdioMap = transportConfigStdio.getStdio();
                AiClientToolMcpVO.TransportConfigStdio.Stdio stdio = stdioMap.get(aiClientToolMcpVO.getMcpName());

                // https://github.com/modelcontextprotocol/servers/tree/main/src/filesystem
                var stdioParams = ServerParameters.builder(stdio.getCommand())
                        .args(stdio.getArgs())
                        .build();
                var mcpClient = McpClient.sync(new StdioClientTransport(stdioParams))
                        .requestTimeout(Duration.ofSeconds(aiClientToolMcpVO.getRequestTimeout())).build();
                var init_stdio = mcpClient.initialize();
                log.info("Tool Stdio MCP Initialized {}", init_stdio);
                return mcpClient;
            }
        }

        thrownew RuntimeException("err! transportType " + transportType + " not exist!");
    }

}

以上代碼，是為了自動化構建 MCP 服務的，其中 case sse 的部分，會對 url 進行拆分，如果本身 url 配置了校驗權限，則不會從另外一個參數獲取，否則從另外參數拼接。這樣就可以很好的擴展用戶配置時的多樣性問題了。

以上是關于帶有權限校驗的 MCP 服務配置的問題，接下來，我們要說下怎么自己開發一個帶有權限校驗

二、實現，帶有權限校驗的 MCP 服務

首先，Spring AI 是有意提供基于自家的 OAuth2 框架，完成 MCP 服務的多樣性權限校驗的。不過目前提供的方案能用，但不算成熟。

圖片

官網：https://spring.io/blog/2025/05/19/spring-ai-mcp-client-oauth2

1. 基于 OAuth2 認證

1.1 工程結構

圖片

工程：https://gitcode.net/KnowledgePlanet/mcp-server-auth - 面向于學習 ai-agent-station 的伙伴
使用 OAuth2 基于 Spring MVC 的方式到也簡單，知道添加配置即可。

1.2 所需的 POM 文件

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-oauth2-resource-server</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-oauth2-authorization-server</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.ai</groupId>
    <artifactId>spring-ai-starter-mcp-server-webmvc</artifactId>
</dependency>

1.3 測試驗證

@Slf4j
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = "server.shutdown=immediate")
publicclass ApiTest {

    @LocalServerPort
    privateint port;

    privatefinal ObjectMapper objectMapper = new ObjectMapper();

    @Test
    public void test_access_token() throws IOException, InterruptedException {
        String token = obtainAccessToken();
        log.info("token:{}", token);
        // eyJraWQiOiJiMWQ0MGIxNi1hOTYzLTQ2NmYtYTVkOC02NGRjMzg0ODljYWEiLCJhbGciOiJSUzI1NiJ9.eyJzdWIiOiJtY3AtY2xpZW50IiwiYXVkIjoibWNwLWNsaWVudCIsIm5iZiI6MTc0ODA1MTc1NiwiaXNzIjoiaHR0cDovL2xvY2FsaG9zdDo1ODA5OCIsImV4cCI6MTc0ODA1MjA1NiwiaWF0IjoxNzQ4MDUxNzU2LCJqdGkiOiI5NjY4ZmZkMi0wNjQ2LTRiNmItODQ4Ni1jYzk3ZjMxNTdmOTEifQ.CG4GYai_NYkmfcqmNi-_HYG06Kan04uNSsC2ivn_eC9Ra6xMKYTs9KIT7k5lKxSFRUOPI7K0zJNVvNXrrIe0iFl-csrG2vGukNTGTPMxtUi2hheBMRbnvjvuojW4DeOEE8UOpdA6uow67ucwcymTlDXE-k7OjRZeyp7UdVz2WyoDFQhLB6ihLbDSj5puAZxfNocirRzo36gmW243aW9f1gugPUcpND-oobc2q8xyBG2cX2AlGXUSS-v9PLjHr2W2smFTKHHGwu7FpMMBnJLUT5gZD0llIg6yqro91nFaAFOpGHXjRZYgVjkRlzxx08Zuquva9PbStxbUl2j8hI43_Q

        var client = HttpClient.newHttpClient();

        var request = HttpRequest.newBuilder()
                .uri(URI.create("http://localhost:" + port + "/sse"))
                .header("Accept", "text/event-stream")
                .header("Authorization", "Bearer " + token)
                .GET()
                .build();

        var responseCode = new AtomicInteger(-1);
        var sseRequest = client.sendAsync(request, HttpResponse.BodyHandlers.ofInputStream()).thenApply(response -> {
            responseCode.set(response.statusCode());
            if (response.statusCode() == 200) {
                log.info("response:{}", JSON.toJSONString(response));
                return response;
            }
            else {
                thrownew RuntimeException("Failed to connect to SSE endpoint: " + response.statusCode());
            }
        });

        await().atMost(Duration.ofSeconds(1)).until(sseRequest::isDone);
        assertThat(sseRequest).isCompleted();
        assertThat(responseCode).hasValue(200);
    }

    private String obtainAccessToken() throws IOException, InterruptedException {
        var client = HttpClient.newHttpClient();

        var clearTextCredentials = "mcp-client:secret".getBytes(StandardCharsets.UTF_8);
        var credentials = new String(Base64.getUrlEncoder().encode(clearTextCredentials));
        var request = HttpRequest.newBuilder()
                .uri(URI.create("http://localhost:" + port + "/oauth2/token"))
                .header("Authorization", "Basic " + credentials)
                .header("Content-Type", "application/x-www-form-urlencoded")
                .POST(ofString("grant_type=client_credentials"))
                .build();

        var rawResponse = client.send(request, HttpResponse.BodyHandlers.ofString()).body();

        Map<String, String> response = objectMapper.readValue(rawResponse, Map.class);
        return response.get("access_token");
    }
    
}

加上 OAuth2 以后，就需要獲取并設置 accessToken 才能訪問 sse 服務了。

2. 基于網關實現

其實我們到不非得依賴于 Spring OAuth2 往 MCP 服務里在添加一些其他的東西。倒不如直接走網關，讓網關來管理權限，MCP 服務只做服務的事情就好。

這里我們基于 Nginx 來配置驗證功能，當然你可以在學習本節的案例后，配置任何其他的網關來管理你的 MCP 服務。

注意，這里的前置條件為你已經跟著小傅哥，至少完成了一個 MCP 服務。課程；https://t.zsxq.com/GwNZp

當我們有了一套基于 sse 形式訪問的 mcp 后，我們是可以給這套 mcp 基于 nginx 轉發的形式進行訪問后面真實的 mcp 服務的。在轉發的過程中，拿到用戶在地址 http://127.0.0.1:9999/sse?apikey=DElk89iu8Ehhnbu mcp 服務后面拼接的 apikey，并對 apikey 進行驗證。

2.1 配置工程

圖片

在 ai-agent-station 項目下，提供了 dev-ops-v2 配置 mcp 服務轉發和驗證能力。
注意，部署的時候，要把 mcp.localhost.conf 轉發的 mcp 服務的地址，更換為你的地址。
另外，每一個 mcp.localhost.conf 還可以配置域名，這樣就達到了高德地圖 mcp 訪問的效果。舉例；https://fatie.mcp.bugstack.cn/sse/apikey=*******

2.2 服務轉發&校驗

# 可以負載服務
upstream backend_servers {
    server 192.168.1.108:8101;
}

server {
    listen 80;

    server_name 192.168.1.104;  # 修改為你的實際服務器 IP 或域名【域名需要備案】

    location /sse {
        # 驗證apikey參數，這個apikey也可以對接服務端接口來處理。
        if ($arg_apikey != "DElk89iu8Ehhnbu") {
            return403; # 如果apikey不正確，返回403禁止訪問
        }

        # 重寫URL，去掉apikey參數
        rewrite ^(/sse/)\?apikey=.* $1break;

        proxy_pass http://backend_servers;  # 將請求代理到上游服務器組
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;

        chunked_transfer_encoding off;
        proxy_buffering off;
        proxy_cache off;
        proxy_set_header X-Forwarded-For $remote_addr;
        proxy_set_header X-Forwarded-Proto $scheme;
    }

    location /mcp/message {
        proxy_pass http://backend_servers;  # 將請求代理到上游服務器組
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
    }

}

特別注意，mcp 服務是有2個步驟的，一個是 sse 訪問，還有一個 mcp/message 的處理。我們只需要對 sse 的請求進行驗證即可。
/sse 請求路徑，需要會提取 apikey 與 nginx 配置的值進行對比，如果不正確則會返回一個 403 禁止訪問，通過則放行。
之后重寫 url 地址，讓轉發到本身 mcp 的地址是干凈的。從 http://127.0.0.1:9999/sse?apikey=DElk89iu8Ehhnbu 驗證轉發后為 http://192.168.1.108:8101/sse

2.3 功能驗證

首先，要確保你的 mcp 服務是可以使用的。如，訪問；http://192.168.1.108:8101/sse 可以獲得到結果。

圖片

- 如圖，驗證成功。我們可以通過轉發的方式進行驗證和使用。 - 另外，有了轉發和驗證，你原本的服務，sse 8101 就不用對外了。只有你的網關（nginx）可以訪問即可。這樣就可以控制權限了。

2.4 動態驗證

那么，目前我們配置的nginx 轉發這不是一個固定的權限賬號嗎，怎么讓不同的接入方都申請一個秘鑰key來使用呢？這里我們需要使用到 nginx 的 auth 認證模塊。

# 可以負載服務
upstream backend_servers {
    server 192.168.1.108:8101;
}

server {
    listen 80;

    server_name 192.168.1.104;  # 修改為你的實際服務器 IP 或域名【域名需要備案】

    location /sse {
        auth_request /auth;

        # 重寫URL，去掉apikey參數
        rewrite ^(/sse/)\?apikey=.* $1break;

        proxy_pass http://backend_servers;  # 將請求代理到上游服務器組
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;

        chunked_transfer_encoding off;
        proxy_buffering off;
        proxy_cache off;
        proxy_set_header X-Forwarded-For $remote_addr;
        proxy_set_header X-Forwarded-Proto $scheme;
    }

    location /mcp/message {
        proxy_pass http://backend_servers;  # 將請求代理到上游服務器組
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
    }

     location = /auth {
        # 發送子請求到HTTP服務，驗證客戶端的憑據，返回響應碼
        internal;
        # 設置參數
        set $query '';
        if ($request_uri ~* "[^\?]+\?(.*)$") {
            set $query $1;
        }
        # 驗證成功，返回200 OK
        proxy_pass http://207.246.123.*:8090/auth/token?$query;
        # 發送原始請求
        proxy_pass_request_body off;
        # 清空 Content-Type
        proxy_set_header Content-Type "";
     }  

}

在訪問 /sse 的時候，增加 auth 認證，auth 來訪問本地一個 http 接口。你可以是 SpringBoot 實現的接口。這個接口負責驗證你的秘鑰是否正確。同時你的 SpringBoot 服務還可以提供出一個創建秘鑰的平臺，讓接入方使用。
其實類似這樣的場景，使用功能更加豐富的 api 網關都是自帶的，或者 github 一些專門為 mcp 做網關服務的也都有。

責任編輯：武曉燕來源： bugstack蟲洞棧

MCP 服務 OAuth2