McpAsyncClient

java.lang.Object
- io.modelcontextprotocol.client.McpAsyncClient

```
public class McpAsyncClient
extends java.lang.Object
```
The Model Context Protocol (MCP) client implementation that provides asynchronous communication with MCP servers using Project Reactor's Mono and Flux types.
This client implements the MCP specification, enabling AI models to interact with external tools and resources through a standardized interface. Key features include:
- Asynchronous communication using reactive programming patterns
- Tool discovery and invocation for server-provided functionality
- Resource access and management with URI-based addressing
- Prompt template handling for standardized AI interactions
- Real-time notifications for tools, resources, and prompts changes
- Structured logging with configurable severity levels
- Message sampling for AI model interactions
The client follows a lifecycle:
1. Initialization - Establishes connection and negotiates capabilities
2. Normal Operation - Handles requests and 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.
另请参阅:

McpClient, McpSchema, McpClientSession

字段概要

字段
限定符和类型字段和说明

protected reactor.core.publisher.Sinks.One<McpSchema.InitializeResult> initializedSink

字段
限定符和类型	字段和说明
`protected reactor.core.publisher.Sinks.One<McpSchema.InitializeResult>`	`initializedSink`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`reactor.core.publisher.Mono<java.lang.Void>`	`addRoot(McpSchema.Root root)` Adds a new root to the client's root list.
`reactor.core.publisher.Mono<McpSchema.CallToolResult>`	`callTool(McpSchema.CallToolRequest callToolRequest)` Calls a tool provided by the server.
`void`	`close()` Closes the client connection immediately.
`reactor.core.publisher.Mono<java.lang.Void>`	`closeGracefully()` Gracefully closes the client connection.
`McpSchema.ClientCapabilities`	`getClientCapabilities()` Get the client capabilities that define the supported features and functionality.
`McpSchema.Implementation`	`getClientInfo()` Get the client implementation information.
`reactor.core.publisher.Mono<McpSchema.GetPromptResult>`	`getPrompt(McpSchema.GetPromptRequest getPromptRequest)` Retrieves a specific prompt by its ID.
`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.InitializeResult>`	`initialize()` The initialization phase MUST be the first interaction between client and server.
`boolean`	`isInitialized()` Check if the client-server connection is initialized.
`reactor.core.publisher.Mono<McpSchema.ListPromptsResult>`	`listPrompts()` Retrieves the list of all prompts provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListPromptsResult>`	`listPrompts(java.lang.String cursor)` Retrieves a paginated list of prompts provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListResourcesResult>`	`listResources()` Retrieves the list of all resources provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListResourcesResult>`	`listResources(java.lang.String cursor)` Retrieves a paginated list of resources provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListResourceTemplatesResult>`	`listResourceTemplates()` Retrieves the list of all resource templates provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListResourceTemplatesResult>`	`listResourceTemplates(java.lang.String cursor)` Retrieves a paginated list of resource templates provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListToolsResult>`	`listTools()` Retrieves the list of all tools provided by the server.
`reactor.core.publisher.Mono<McpSchema.ListToolsResult>`	`listTools(java.lang.String cursor)` Retrieves a paginated list of tools provided by the server.
`void`	`openSSE()` The client may issue an HTTP GET to the MCP endpoint.
`reactor.core.publisher.Mono<java.lang.Object>`	`ping()` Sends a ping request to the server.
`reactor.core.publisher.Mono<McpSchema.ReadResourceResult>`	`readResource(McpSchema.ReadResourceRequest readResourceRequest)` Reads the content of a specific resource identified by the provided request.
`reactor.core.publisher.Mono<McpSchema.ReadResourceResult>`	`readResource(McpSchema.Resource resource)` Reads the content of a specific resource identified by the provided Resource object.
`reactor.core.publisher.Mono<java.lang.Void>`	`removeRoot(java.lang.String rootUri)` Removes a root from the client's root list.
`reactor.core.publisher.Mono<java.lang.Void>`	`rootsListChangedNotification()` Manually sends a roots/list_changed notification.
`reactor.core.publisher.Mono<java.lang.Void>`	`setLoggingLevel(McpSchema.LoggingLevel loggingLevel)` Sets the minimum logging level for messages received from the server.
`reactor.core.publisher.Mono<java.lang.Void>`	`subscribeResource(McpSchema.SubscribeRequest subscribeRequest)` Subscribes to changes in a specific resource.
`reactor.core.publisher.Mono<java.lang.Void>`	`unsubscribeResource(McpSchema.UnsubscribeRequest unsubscribeRequest)` Cancels an existing subscription to a resource.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - initializedSink
```
protected final reactor.core.publisher.Sinks.One<McpSchema.InitializeResult> initializedSink
```
- 方法详细资料
  - 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
  - isInitialized
```
public boolean isInitialized()
```
    Check if the client-server connection is initialized.
    
    返回:
    
    true if the client-server connection is initialized
  - getClientCapabilities
```
public McpSchema.ClientCapabilities getClientCapabilities()
```
    Get the client capabilities that define the supported features and functionality.
    
    返回:
    
    The client capabilities
  - getClientInfo
