io.modelcontextprotocol.server

类 McpAsyncServer

java.lang.Object

io.modelcontextprotocol.server.McpAsyncServer

public class McpAsyncServer
extends java.lang.Object

The Model Context Protocol (MCP) server implementation that provides asynchronous communication using Project Reactor's Mono and Flux types.

This server implements the MCP specification, enabling AI models to expose tools, resources, and prompts through a standardized interface. Key features include:

• Asynchronous communication using reactive programming patterns
• Dynamic tool registration and management
• Resource handling with URI-based addressing
• Prompt template management
• Real-time client notifications for state changes
• Structured logging with configurable severity levels
• Support for client-side AI model sampling

The server follows a lifecycle:

1. Initialization - Accepts client connections and negotiates capabilities
2. Normal Operation - Handles client requests and sends notifications
3. Graceful Shutdown - Ensures clean connection termination

This implementation uses Project Reactor for non-blocking operations, making it suitable for high-throughput scenarios and reactive applications. All operations return Mono or Flux types that can be composed into reactive pipelines.

The server supports runtime modification of its capabilities through methods like addTool(io.modelcontextprotocol.server.McpServerFeatures.AsyncToolSpecification), addResource(io.modelcontextprotocol.server.McpServerFeatures.AsyncResourceSpecification), and addPrompt(io.modelcontextprotocol.server.McpServerFeatures.AsyncPromptSpecification), automatically notifying connected clients of changes when configured to do so.

另请参阅:

McpServer, McpSchema, McpClientSession

构造器概要

构造器

构造器和说明
McpAsyncServer(McpServerTransportProvider mcpTransportProvider, com.fasterxml.jackson.databind.ObjectMapper objectMapper, McpServerFeatures.Async features, java.time.Duration requestTimeout, McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator) Create a new McpAsyncServer with the given transport provider and capabilities.
McpAsyncServer(McpStreamableServerTransportProvider mcpTransportProvider, com.fasterxml.jackson.databind.ObjectMapper objectMapper, McpServerFeatures.Async features, java.time.Duration requestTimeout, McpUriTemplateManagerFactory uriTemplateManagerFactory, JsonSchemaValidator jsonSchemaValidator)

方法概要

限定符和类型	方法和说明
reactor.core.publisher.Mono<java.lang.Void>	addPrompt(McpServerFeatures.AsyncPromptSpecification promptSpecification) Add a new prompt handler at runtime.
reactor.core.publisher.Mono<java.lang.Void>	addResource(McpServerFeatures.AsyncResourceSpecification resourceSpecification) Add a new resource handler at runtime.
reactor.core.publisher.Mono<java.lang.Void>	addTool(McpServerFeatures.AsyncToolSpecification toolSpecification) Add a new tool call specification at runtime.
void	close() Close the server immediately.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Gracefully closes the server, allowing any in-progress operations to complete.
McpSchema.ServerCapabilities	getServerCapabilities() Get the server capabilities that define the supported features and functionality.
McpSchema.Implementation	getServerInfo() Get the server implementation information.
reactor.core.publisher.Mono<java.lang.Void>	loggingNotification(McpSchema.LoggingMessageNotification loggingMessageNotification) 已过时。 Use McpAsyncServerExchange#loggingNotification(LoggingMessageNotification) instead.
reactor.core.publisher.Mono<java.lang.Void>	notifyPromptsListChanged() Notifies clients that the list of available prompts has changed.
reactor.core.publisher.Mono<java.lang.Void>	notifyResourcesListChanged() Notifies clients that the list of available resources has changed.
reactor.core.publisher.Mono<java.lang.Void>	notifyResourcesUpdated(McpSchema.ResourcesUpdatedNotification resourcesUpdatedNotification) Notifies clients that the resources have updated.
reactor.core.publisher.Mono<java.lang.Void>	notifyToolsListChanged() Notifies clients that the list of available tools has changed.
reactor.core.publisher.Mono<java.lang.Void>	removePrompt(java.lang.String promptName) Remove a prompt handler at runtime.
reactor.core.publisher.Mono<java.lang.Void>	removeResource(java.lang.String resourceUri) Remove a resource handler at runtime.
reactor.core.publisher.Mono<java.lang.Void>	removeTool(java.lang.String toolName) Remove a tool handler at runtime.

从类继承的方法 java.lang.Object

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

构造器详细资料

McpAsyncServer

