io.modelcontextprotocol.spec

类 McpClientSession

java.lang.Object

io.modelcontextprotocol.spec.McpClientSession

所有已实现的接口:

McpSession

public class McpClientSession
extends java.lang.Object
implements McpSession

Default implementation of the MCP (Model Context Protocol) session that manages bidirectional JSON-RPC communication between clients and servers. This implementation follows the MCP specification for message exchange and transport handling.

The session manages:

• Request/response handling with unique message IDs
• Notification processing
• Message timeout management
• Transport layer abstraction

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	McpClientSession.MethodNotFoundError
static interface	McpClientSession.NotificationHandler Functional interface for handling incoming JSON-RPC notifications.
static interface	McpClientSession.RequestHandler<T> Functional interface for handling incoming JSON-RPC requests.

构造器概要

构造器

构造器和说明
McpClientSession(java.time.Duration requestTimeout, McpClientTransport transport, java.util.Map<java.lang.String,McpClientSession.RequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,McpClientSession.NotificationHandler> notificationHandlers) Creates a new McpClientSession with the specified configuration and handlers.

方法概要

限定符和类型	方法和说明
void	close() Closes the session immediately, potentially interrupting pending operations.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the session gracefully, allowing pending operations to complete.
java.lang.String	getId() Retrieve the session id.
static McpClientSession.MethodNotFoundError	getMethodNotFoundError(java.lang.String method)
reactor.core.publisher.Mono<java.lang.Void>	handle(McpSchema.JSONRPCMessage message) Called by the McpServerTransportProvider once the session is determined.
void	openSSE() The client may issue an HTTP GET to the MCP endpoint.
reactor.core.publisher.Mono<java.lang.Void>	sendNotification(java.lang.String method) Sends a notification to the model client or server without parameters.
reactor.core.publisher.Mono<java.lang.Void>	sendNotification(java.lang.String method, java.util.Map<java.lang.String,java.lang.Object> params) Sends a JSON-RPC notification.
<T> reactor.core.publisher.Mono<T>	sendRequest(java.lang.String method, java.lang.Object requestParams, com.fasterxml.jackson.core.type.TypeReference<T> typeRef) Sends a JSON-RPC request and returns the response.

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

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

构造器详细资料

McpClientSession

public McpClientSession(java.time.Duration requestTimeout,
                        McpClientTransport transport,
                        java.util.Map<java.lang.String,McpClientSession.RequestHandler<?>> requestHandlers,
                        java.util.Map<java.lang.String,McpClientSession.NotificationHandler> notificationHandlers)

Creates a new McpClientSession with the specified configuration and handlers.

参数:

requestTimeout - Duration to wait for responses

transport - Transport implementation for message exchange

requestHandlers - Map of method names to request handlers

notificationHandlers - Map of method names to notification handlers

方法详细资料

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.

getMethodNotFoundError

public static McpClientSession.MethodNotFoundError getMethodNotFoundError(java.lang.String method)

getId

public java.lang.String getId()

从接口复制的说明: McpSession

Retrieve the session id.

指定者:

getId 在接口中 McpSession

返回:

session id

handle

public reactor.core.publisher.Mono<java.lang.Void> handle(McpSchema.JSONRPCMessage message)

从接口复制的说明: McpSession

Called by the McpServerTransportProvider once the session is determined. The purpose of this method is to dispatch the message to an appropriate handler as specified by the MCP server implementation (McpAsyncServer or McpSyncServer) via McpServerSession.Factory that the server creates.

指定者:

handle 在接口中 McpSession

参数:

message - the incoming JSON-RPC message

返回:

a Mono that completes when the message is processed

sendRequest

public <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String method,
                                                      java.lang.Object requestParams,
                                                      com.fasterxml.jackson.core.type.TypeReference<T> typeRef)

Sends a JSON-RPC request and returns the response.

指定者:

sendRequest 在接口中 McpSession

类型参数:

T - The expected response type

参数:

method - The method name to call

requestParams - The request parameters

typeRef - Type reference for response deserialization

返回:

A Mono containing the response

sendNotification

public reactor.core.publisher.Mono<java.lang.Void> sendNotification(java.lang.String method)

从接口复制的说明: McpSession

Sends a notification to the model client or server without parameters.

This method implements the notification pattern where no response is expected from the counterparty. It's useful for fire-and-forget scenarios.

指定者:

sendNotification 在接口中 McpSession

参数:

method - the name of the notification method to be called on the server

返回:

a Mono that completes when the notification has been sent

sendNotification

public reactor.core.publisher.Mono<java.lang.Void> sendNotification(java.lang.String method,
                                                                    java.util.Map<java.lang.String,java.lang.Object> params)

Sends a JSON-RPC notification.

指定者:

sendNotification 在接口中 McpSession

参数:

method - The method name for the notification

params - The notification parameters

返回:

A Mono that completes when the notification is sent

closeGracefully

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

Closes the session gracefully, allowing pending operations to complete.

指定者:

closeGracefully 在接口中 McpSession

返回:

A Mono that completes when the session is closed

close

public void close()

Closes the session immediately, potentially interrupting pending operations.

指定者:

close 在接口中 McpSession