```
public McpSchema.Implementation getClientInfo()
```
    Get the client implementation information.
    
    返回:
    
    The client implementation details
  - close
```
public void close()
```
    Closes the client connection immediately.
  - closeGracefully
```
public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
```
    Gracefully closes the client connection.
    
    返回:
    
    A Mono that completes when the connection is closed
  - openSSE
```
public void openSSE()
```
    The client may issue an HTTP GET to the MCP endpoint. This can be used to open an SSE stream, allowing the server to communicate to the client, without the client first sending data via HTTP POST.
  - initialize
```
public reactor.core.publisher.Mono<McpSchema.InitializeResult> initialize()
```
    The initialization phase MUST be the first interaction between client and server. During this phase, the client and server:
    - Establish protocol version compatibility
    - Exchange and negotiate capabilities
    - Share implementation details
    The client MUST initiate this phase by sending an initialize request containing: The protocol version the client supports, client's capabilities and clients implementation information.
    The server MUST respond with its own capabilities and information.
    After successful initialization, the client MUST send an initialized notification to indicate it is ready to begin normal operations.
    返回:
    
    the initialize result.
    
    另请参阅:
    
    MCP Initialization Spec
  - ping
```
public reactor.core.publisher.Mono<java.lang.Object> ping()
```
    Sends a ping request to the server.
    
    返回:
    
    A Mono that completes with the server's ping response
  - addRoot
```
public reactor.core.publisher.Mono<java.lang.Void> addRoot(McpSchema.Root root)
```
    Adds a new root to the client's root list.
    
    参数:
    
    root - The root to add.
    
    返回:
    
    A Mono that completes when the root is added and notifications are sent.
  - removeRoot
```
public reactor.core.publisher.Mono<java.lang.Void> removeRoot(java.lang.String rootUri)
```
    Removes a root from the client's root list.
    
    参数:
    
    rootUri - The URI of the root to remove.
    
    返回:
    
    A Mono that completes when the root is removed and notifications are sent.
  - rootsListChangedNotification
```
public reactor.core.publisher.Mono<java.lang.Void> rootsListChangedNotification()
```
    Manually sends a roots/list_changed notification. The addRoot and removeRoot methods automatically send the roots/list_changed notification if the client is in an initialized state.
    
    返回:
    
    A Mono that completes when the notification is sent.
  - callTool
```
public reactor.core.publisher.Mono<McpSchema.CallToolResult> callTool(McpSchema.CallToolRequest callToolRequest)
```
    Calls a tool provided by the server. Tools enable servers to expose executable functionality that can interact with external systems, perform computations, and take actions in the real world.
    
    参数:
    
    callToolRequest - The request containing the tool name and input parameters.
    
    返回:
    
    A Mono that emits the result of the tool call, including the output and any errors.
    
    另请参阅:
    
    McpSchema.CallToolRequest, McpSchema.CallToolResult, listTools()
  - listTools
```
public reactor.core.publisher.Mono<McpSchema.ListToolsResult> listTools()
```
    Retrieves the list of all tools provided by the server.
    
    返回:
    
    A Mono that emits the list of tools result.
  - listTools
```
public reactor.core.publisher.Mono<McpSchema.ListToolsResult> listTools(java.lang.String cursor)
```
    Retrieves a paginated list of tools provided by the server.
    
    参数:
    
    cursor - Optional pagination cursor from a previous list request
    
    返回:
    
    A Mono that emits the list of tools result
  - listResources
```
public reactor.core.publisher.Mono<McpSchema.ListResourcesResult> listResources()
```
    Retrieves the list of all resources provided by the server. Resources represent any kind of UTF-8 encoded data that an MCP server makes available to clients, such as database records, API responses, log files, and more.
    
    返回:
    
    A Mono that completes with the list of resources result.
    
    另请参阅:
    
    McpSchema.ListResourcesResult, readResource(McpSchema.Resource)
  - listResources
```
public reactor.core.publisher.Mono<McpSchema.ListResourcesResult> listResources(java.lang.String cursor)
```
    Retrieves a paginated list of resources provided by the server. Resources represent any kind of UTF-8 encoded data that an MCP server makes available to clients, such as database records, API responses, log files, and more.
    
    参数:
    
    cursor - Optional pagination cursor from a previous list request.
    
    返回:
    
    A Mono that completes with the list of resources result.
    
    另请参阅:
    
    McpSchema.ListResourcesResult, readResource(McpSchema.Resource)
  - readResource
```
public reactor.core.publisher.Mono<McpSchema.ReadResourceResult> readResource(McpSchema.Resource resource)
```
    Reads the content of a specific resource identified by the provided Resource object. This method fetches the actual data that the resource represents.
    
    参数:
    
    resource - The resource to read, containing the URI that identifies the resource.
    
    返回:
    
    A Mono that completes with the resource content.
    
    另请参阅:
    
    McpSchema.Resource, McpSchema.ReadResourceResult
  - readResource
