io.modelcontextprotocol.spec

类 McpServerSession

java.lang.Object

io.modelcontextprotocol.spec.McpServerSession

所有已实现的接口:

McpLoggableSession, McpSession

public class McpServerSession
extends java.lang.Object
implements McpLoggableSession

Represents a Model Context Protocol (MCP) session on the server side. It manages bidirectional JSON-RPC communication with the client.

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	McpServerSession.Factory Factory for creating server sessions which delegate to a provided 1:1 transport with a connected client.
static interface	McpServerSession.InitNotificationHandler Notification handler for the initialization notification from the client.
static interface	McpServerSession.InitRequestHandler 已过时。 Use McpInitRequestHandler
static class	McpServerSession.MethodNotFoundError
static interface	McpServerSession.NotificationHandler 已过时。 Use McpNotificationHandler
static interface	McpServerSession.RequestHandler<T> 已过时。 Use McpRequestHandler

构造器概要

构造器

构造器和说明
McpServerSession(java.lang.String id, java.time.Duration requestTimeout, McpServerTransport transport, McpInitRequestHandler initHandler, java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers) Creates a new server session with the given parameters and the transport to use.
McpServerSession(java.lang.String id, java.time.Duration requestTimeout, McpServerTransport transport, McpInitRequestHandler initHandler, McpServerSession.InitNotificationHandler initNotificationHandler, java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers) 已过时。 Use McpServerSession(String, Duration, McpServerTransport, McpInitRequestHandler, Map, Map)

方法概要

限定符和类型	方法和说明
void	close() Closes the session and releases any associated resources.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the session and releases any associated resources asynchronously.
java.lang.String	getId() Retrieve the session id.
reactor.core.publisher.Mono<java.lang.Void>	handle(McpSchema.JSONRPCMessage message) Called by the McpServerTransportProvider once the session is determined.
void	init(McpSchema.ClientCapabilities clientCapabilities, McpSchema.Implementation clientInfo) Called upon successful initialization sequence between the client and the server with the client capabilities and information.
boolean	isNotificationForLevelAllowed(McpSchema.LoggingLevel loggingLevel) Allows checking whether a particular logging level is allowed.
reactor.core.publisher.Mono<java.lang.Void>	sendNotification(java.lang.String method, java.lang.Object params) Sends a notification to the model client or server with parameters.
<T> reactor.core.publisher.Mono<T>	sendRequest(java.lang.String method, java.lang.Object requestParams, TypeRef<T> typeRef) Sends a request to the model counterparty and expects a response of type T.
void	setMinLoggingLevel(McpSchema.LoggingLevel minLoggingLevel) Set the minimum logging level for the client.

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

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

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

sendNotification

构造器详细资料

McpServerSession

public McpServerSession(java.lang.String id,
                        java.time.Duration requestTimeout,
                        McpServerTransport transport,
                        McpInitRequestHandler initHandler,
                        java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers,
                        java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers)

Creates a new server session with the given parameters and the transport to use.

参数:

id - session id

transport - the transport to use

initHandler - called when a McpSchema.InitializeRequest is received by the server

requestHandlers - map of request handlers to use

notificationHandlers - map of notification handlers to use

McpServerSession

@Deprecated
public McpServerSession(java.lang.String id,
                                    java.time.Duration requestTimeout,
                                    McpServerTransport transport,
                                    McpInitRequestHandler initHandler,
                                    McpServerSession.InitNotificationHandler initNotificationHandler,
                                    java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers,
                                    java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers)

已过时。 Use McpServerSession(String, Duration, McpServerTransport, McpInitRequestHandler, Map, Map)

Creates a new server session with the given parameters and the transport to use.

参数:

id - session id

transport - the transport to use

initHandler - called when a McpSchema.InitializeRequest is received by the server

initNotificationHandler - called when a McpSchema.METHOD_NOTIFICATION_INITIALIZED is received.

requestHandlers - map of request handlers to use

notificationHandlers - map of notification handlers to use

方法详细资料

getId

public java.lang.String getId()

Retrieve the session id.

返回:

session id

init

public void init(McpSchema.ClientCapabilities clientCapabilities,
                 McpSchema.Implementation clientInfo)

Called upon successful initialization sequence between the client and the server with the client capabilities and information. Initialization Spec

参数:

clientCapabilities - the capabilities the connected client provides

clientInfo - the information about the connected client

setMinLoggingLevel

public void setMinLoggingLevel(McpSchema.LoggingLevel minLoggingLevel)

从接口复制的说明: McpLoggableSession

Set the minimum logging level for the client. Messages below this level will be filtered out.

指定者:

setMinLoggingLevel 在接口中 McpLoggableSession

参数:

minLoggingLevel - The minimum logging level

isNotificationForLevelAllowed

public boolean isNotificationForLevelAllowed(McpSchema.LoggingLevel loggingLevel)

从接口复制的说明: McpLoggableSession

Allows checking whether a particular logging level is allowed.

指定者:

isNotificationForLevelAllowed 在接口中 McpLoggableSession

参数:

loggingLevel - the level to check

返回:

whether the logging at the specified level is permitted.

sendRequest

public <T> reactor.core.publisher.Mono<T> sendRequest(java.lang.String method,
                                                      java.lang.Object requestParams,
                                                      TypeRef<T> typeRef)

从接口复制的说明: McpSession

Sends a request to the model counterparty and expects a response of type T.

This method handles the request-response pattern where a response is expected from the client or server. The response type is determined by the provided TypeReference.

指定者:

sendRequest 在接口中 McpSession

类型参数:

T - the type of the expected response

参数:

method - the name of the method to be called on the counterparty

requestParams - the parameters to be sent with the request

typeRef - the TypeReference describing the expected response type

返回:

a Mono that will emit the response when received

sendNotification

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

从接口复制的说明: McpSession

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

Similar to McpSession.sendNotification(String) but allows sending additional parameters with the notification.

指定者:

sendNotification 在接口中 McpSession

参数:

method - the name of the notification method to be sent to the counterparty

params - parameters to be sent with the notification

返回:

a Mono that completes when the notification has been sent

handle

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

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.

参数:

message - the incoming JSON-RPC message

返回:

a Mono that completes when the message is processed

closeGracefully

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

从接口复制的说明: McpSession

Closes the session and releases any associated resources asynchronously.

指定者:

closeGracefully 在接口中 McpSession

返回:

a Mono that completes when the session has been closed.

close

public void close()

从接口复制的说明: McpSession

Closes the session and releases any associated resources.

指定者:

close 在接口中 McpSession