io.modelcontextprotocol.spec

接口 McpStreamableServerTransportProvider

所有超级接口:

McpServerTransportProviderBase

所有已知实现类:

WebRxStreamableServerTransportProvider

public interface McpStreamableServerTransportProvider
extends McpServerTransportProviderBase

The core building block providing the server-side MCP transport for Streamable HTTP servers. Implement this interface to bridge between a particular server-side technology and the MCP server transport layer.

The lifecycle of the provider dictates that it be created first, upon application startup, and then passed into either McpServer.sync(McpStreamableServerTransportProvider) or McpServer.async(McpStreamableServerTransportProvider). As a result of the MCP server creation, the provider will be notified of a McpStreamableServerSession.Factory which will be used to handle a 1:1 communication between a newly connected client and the server using a session concept. The provider's responsibility is to create instances of McpStreamableServerTransport that the session will utilise during the session lifetime.

Finally, the McpStreamableServerTransports can be closed in bulk when close() or closeGracefully() are called as part of the normal application shutdown event. Individual McpStreamableServerTransports can also be closed on a per-session basis, where the McpServerSession.close() or McpServerSession.closeGracefully() closes the provided transport.

方法概要

限定符和类型	方法和说明
default void	close() Immediately closes all the transports with connected clients and releases any associated resources.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Gracefully closes all the transports with connected clients and releases any associated resources asynchronously.
reactor.core.publisher.Mono<java.lang.Void>	notifyClients(java.lang.String method, java.lang.Object params) Sends a notification to all connected clients.
void	setSessionFactory(McpStreamableServerSession.Factory sessionFactory) Sets the session factory that will be used to create sessions for new clients.

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

protocolVersions

方法详细资料

setSessionFactory

void setSessionFactory(McpStreamableServerSession.Factory sessionFactory)

Sets the session factory that will be used to create sessions for new clients. An implementation of the MCP server MUST call this method before any MCP interactions take place.

参数:

sessionFactory - the session factory to be used for initiating client sessions

notifyClients

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

Sends a notification to all connected clients.

指定者:

notifyClients 在接口中 McpServerTransportProviderBase

参数:

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

params - parameters to be sent with the notification

返回:

a Mono that completes when the notification has been broadcast

另请参阅:

McpSession#sendNotification(String, Map)

close

default void close()

Immediately closes all the transports with connected clients and releases any associated resources.

指定者:

close 在接口中 McpServerTransportProviderBase

closeGracefully

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

Gracefully closes all the transports with connected clients and releases any associated resources asynchronously.

指定者:

closeGracefully 在接口中 McpServerTransportProviderBase

返回:

a Mono that completes when the connections have been closed.