```
public reactor.core.publisher.Mono<McpSchema.ReadResourceResult> readResource(McpSchema.ReadResourceRequest readResourceRequest)
```
    Reads the content of a specific resource identified by the provided request. This method fetches the actual data that the resource represents.
    
    参数:
    
    readResourceRequest - The request containing the URI of the resource to read
    
    返回:
    
    A Mono that completes with the resource content.
    
    另请参阅:
    
    McpSchema.ReadResourceRequest, McpSchema.ReadResourceResult
  - listResourceTemplates
```
public reactor.core.publisher.Mono<McpSchema.ListResourceTemplatesResult> listResourceTemplates()
```
    Retrieves the list of all resource templates provided by the server. Resource templates allow servers to expose parameterized resources using URI templates, enabling dynamic resource access based on variable parameters.
    
    返回:
    
    A Mono that completes with the list of resource templates result.
    
    另请参阅:
    
    McpSchema.ListResourceTemplatesResult
  - listResourceTemplates
```
public reactor.core.publisher.Mono<McpSchema.ListResourceTemplatesResult> listResourceTemplates(java.lang.String cursor)
```
    Retrieves a paginated list of resource templates provided by the server. Resource templates allow servers to expose parameterized resources using URI templates, enabling dynamic resource access based on variable parameters.
    
    参数:
    
    cursor - Optional pagination cursor from a previous list request.
    
    返回:
    
    A Mono that completes with the list of resource templates result.
    
    另请参阅:
    
    McpSchema.ListResourceTemplatesResult
  - subscribeResource
```
public reactor.core.publisher.Mono<java.lang.Void> subscribeResource(McpSchema.SubscribeRequest subscribeRequest)
```
    Subscribes to changes in a specific resource. When the resource changes on the server, the client will receive notifications through the resources change notification handler.
    
    参数:
    
    subscribeRequest - The subscribe request containing the URI of the resource.
    
    返回:
    
    A Mono that completes when the subscription is complete.
    
    另请参阅:
    
    McpSchema.SubscribeRequest, unsubscribeResource(McpSchema.UnsubscribeRequest)
  - unsubscribeResource
```
public reactor.core.publisher.Mono<java.lang.Void> unsubscribeResource(McpSchema.UnsubscribeRequest unsubscribeRequest)
```
    Cancels an existing subscription to a resource. After unsubscribing, the client will no longer receive notifications when the resource changes.
    
    参数:
    
    unsubscribeRequest - The unsubscribe request containing the URI of the resource.
    
    返回:
    
    A Mono that completes when the unsubscription is complete.
    
    另请参阅:
    
    McpSchema.UnsubscribeRequest, subscribeResource(McpSchema.SubscribeRequest)
  - listPrompts
```
public reactor.core.publisher.Mono<McpSchema.ListPromptsResult> listPrompts()
```
    Retrieves the list of all prompts provided by the server.
    
    返回:
    
    A Mono that completes with the list of prompts result.
    
    另请参阅:
    
    McpSchema.ListPromptsResult, #getPrompt(GetPromptRequest)
  - listPrompts
```
public reactor.core.publisher.Mono<McpSchema.ListPromptsResult> listPrompts(java.lang.String cursor)
```
    Retrieves a paginated list of prompts provided by the server.
    
    参数:
    
    cursor - Optional pagination cursor from a previous list request
    
    返回:
    
    A Mono that completes with the list of prompts result.
    
    另请参阅:
    
    McpSchema.ListPromptsResult, #getPrompt(GetPromptRequest)
  - getPrompt
```
public reactor.core.publisher.Mono<McpSchema.GetPromptResult> getPrompt(McpSchema.GetPromptRequest getPromptRequest)
```
    Retrieves a specific prompt by its ID. This provides the complete prompt template including all parameters and instructions for generating AI content.
    
    参数:
    
    getPromptRequest - The request containing the ID of the prompt to retrieve.
    
    返回:
    
    A Mono that completes with the prompt result.
    
    另请参阅:
    
    McpSchema.GetPromptRequest, McpSchema.GetPromptResult, listPrompts()
  - setLoggingLevel
```
public reactor.core.publisher.Mono<java.lang.Void> setLoggingLevel(McpSchema.LoggingLevel loggingLevel)
```
    Sets the minimum logging level for messages received from the server. The client will only receive log messages at or above the specified severity level.
    
    参数:
    
    loggingLevel - The minimum logging level to receive.
    
    返回:
    
    A Mono that completes when the logging level is set.
    
    另请参阅:
    
    McpSchema.LoggingLevel

类 McpAsyncClient

字段概要

方法概要

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

字段详细资料

initializedSink

方法详细资料

getServerCapabilities

getServerInfo

isInitialized

getClientCapabilities

getClientInfo

close

closeGracefully

openSSE

initialize

ping

addRoot

removeRoot

rootsListChangedNotification

callTool

listTools

listTools

listResources

listResources

readResource

readResource

listResourceTemplates

listResourceTemplates

subscribeResource

unsubscribeResource

listPrompts

listPrompts

getPrompt

setLoggingLevel