Package com.bytedesk.ai.springai.mcp_server

Class McpServerService

java.lang.Object

com.bytedesk.ai.springai.mcp_server.McpServerService

@Service
public class McpServerService
extends Object

MCP Server 客户端服务 - 简化版本 负责与第三方 MCP 服务器通信，调用工具、获取资源、管理连接等 注意：当前版本为简化实现，主要用于配置管理和接口定义 Spring AI 1.0.1 的 MCP 客户端 API 正在发展中，未来版本将提供完整的客户端功能

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	McpServerService.ServerStatus	服务器状态信息

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<String,Boolean>	connectionCache
private final McpServerRestService	mcpServerRestService
private final Map<String,McpServerService.ServerStatus>	serverStatusCache
private final org.springframework.web.reactive.function.client.WebClient.Builder	webClientBuilder

Constructor Summary

Constructors

Constructor	Description
McpServerService()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<ToolCallResponse>	callTool(ToolCallRequest request)	调用 MCP 工具
CompletableFuture<Boolean>	connectToServer(String serverUid)	连接到 MCP 服务器
CompletableFuture<Void>	disconnectFromServer(String serverUid)	断开与指定MCP服务器的连接
List<String>	getActiveServers()	获取所有活跃的服务器
CompletableFuture<List<McpPrompt>>	getAvailablePrompts(String serverUid)	获取服务器可用提示列表
CompletableFuture<List<McpResource>>	getAvailableResources(String serverUid)	获取服务器可用资源列表
CompletableFuture<List<McpTool>>	getAvailableTools(String serverUid)	获取服务器可用工具列表
CompletableFuture<Object>	getPrompt(String serverUid, String promptName, Map<String,Object> arguments)	获取提示内容
McpServerService.ServerStatus	getServerStatus(String serverUid)	获取服务器状态
CompletableFuture<Boolean>	healthCheck(String serverUid)	健康检查
private void	loadServerCapabilities(String serverUid)
private boolean	performConnection(McpServerEntity server)	执行实际连接操作（当前为模拟实现）
private boolean	performHttpHealthCheck(McpServerEntity server)
CompletableFuture<Object>	readResource(String serverUid, String resourceUri)	读取资源内容
private void	updateEntityStatus(McpServerEntity server, McpServerStatusEnum status, String error)
private void	updateEntityStatus(String serverUid, McpServerStatusEnum status, String error)
private void	updateServerCapabilities(String serverUid, McpServerService.ServerStatus status)
private void	updateServerStatus(String serverUid, boolean connected, String error)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

mcpServerRestService

private final McpServerRestService mcpServerRestService

webClientBuilder

private final org.springframework.web.reactive.function.client.WebClient.Builder webClientBuilder

connectionCache

private final Map<String,Boolean> connectionCache

serverStatusCache

private final Map<String,McpServerService.ServerStatus> serverStatusCache

Constructor Details

McpServerService

public McpServerService()

Method Details

connectToServer

public CompletableFuture<Boolean> connectToServer(String serverUid)

连接到 MCP 服务器

disconnectFromServer

public CompletableFuture<Void> disconnectFromServer(String serverUid)

断开与指定MCP服务器的连接

callTool

@Retryable(value=java.lang.Exception.class,
           maxAttempts=3,
           backoff=@Backoff(delay=1000L,multiplier=2.0))
public CompletableFuture<ToolCallResponse> callTool(ToolCallRequest request)

调用 MCP 工具

getAvailableTools

public CompletableFuture<List<McpTool>> getAvailableTools(String serverUid)

获取服务器可用工具列表

getAvailableResources

public CompletableFuture<List<McpResource>> getAvailableResources(String serverUid)

获取服务器可用资源列表

getAvailablePrompts

public CompletableFuture<List<McpPrompt>> getAvailablePrompts(String serverUid)

获取服务器可用提示列表

readResource

public CompletableFuture<Object> readResource(String serverUid,
 String resourceUri)

读取资源内容

getPrompt

public CompletableFuture<Object> getPrompt(String serverUid,
 String promptName,
 Map<String,Object> arguments)

获取提示内容

healthCheck

public CompletableFuture<Boolean> healthCheck(String serverUid)

健康检查

getServerStatus

public McpServerService.ServerStatus getServerStatus(String serverUid)

获取服务器状态

getActiveServers

public List<String> getActiveServers()

获取所有活跃的服务器

performConnection

private boolean performConnection(McpServerEntity server)

执行实际连接操作（当前为模拟实现）

loadServerCapabilities

private void loadServerCapabilities(String serverUid)

updateServerCapabilities

private void updateServerCapabilities(String serverUid,
 McpServerService.ServerStatus status)

updateServerStatus

private void updateServerStatus(String serverUid,
 boolean connected,
 String error)

updateEntityStatus

private void updateEntityStatus(McpServerEntity server,
 McpServerStatusEnum status,
 String error)

updateEntityStatus

private void updateEntityStatus(String serverUid,
 McpServerStatusEnum status,
 String error)

performHttpHealthCheck

private boolean performHttpHealthCheck(McpServerEntity server)