Lzh on GitHub

无状态 Streamable-HTTP MCP 服务器

无状态 Streamable-HTTP MCP 服务器旨在简化部署,在请求之间不维护会话状态。这类服务器非常适合微服务架构和云原生部署。

设置属性 spring.ai.mcp.server.protocol=STATELESS
使用 Streamable-HTTP 客户端 连接无状态服务器。
无状态服务器不支持向 MCP 客户端发送消息请求(例如,elicitation、sampling、ping)。

无状态 WebMVC 服务器

使用 spring-ai-starter-mcp-server-webmvc 依赖:

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

并将属性设置为 spring.ai.mcp.server.protocol=STATELESS

  • 使用 Spring MVC 传输实现无状态操作
  • 不进行会话状态管理
  • 简化的部署模型
  • 针对云原生环境优化

无状态 WebFlux 服务器

使用 spring-ai-starter-mcp-server-webflux 依赖:

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

并将属性设置为 spring.ai.mcp.server.protocol=STATELESS

  • 使用 WebFlux 传输实现响应式无状态操作
  • 不进行会话状态管理
  • 非阻塞请求处理
  • 针对高吞吐量场景优化

配置属性

通用属性

所有通用属性都以 spring.ai.mcp.server 为前缀:

属性描述默认值
enabled启用/禁用无状态 MCP 服务器true
protocolMCP 服务器协议必须设置为 STATELESS 以启用无状态服务器
tool-callback-converter启用/禁用将 Spring AI ToolCallbacks 转换为 MCP 工具规范true
name服务器名称(用于标识)mcp-server
version服务器版本1.0.0
instructions可选的客户端交互指导说明null
type服务器类型(SYNC/ASYNC)SYNC
capabilities.resource启用/禁用资源能力true
capabilities.tool启用/禁用工具能力true
capabilities.prompt启用/禁用提示能力true
capabilities.completion启用/禁用完成能力true
tool-response-mime-type每个工具名称的响应 MIME 类型-
request-timeout请求超时时间20 秒

MCP 注解属性

MCP 服务器注解提供了一种使用 Java 注解声明式实现 MCP 服务器处理器的方法。

服务器的 mcp-annotations 属性以 spring.ai.mcp.server.annotation-scanner 为前缀:

属性描述默认值
enabled启用/禁用 MCP 服务器注解的自动扫描true

无状态连接属性

所有连接属性均以 spring.ai.mcp.server.stateless 为前缀:

属性描述默认值
mcp-endpoint自定义 MCP 端点路径/mcp
disallow-delete禁止删除操作false

功能与能力

MCP 服务器启动器允许服务器向客户端公开工具、资源和提示。它会根据服务器类型,自动将以 Spring Bean 注册的自定义功能处理器转换为同步或异步规范。

工具

允许服务器公开可被语言模型调用的工具。MCP 服务器启动器提供以下功能:

  • 支持变更通知
  • 根据服务器类型,Spring AI 工具 会自动转换为同步/异步规范
  • 通过 Spring Bean 自动注册工具示例
@Bean
public ToolCallbackProvider myTools(...) {
    List<ToolCallback> tools = ...
    return ToolCallbackProvider.from(tools);
}

或使用底层 API:

@Bean
public List<McpStatelessServerFeatures.SyncToolSpecification> myTools(...) {
    List<McpStatelessServerFeatures.SyncToolSpecification> tools = ...
    return tools;
}

自动配置会自动检测并注册所有工具回调,包括:

  • 单个 ToolCallback Bean
  • ToolCallback Bean 列表
  • ToolCallbackProvider Bean

工具会按名称去重,使用每个工具名称的第一个出现项。

可以通过将 tool-callback-converter 设置为 false 来禁用所有工具回调的自动检测和注册。
工具上下文(Tool Context)不适用于无状态服务器。

资源

提供一种标准化方式,让服务器可以向客户端公开资源。

  • 支持静态和动态资源规范
  • 可选的变更通知
  • 支持资源模板
  • 自动在同步/异步资源规范之间转换