public McpAsyncServer(McpServerTransportProvider mcpTransportProvider,
                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                      McpServerFeatures.Async features,
                      java.time.Duration requestTimeout,
                      McpUriTemplateManagerFactory uriTemplateManagerFactory,
                      JsonSchemaValidator jsonSchemaValidator)

Create a new McpAsyncServer with the given transport provider and capabilities.

参数:

mcpTransportProvider - The transport layer implementation for MCP communication.

features - The MCP server supported features.

objectMapper - The ObjectMapper to use for JSON serialization/deserialization

McpAsyncServer

public McpAsyncServer(McpStreamableServerTransportProvider mcpTransportProvider,
                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                      McpServerFeatures.Async features,
                      java.time.Duration requestTimeout,
                      McpUriTemplateManagerFactory uriTemplateManagerFactory,
                      JsonSchemaValidator jsonSchemaValidator)

方法详细资料

getServerCapabilities

public McpSchema.ServerCapabilities getServerCapabilities()

Get the server capabilities that define the supported features and functionality.

返回:

The server capabilities

getServerInfo

public McpSchema.Implementation getServerInfo()

Get the server implementation information.

返回:

The server implementation details

closeGracefully

public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()

Gracefully closes the server, allowing any in-progress operations to complete.

返回:

A Mono that completes when the server has been closed

close

public void close()

Close the server immediately.

addTool

public reactor.core.publisher.Mono<java.lang.Void> addTool(McpServerFeatures.AsyncToolSpecification toolSpecification)

Add a new tool call specification at runtime.

参数:

toolSpecification - The tool specification to add

返回:

Mono that completes when clients have been notified of the change

removeTool

public reactor.core.publisher.Mono<java.lang.Void> removeTool(java.lang.String toolName)

Remove a tool handler at runtime.

参数:

toolName - The name of the tool handler to remove

返回:

Mono that completes when clients have been notified of the change

notifyToolsListChanged

public reactor.core.publisher.Mono<java.lang.Void> notifyToolsListChanged()

Notifies clients that the list of available tools has changed.

返回:

A Mono that completes when all clients have been notified

addResource

public reactor.core.publisher.Mono<java.lang.Void> addResource(McpServerFeatures.AsyncResourceSpecification resourceSpecification)

Add a new resource handler at runtime.

参数:

resourceSpecification - The resource handler to add

返回:

Mono that completes when clients have been notified of the change

removeResource

public reactor.core.publisher.Mono<java.lang.Void> removeResource(java.lang.String resourceUri)

Remove a resource handler at runtime.

参数:

resourceUri - The URI of the resource handler to remove

返回:

Mono that completes when clients have been notified of the change

notifyResourcesListChanged

public reactor.core.publisher.Mono<java.lang.Void> notifyResourcesListChanged()

Notifies clients that the list of available resources has changed.

返回:

A Mono that completes when all clients have been notified

notifyResourcesUpdated

public reactor.core.publisher.Mono<java.lang.Void> notifyResourcesUpdated(McpSchema.ResourcesUpdatedNotification resourcesUpdatedNotification)

Notifies clients that the resources have updated.

返回:

A Mono that completes when all clients have been notified

addPrompt

public reactor.core.publisher.Mono<java.lang.Void> addPrompt(McpServerFeatures.AsyncPromptSpecification promptSpecification)

Add a new prompt handler at runtime.

参数:

promptSpecification - The prompt handler to add

返回:

Mono that completes when clients have been notified of the change

removePrompt

public reactor.core.publisher.Mono<java.lang.Void> removePrompt(java.lang.String promptName)

Remove a prompt handler at runtime.

参数:

promptName - The name of the prompt handler to remove

返回:

Mono that completes when clients have been notified of the change

notifyPromptsListChanged

public reactor.core.publisher.Mono<java.lang.Void> notifyPromptsListChanged()

Notifies clients that the list of available prompts has changed.

返回:

A Mono that completes when all clients have been notified

loggingNotification

@Deprecated
public reactor.core.publisher.Mono<java.lang.Void> loggingNotification(McpSchema.LoggingMessageNotification loggingMessageNotification)

已过时。 Use McpAsyncServerExchange#loggingNotification(LoggingMessageNotification) instead.

This implementation would, incorrectly, broadcast the logging message to all connected clients, using a single minLoggingLevel for all of them. Similar to the sampling and roots, the logging level should be set per client session and use the ServerExchange to send the logging message to the right client.

参数:

loggingMessageNotification - The logging message to send

返回:

A Mono that completes when the notification has been sent