io.modelcontextprotocol.server

类 McpAsyncServerExchange

java.lang.Object

io.modelcontextprotocol.server.McpAsyncServerExchange

public class McpAsyncServerExchange
extends java.lang.Object

Represents an asynchronous exchange with a Model Context Protocol (MCP) client. The exchange provides methods to interact with the client and query its capabilities.

字段概要

字段

限定符和类型	字段和说明
static com.fasterxml.jackson.core.type.TypeReference<java.lang.Object>	OBJECT_TYPE_REF

构造器概要

构造器

构造器和说明
McpAsyncServerExchange(McpSession session, McpSchema.ClientCapabilities clientCapabilities, McpSchema.Implementation clientInfo) 已过时。 Use McpAsyncServerExchange(String, McpLoggableSession, McpSchema.ClientCapabilities, McpSchema.Implementation, McpTransportContext)
McpAsyncServerExchange(java.lang.String sessionId, McpLoggableSession session, McpSchema.ClientCapabilities clientCapabilities, McpSchema.Implementation clientInfo, McpTransportContext transportContext) Create a new asynchronous exchange with the client.

方法概要

限定符和类型	方法和说明
reactor.core.publisher.Mono<McpSchema.ElicitResult>	createElicitation(McpSchema.ElicitRequest elicitRequest) Creates a new elicitation.
reactor.core.publisher.Mono<McpSchema.CreateMessageResult>	createMessage(McpSchema.CreateMessageRequest createMessageRequest) Create a new message using the sampling capabilities of the client.
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.ListRootsResult>	listRoots() Retrieves the list of all roots provided by the client.
reactor.core.publisher.Mono<McpSchema.ListRootsResult>	listRoots(java.lang.String cursor) Retrieves a paginated list of roots provided by the client.
reactor.core.publisher.Mono<java.lang.Void>	loggingNotification(McpSchema.LoggingMessageNotification loggingMessageNotification) Send a logging message notification to the client.
reactor.core.publisher.Mono<java.lang.Object>	ping() Sends a ping request to the client.
reactor.core.publisher.Mono<java.lang.Void>	progressNotification(McpSchema.ProgressNotification progressNotification) Sends a notification to the client that the current progress status has changed for long-running operations.
java.lang.String	sessionId() Provides the Session ID.
McpTransportContext	transportContext() Provides the McpTransportContext associated with the transport layer.

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

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

字段详细资料

OBJECT_TYPE_REF

public static final com.fasterxml.jackson.core.type.TypeReference<java.lang.Object> OBJECT_TYPE_REF

构造器详细资料

McpAsyncServerExchange

@Deprecated
public McpAsyncServerExchange(McpSession session,
                                          McpSchema.ClientCapabilities clientCapabilities,
                                          McpSchema.Implementation clientInfo)

已过时。 Use McpAsyncServerExchange(String, McpLoggableSession, McpSchema.ClientCapabilities, McpSchema.Implementation, McpTransportContext)

Create a new asynchronous exchange with the client.

参数:

session - The server session representing a 1-1 interaction.

clientCapabilities - The client capabilities that define the supported features and functionality.

clientInfo - The client implementation information.

McpAsyncServerExchange

public McpAsyncServerExchange(java.lang.String sessionId,
                              McpLoggableSession session,
                              McpSchema.ClientCapabilities clientCapabilities,
                              McpSchema.Implementation clientInfo,
                              McpTransportContext transportContext)

Create a new asynchronous exchange with the client.

参数:

session - The server session representing a 1-1 interaction.

clientCapabilities - The client capabilities that define the supported features and functionality.

clientInfo - The client implementation information.

transportContext - context associated with the client as extracted from the transport

方法详细资料

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

transportContext

public McpTransportContext transportContext()

Provides the McpTransportContext associated with the transport layer. For HTTP transports it can contain the metadata associated with the HTTP request that triggered the processing.

返回:

the transport context object

sessionId

public java.lang.String sessionId()

Provides the Session ID.

返回:

session ID string

createMessage

public reactor.core.publisher.Mono<McpSchema.CreateMessageResult> createMessage(McpSchema.CreateMessageRequest 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

另请参阅:

McpSchema.CreateMessageRequest, McpSchema.CreateMessageResult, Sampling Specification

createElicitation

public reactor.core.publisher.Mono<McpSchema.ElicitResult> createElicitation(McpSchema.ElicitRequest elicitRequest)

Creates a new elicitation. MCP provides a standardized way for servers to request additional information from users through the client during interactions. This flow allows clients to maintain control over user interactions and data sharing while enabling servers to gather necessary information dynamically. Servers can request structured data from users with optional JSON schemas to validate responses.

参数:

elicitRequest - The request to create a new elicitation

返回:

A Mono that completes when the elicitation has been resolved.

另请参阅:

McpSchema.ElicitRequest, McpSchema.ElicitResult, Elicitation Specification

listRoots

public reactor.core.publisher.Mono<McpSchema.ListRootsResult> listRoots()

Retrieves the list of all roots provided by the client.

返回:

A Mono that emits the list of roots result.

listRoots

public reactor.core.publisher.Mono<McpSchema.ListRootsResult> listRoots(java.lang.String cursor)

Retrieves a paginated list of roots provided by the client.

参数:

cursor - Optional pagination cursor from a previous list request

返回:

A Mono that emits the list of roots result containing

loggingNotification

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

Send a logging message notification to the client. 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

progressNotification

public reactor.core.publisher.Mono<java.lang.Void> progressNotification(McpSchema.ProgressNotification progressNotification)

Sends a notification to the client that the current progress status has changed for long-running operations.

参数:

progressNotification - The progress notification to send

返回:

A Mono that completes when the notification has been sent

ping

public reactor.core.publisher.Mono<java.lang.Object> ping()

Sends a ping request to the client.

返回:

A Mono that completes with clients's ping response