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

方法概要

所有方法实例方法具体方法已过时的方法
限定符和类型	方法和说明
`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>`	`addResourceTemplate(McpServerFeatures.AsyncResourceTemplateSpecification resourceTemplateSpecification)` Add a new resource template 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.Flux<McpSchema.Prompt>`	`listPrompts()` List all registered prompts.
`reactor.core.publisher.Flux<McpSchema.Resource>`	`listResources()` List all registered resources.
`reactor.core.publisher.Flux<McpSchema.ResourceTemplate>`	`listResourceTemplates()` List all registered resource templates.
`reactor.core.publisher.Flux<McpSchema.Tool>`	`listTools()` List all registered tools.
`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>`	`removeResourceTemplate(java.lang.String uriTemplate)` Remove a resource template 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
  - 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
  - listTools
```
public reactor.core.publisher.Flux<McpSchema.Tool> listTools()
```
    List all registered tools.
    
    返回:
    
    A Flux stream of all registered tools
  - 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
  - listResources
```
public reactor.core.publisher.Flux<McpSchema.Resource> listResources()
```
    List all registered resources.
    
    返回:
    
    A Flux stream of all registered resources
  - 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
  - addResourceTemplate
```
public reactor.core.publisher.Mono<java.lang.Void> addResourceTemplate(McpServerFeatures.AsyncResourceTemplateSpecification resourceTemplateSpecification)
```
    Add a new resource template at runtime.
    
    参数:
    
    resourceTemplateSpecification - The resource template to add
    
    返回:
    
    Mono that completes when clients have been notified of the change
  - listResourceTemplates
```
public reactor.core.publisher.Flux<McpSchema.ResourceTemplate> listResourceTemplates()
```
    List all registered resource templates.
    
    返回:
    
    A Flux stream of all registered resource templates
  - removeResourceTemplate
```
public reactor.core.publisher.Mono<java.lang.Void> removeResourceTemplate(java.lang.String uriTemplate)
```
    Remove a resource template at runtime.
    
    参数:
    
    uriTemplate - The URI template of the resource template 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
  - listPrompts
```
public reactor.core.publisher.Flux<McpSchema.Prompt> listPrompts()
```
    List all registered prompts.
    
    返回:
    
    A Flux stream of all registered prompts
  - 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

类 McpAsyncServer

方法概要

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

方法详细资料

getServerCapabilities

getServerInfo

closeGracefully

close

addTool

listTools

removeTool

notifyToolsListChanged

addResource

listResources

removeResource

addResourceTemplate

listResourceTemplates

removeResourceTemplate

notifyResourcesListChanged

notifyResourcesUpdated

addPrompt

listPrompts

removePrompt

notifyPromptsListChanged

loggingNotification