io.modelcontextprotocol.spec

类 McpStreamableServerSession

java.lang.Object

io.modelcontextprotocol.spec.McpStreamableServerSession

所有已实现的接口:

McpLoggableSession, McpSession

public class McpStreamableServerSession
extends java.lang.Object
implements McpLoggableSession

Representation of a Streamable HTTP server session that keeps track of mapping server-initiated requests to the client and mapping arriving responses. It also allows handling incoming notifications. For requests, it provides the default SSE streaming capability without the insight into the transport-specific details of HTTP handling.

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	McpStreamableServerSession.Factory Factory for new Streamable HTTP MCP sessions.
static interface	McpStreamableServerSession.InitRequestHandler Request handler for the initialization request.
static class	McpStreamableServerSession.McpStreamableServerSessionInit Composite holding the McpStreamableServerSession and the initialization result
class	McpStreamableServerSession.McpStreamableServerSessionStream An individual SSE stream within a Streamable HTTP context.
static class	McpStreamableServerSession.MethodNotFoundError

构造器概要

构造器

构造器和说明
McpStreamableServerSession(java.lang.String id, McpSchema.ClientCapabilities clientCapabilities, McpSchema.Implementation clientInfo, java.time.Duration requestTimeout, java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers, java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers) Create an instance of the streamable session.

方法概要

限定符和类型	方法和说明
reactor.core.publisher.Mono<java.lang.Void>	accept(McpSchema.JSONRPCNotification notification) Handle the MCP notification.
reactor.core.publisher.Mono<java.lang.Void>	accept(McpSchema.JSONRPCResponse response) Handle the MCP response.
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.
reactor.core.publisher.Mono<java.lang.Void>	delete()
java.lang.String	getId() Return the Session ID.
boolean	isNotificationForLevelAllowed(McpSchema.LoggingLevel loggingLevel) Allows checking whether a particular logging level is allowed.
McpStreamableServerSession.McpStreamableServerSessionStream	listeningStream(McpStreamableServerTransport transport) Create a listening stream (the generic HTTP GET request without Last-Event-ID header).
reactor.core.publisher.Flux<McpSchema.JSONRPCMessage>	replay(java.lang.Object lastEventId)
reactor.core.publisher.Mono<java.lang.Void>	responseStream(McpSchema.JSONRPCRequest jsonrpcRequest, McpStreamableServerTransport transport) Provide the SSE stream of MCP messages finalized with a Response.
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

构造器详细资料

McpStreamableServerSession

public McpStreamableServerSession(java.lang.String id,
                                  McpSchema.ClientCapabilities clientCapabilities,
                                  McpSchema.Implementation clientInfo,
                                  java.time.Duration requestTimeout,
                                  java.util.Map<java.lang.String,McpRequestHandler<?>> requestHandlers,
                                  java.util.Map<java.lang.String,McpNotificationHandler> notificationHandlers)

Create an instance of the streamable session.

参数:

id - session ID

clientCapabilities - client capabilities

clientInfo - client info

requestTimeout - timeout to use for requests

requestHandlers - the map of MCP request handlers keyed by method name

notificationHandlers - the map of MCP notification handlers keyed by method name

方法详细资料

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.

getId

public java.lang.String getId()

Return the Session ID.

返回:

session ID

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

delete

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

listeningStream

public McpStreamableServerSession.McpStreamableServerSessionStream listeningStream(McpStreamableServerTransport transport)

Create a listening stream (the generic HTTP GET request without Last-Event-ID header).

参数:

transport - The dedicated SSE transport stream

返回:

a stream representation

replay

public reactor.core.publisher.Flux<McpSchema.JSONRPCMessage> replay(java.lang.Object lastEventId)

responseStream

public reactor.core.publisher.Mono<java.lang.Void> responseStream(McpSchema.JSONRPCRequest jsonrpcRequest,
                                                                  McpStreamableServerTransport transport)

Provide the SSE stream of MCP messages finalized with a Response.

参数:

jsonrpcRequest - the MCP request triggering the stream creation

transport - the SSE transport stream to send messages to

返回:

Mono which completes once the processing is done

accept

public reactor.core.publisher.Mono<java.lang.Void> accept(McpSchema.JSONRPCNotification notification)

Handle the MCP notification.

参数:

notification - MCP notification

返回:

Mono which completes upon succesful handling

accept

public reactor.core.publisher.Mono<java.lang.Void> accept(McpSchema.JSONRPCResponse response)

Handle the MCP response.

参数:

response - MCP response to the server-initiated request

返回:

Mono which completes upon successful processing

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