io.modelcontextprotocol.spec

类 DefaultMcpSession

java.lang.Object

io.modelcontextprotocol.spec.DefaultMcpSession

所有已实现的接口:

McpSession

已过时。

This method will be removed in 0.9.0. Use McpClientSession instead

@Deprecated
public class DefaultMcpSession
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	DefaultMcpSession.MethodNotFoundError 已过时。
static interface	DefaultMcpSession.NotificationHandler 已过时。 Functional interface for handling incoming JSON-RPC notifications.
static interface	DefaultMcpSession.RequestHandler<T> 已过时。 Functional interface for handling incoming JSON-RPC requests.

构造器概要

构造器

构造器和说明
DefaultMcpSession(java.time.Duration requestTimeout, McpTransport transport, java.util.Map<java.lang.String,DefaultMcpSession.RequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,DefaultMcpSession.NotificationHandler> notificationHandlers) 已过时。 Creates a new DefaultMcpSession 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.
static DefaultMcpSession.MethodNotFoundError	getMethodNotFoundError(java.lang.String method) 已过时。
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

从接口继承的方法 io.modelcontextprotocol.spec.McpSession

sendNotification

构造器详细资料

DefaultMcpSession

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

已过时。

Creates a new DefaultMcpSession 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

方法详细资料

getMethodNotFoundError

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

已过时。

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,
                                                                    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