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.AsyncToolRegistration), addResource(io.modelcontextprotocol.server.McpServerFeatures.AsyncResourceRegistration), and addPrompt(io.modelcontextprotocol.server.McpServerFeatures.AsyncPromptRegistration), automatically notifying connected clients of changes when configured to do so.
另请参阅:

McpServer, McpSchema, McpClientSession

方法概要

所有方法实例方法具体方法已过时的方法
限定符和类型	方法和说明
`reactor.core.publisher.Mono<java.lang.Void>`	`addPrompt(McpServerFeatures.AsyncPromptRegistration promptRegistration)` 已过时。 This method will be removed in 0.9.0. Use `addPrompt(McpServerFeatures.AsyncPromptSpecification)`.
`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.AsyncResourceRegistration resourceHandler)` 已过时。 This method will be removed in 0.9.0. Use `addResource(McpServerFeatures.AsyncResourceSpecification)`.
`reactor.core.publisher.Mono<java.lang.Void>`	`addResource(McpServerFeatures.AsyncResourceSpecification resourceHandler)` Add a new resource handler at runtime.
`reactor.core.publisher.Mono<java.lang.Void>`	`addResourceTemplate(McpServerFeatures.AsyncResourceTemplateSpecification resourceHandler)` Add a new resource template handler at runtime.
`reactor.core.publisher.Mono<java.lang.Void>`	`addTool(McpServerFeatures.AsyncToolRegistration toolRegistration)` 已过时。 This method will be removed in 0.9.0. Use `addTool(McpServerFeatures.AsyncToolSpecification)`.
`reactor.core.publisher.Mono<java.lang.Void>`	`addTool(McpServerFeatures.AsyncToolSpecification toolSpecification)` Add a new tool 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.
`reactor.core.publisher.Mono<McpSchema.CreateMessageResult>`	`createMessage(McpSchema.CreateMessageRequest createMessageRequest)` 已过时。 This will be removed in 0.9.0. Use `McpAsyncServerExchange.createMessage(McpSchema.CreateMessageRequest)`.
`McpSchema.ClientCapabilities`	`getClientCapabilities()` 已过时。 This will be removed in 0.9.0. Use `McpAsyncServerExchange.getClientCapabilities()`.
`McpSchema.Implementation`	`getClientInfo()` 已过时。 This will be removed in 0.9.0. Use `McpAsyncServerExchange.getClientInfo()`.
`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<McpSchema.ListRootsResult>`	`listRoots()` 已过时。 This will be removed in 0.9.0. Use `McpAsyncServerExchange.listRoots()`.
`reactor.core.publisher.Mono<McpSchema.ListRootsResult>`	`listRoots(java.lang.String cursor)` 已过时。 This will be removed in 0.9.0. Use `McpAsyncServerExchange.listRoots(String)`.
`reactor.core.publisher.Mono<java.lang.Void>`	`loggingNotification(McpSchema.LoggingMessageNotification loggingMessageNotification)` Send a logging message notification to all connected clients.
`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>`	`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>`	`removeResourceTemplate(java.lang.String resourceUri)` Remove a resource template 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

- 方法详细资料
  - 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
  - getClientCapabilities
```
@Deprecated
public McpSchema.ClientCapabilities getClientCapabilities()
```
    已过时。 This will be removed in 0.9.0. Use McpAsyncServerExchange.getClientCapabilities().
    
    Get the client capabilities that define the supported features and functionality.
    
    返回:
    
    The client capabilities
  - getClientInfo
```
@Deprecated
public McpSchema.Implementation getClientInfo()
```
    已过时。 This will be removed in 0.9.0. Use McpAsyncServerExchange.getClientInfo().
    
    Get the client implementation information.
    
    返回:
    
    The client 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.
  - listRoots
```
@Deprecated
public reactor.core.publisher.Mono<McpSchema.ListRootsResult> listRoots()
```
    已过时。 This will be removed in 0.9.0. Use McpAsyncServerExchange.listRoots().
    
    Retrieves the list of all roots provided by the client.
    
    返回:
    
    A Mono that emits the list of roots result.
  - listRoots
```
@Deprecated
public reactor.core.publisher.Mono<McpSchema.ListRootsResult> listRoots(java.lang.String cursor)
```
    已过时。 This will be removed in 0.9.0. Use McpAsyncServerExchange.listRoots(String).
    
    Retrieves a paginated list of roots provided by the server.
    
    参数:
    
    cursor - Optional pagination cursor from a previous list request
    
    返回:
    
    A Mono that emits the list of roots result containing
  - addTool