通过 Spring Bean 自动注册资源示例:

@Bean
public List<McpStatelessServerFeatures.SyncResourceSpecification> myResources(...) {
    var systemInfoResource = new McpSchema.Resource(...);
    var resourceSpecification = new McpStatelessServerFeatures.SyncResourceSpecification(systemInfoResource, (context, request) -> {
        try {
            var systemInfo = Map.of(...);
            String jsonContent = new ObjectMapper().writeValueAsString(systemInfo);
            return new McpSchema.ReadResourceResult(
                    List.of(new McpSchema.TextResourceContents(request.uri(), "application/json", jsonContent)));
        }
        catch (Exception e) {
            throw new RuntimeException("生成系统信息失败", e);
        }
    });

    return List.of(resourceSpecification);
}

该机制会自动将注册的资源处理器转换为同步/异步规范并提供给无状态 MCP 服务器使用。

提示

提供一种标准化方式,让服务器可以向客户端公开提示(Prompt)模板。

  • 支持变更通知
  • 支持模板版本管理
  • 自动在同步/异步提示规范之间转换
  • 通过 Spring Bean 自动注册提示示例
@Bean
public List<McpStatelessServerFeatures.SyncPromptSpecification> myPrompts() {
    var prompt = new McpSchema.Prompt("greeting", "一个友好的问候提示",
        List.of(new McpSchema.PromptArgument("name", "需要问候的名字", true)));

    var promptSpecification = new McpStatelessServerFeatures.SyncPromptSpecification(prompt, (context, getPromptRequest) -> {
        String nameArgument = (String) getPromptRequest.arguments().get("name");
        if (nameArgument == null) { nameArgument = "friend"; }
        var userMessage = new PromptMessage(Role.USER, new TextContent("Hello " + nameArgument + "! 今天我能如何帮助你?"));
        return new GetPromptResult("个性化问候消息", List.of(userMessage));
    });

    return List.of(promptSpecification);
}

该机制会自动将注册的提示处理器转换为同步/异步规范并提供给无状态 MCP 服务器使用。

补全

提供一种标准化方式,让服务器可以向客户端公开补全(Completion)功能。

  • 支持同步和异步补全规范
  • 通过 Spring Bean 自动注册

示例:

@Bean
public List<McpStatelessServerFeatures.SyncCompletionSpecification> myCompletions() {
    var completion = new McpStatelessServerFeatures.SyncCompletionSpecification(
        new McpSchema.PromptReference(
            "ref/prompt", "code-completion", "提供代码补全建议"),
        (exchange, request) -> {
            // 返回补全建议的实现
            return new McpSchema.CompleteResult(List.of("python", "pytorch", "pyside"), 10, true);
        }
    );

    return List.of(completion);
}

该机制会自动将注册的补全处理器转换为同步/异步规范,供无状态 MCP 服务器使用。

使用示例

无状态服务器配置

spring:
  ai:
    mcp:
      server:
        protocol: STATELESS
        name: stateless-mcp-server
        version: 1.0.0
        type: ASYNC
        instructions: "This stateless server is optimized for cloud deployments"
        streamable-http:
          mcp-endpoint: /api/mcp

使用 MCP 服务器创建 Spring Boot 应用

@Service
public class WeatherService {

    @Tool(description = "Get weather information by city name")
    public String getWeather(String cityName) {
        // Implementation
    }
}

@SpringBootApplication
public class McpServerApplication {

    private static final Logger logger = LoggerFactory.getLogger(McpServerApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(McpServerApplication.class, args);
    }

    @Bean
    public ToolCallbackProvider weatherTools(WeatherService weatherService) {
        return MethodToolCallbackProvider.builder().toolObjects(weatherService).build();
    }
}

自动配置会将工具回调(ToolCallbacks)自动注册为 MCP 工具。你可以有多个 Bean 提供 ToolCallbacks,自动配置会将它们合并处理。