无状态可流式HTTP MCP服务器

无状态可流式HTTP MCP服务器旨在简化部署,其中请求之间不维护会话状态。这些服务器是微服务架构和云原生部署的理想选择。

设置属性 spring.ai.mcp.server.protocol=STATELESS
使用 可流式HTTP客户端 连接到无状态服务器。
无状态服务器不支持向MCP客户端发送消息请求(例如,引导、采样、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.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

protocol

MCP服务器协议

必须设置为 STATELESS 以启用无状态服务器

tool-callback-converter

启用/禁用Spring AI ToolCallbacks到MCP工具规范的转换

true

name

用于识别的服务器名称

mcp-server

version

服务器版本

1.0.0

instructions

客户端交互的可选说明

null

类型

服务器类型(同步/异步)

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

不允许删除操作

功能和能力

MCP Server Boot Starter允许服务器向客户端公开工具、资源和提示。它会自动将注册为Spring bean的自定义能力处理程序根据服务器类型转换为同步/异步规范

工具

允许服务器公开可由语言模型调用的工具。MCP Server Boot Starter提供

  • 变更通知支持

  • 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,可以禁用所有工具回调的自动检测和注册。
工具上下文支持不适用于无状态服务器。

资源

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

  • 静态和动态资源规范

  • 可选的变更通知

  • 支持资源模板

  • 同步/异步资源规范之间的自动转换

  • 通过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("Failed to generate system info", e);
        }
    });

    return List.of(resourceSpecification);
}

提示

提供了一种标准化方式,供服务器向客户端公开提示模板。

  • 变更通知支持

  • 模板版本控制

  • 同步/异步提示规范之间的自动转换

  • 通过Spring bean自动生成提示规范

@Bean
public List<McpStatelessServerFeatures.SyncPromptSpecification> myPrompts() {
    var prompt = new McpSchema.Prompt("greeting", "A friendly greeting prompt",
        List.of(new McpSchema.PromptArgument("name", "The name to greet", 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 + "! How can I assist you today?"));
        return new GetPromptResult("A personalized greeting message", List.of(userMessage));
    });

    return List.of(promptSpecification);
}

完成

提供了一种标准化方式,供服务器向客户端公开完成能力。

  • 支持同步和异步完成规范

  • 通过Spring bean自动注册

@Bean
public List<McpStatelessServerFeatures.SyncCompletionSpecification> myCompletions() {
    var completion = new McpStatelessServerFeatures.SyncCompletionSpecification(
        new McpSchema.PromptReference(
					"ref/prompt", "code-completion", "Provides code completion suggestions"),
        (exchange, request) -> {
            // Implementation that returns completion suggestions
            return new McpSchema.CompleteResult(List.of("python", "pytorch", "pyside"), 10, true);
        }
    );

    return List.of(completion);
}

使用示例

无状态服务器配置

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();
	}
}

自动配置将自动注册工具回调作为MCP工具。您可以有多个生成ToolCallbacks的bean,自动配置将合并它们。

© . This site is unofficial and not affiliated with VMware.