io.modelcontextprotocol.server.transport

类 WebRxStreamableServerTransportProvider

java.lang.Object

io.modelcontextprotocol.server.transport.WebRxStreamableServerTransportProvider

所有已实现的接口:

IMcpHttpServerTransport, McpServerTransportProviderBase, McpStreamableServerTransportProvider

public class WebRxStreamableServerTransportProvider
extends java.lang.Object
implements McpStreamableServerTransportProvider, IMcpHttpServerTransport

Server-side implementation of the Model Context Protocol (MCP) streamable transport layer using HTTP with Server-Sent Events (SSE) through Spring WebMVC. This implementation provides a bridge between synchronous WebMVC operations and reactive programming patterns to maintain compatibility with the reactive transport interface.

另请参阅:

McpStreamableServerTransportProvider

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	WebRxStreamableServerTransportProvider.Builder Builder for creating instances of WebRxStreamableServerTransportProvider.

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	DEFAULT_BASE_URL Default base URL for the message endpoint.
static java.lang.String	ENDPOINT_EVENT_TYPE Event type for sending the message endpoint URI to clients.
static java.lang.String	MESSAGE_EVENT_TYPE Event type for JSON-RPC messages sent through the SSE connection.

方法概要

限定符和类型	方法和说明
static WebRxStreamableServerTransportProvider.Builder	builder()
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Gracefully closes all the transports with connected clients and releases any associated resources asynchronously.
java.lang.String	getMcpEndpoint()
reactor.core.publisher.Mono<java.lang.Void>	notifyClients(java.lang.String method, java.lang.Object params) Sends a notification to all connected clients.
java.util.List<java.lang.String>	protocolVersions() Returns the protocol version supported by this transport provider.
void	setSessionFactory(McpStreamableServerSession.Factory sessionFactory) Sets the session factory that will be used to create sessions for new clients.
void	toHttpHandler(org.noear.solon.SolonApp app)

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

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

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

close

字段详细资料

MESSAGE_EVENT_TYPE

public static final java.lang.String MESSAGE_EVENT_TYPE

Event type for JSON-RPC messages sent through the SSE connection.

另请参阅:

常量字段值

ENDPOINT_EVENT_TYPE

public static final java.lang.String ENDPOINT_EVENT_TYPE

Event type for sending the message endpoint URI to clients.

另请参阅:

常量字段值

DEFAULT_BASE_URL

public static final java.lang.String DEFAULT_BASE_URL

Default base URL for the message endpoint.

另请参阅:

常量字段值

方法详细资料

toHttpHandler

public void toHttpHandler(org.noear.solon.SolonApp app)

指定者:

toHttpHandler 在接口中 IMcpHttpServerTransport

getMcpEndpoint

public java.lang.String getMcpEndpoint()

指定者:

getMcpEndpoint 在接口中 IMcpHttpServerTransport

protocolVersions

public java.util.List<java.lang.String> protocolVersions()

从接口复制的说明: McpServerTransportProviderBase

Returns the protocol version supported by this transport provider.

指定者:

protocolVersions 在接口中 McpServerTransportProviderBase

返回:

the protocol version as a string

setSessionFactory

public void setSessionFactory(McpStreamableServerSession.Factory sessionFactory)

从接口复制的说明: McpStreamableServerTransportProvider

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.

指定者:

setSessionFactory 在接口中 McpStreamableServerTransportProvider

参数:

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

notifyClients

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

从接口复制的说明: McpStreamableServerTransportProvider

Sends a notification to all connected clients.

指定者:

notifyClients 在接口中 McpServerTransportProviderBase

指定者:

notifyClients 在接口中 McpStreamableServerTransportProvider

参数:

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)

closeGracefully

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

从接口复制的说明: McpStreamableServerTransportProvider

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

指定者:

closeGracefully 在接口中 McpServerTransportProviderBase

指定者:

closeGracefully 在接口中 McpStreamableServerTransportProvider

返回:

a Mono that completes when the connections have been closed.

builder

public static WebRxStreamableServerTransportProvider.Builder builder()