```
@Deprecated
public reactor.core.publisher.Mono<java.lang.Void> addTool(McpServerFeatures.AsyncToolRegistration toolRegistration)
```
    已过时。 This method will be removed in 0.9.0. Use addTool(McpServerFeatures.AsyncToolSpecification).
    
    Add a new tool registration at runtime.
    
    参数:
    
    toolRegistration - The tool registration to add
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - addTool
```
public reactor.core.publisher.Mono<java.lang.Void> addTool(McpServerFeatures.AsyncToolSpecification toolSpecification)
```
    Add a new tool 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
```
@Deprecated
public reactor.core.publisher.Mono<java.lang.Void> addResource(McpServerFeatures.AsyncResourceRegistration resourceHandler)
```
    已过时。 This method will be removed in 0.9.0. Use addResource(McpServerFeatures.AsyncResourceSpecification).
    
    Add a new resource handler at runtime.
    
    参数:
    
    resourceHandler - The resource handler to add
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - addResource
```
public reactor.core.publisher.Mono<java.lang.Void> addResource(McpServerFeatures.AsyncResourceSpecification resourceHandler)
```
    Add a new resource handler at runtime.
    
    参数:
    
    resourceHandler - 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
  - addResourceTemplate
```
public reactor.core.publisher.Mono<java.lang.Void> addResourceTemplate(McpServerFeatures.AsyncResourceTemplateSpecification resourceHandler)
```
    Add a new resource template handler at runtime.
    
    参数:
    
    resourceHandler - The resource template handler to add
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - removeResourceTemplate
```
public reactor.core.publisher.Mono<java.lang.Void> removeResourceTemplate(java.lang.String resourceUri)
```
    Remove a resource template handler at runtime.
    
    参数:
    
    resourceUri - The URI of the resource template handler to remove
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - addPrompt
```
@Deprecated
public reactor.core.publisher.Mono<java.lang.Void> addPrompt(McpServerFeatures.AsyncPromptRegistration promptRegistration)
```
    已过时。 This method will be removed in 0.9.0. Use addPrompt(McpServerFeatures.AsyncPromptSpecification).
    
    Add a new prompt handler at runtime.
    
    参数:
    
    promptRegistration - The prompt handler to add
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - 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
```
public reactor.core.publisher.Mono<java.lang.Void> loggingNotification(McpSchema.LoggingMessageNotification loggingMessageNotification)
```
    Send a logging message notification to all connected clients. Messages below the current minimum logging level will be filtered out.
    
    参数:
    
    loggingMessageNotification - The logging message to send
    
    返回:
    
    A Mono that completes when the notification has been sent
  - createMessage
```
@Deprecated
public reactor.core.publisher.Mono<McpSchema.CreateMessageResult> createMessage(McpSchema.CreateMessageRequest createMessageRequest)
```
    已过时。 This will be removed in 0.9.0. Use McpAsyncServerExchange.createMessage(McpSchema.CreateMessageRequest).
    
    Create a new message using the sampling capabilities of the client. The Model Context Protocol (MCP) provides a standardized way for servers to request LLM sampling (“completions” or “generations”) from language models via clients. This flow allows clients to maintain control over model access, selection, and permissions while enabling servers to leverage AI capabilities—with no server API keys necessary. Servers can request text or image-based interactions and optionally include context from MCP servers in their prompts.
    
    参数:
    
    createMessageRequest - The request to create a new message
    
    返回:
    
    A Mono that completes when the message has been created
    
    抛出:
    
    McpError - if the client has not been initialized or does not support sampling capabilities
    
    McpError - if the client does not support the createMessage method
    
    另请参阅:
    
    McpSchema.CreateMessageRequest, McpSchema.CreateMessageResult, Sampling Specification

类 McpAsyncServer

方法概要

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

方法详细资料

getServerCapabilities

getServerInfo

getClientCapabilities

getClientInfo

closeGracefully

close

listRoots

listRoots

addTool

addTool

removeTool

notifyToolsListChanged

addResource

addResource

removeResource

notifyResourcesListChanged

addResourceTemplate

removeResourceTemplate

addPrompt

addPrompt

removePrompt

notifyPromptsListChanged

loggingNotification

createMessage