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 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()` Initiates a graceful shutdown of the transport.
`java.lang.String`	`getMcpEndpoint()`
`reactor.core.publisher.Mono<java.lang.Void>`	`notifyClients(java.lang.String method, java.lang.Object params)` Broadcasts a notification to all connected clients through their SSE connections.
`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)
```
    Broadcasts a notification to all connected clients through their SSE connections. If any errors occur during sending to a particular client, they are logged but don't prevent sending to other clients.
    
    指定者:
    
    notifyClients 在接口中 McpServerTransportProviderBase
    
    指定者:
    
    notifyClients 在接口中 McpStreamableServerTransportProvider
    
    参数:
    
    method - The method name for the notification
    
    params - The parameters for the notification
    
    返回:
    
    A Mono that completes when the broadcast attempt is finished
    
    另请参阅:
    
    McpSession#sendNotification(String, Map)
  - closeGracefully
```
public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
```
    Initiates a graceful shutdown of the transport.
    
    指定者:
    
    closeGracefully 在接口中 McpServerTransportProviderBase
    
    指定者:
    
    closeGracefully 在接口中 McpStreamableServerTransportProvider
    
    返回:
    
    A Mono that completes when all cleanup operations are finished
  - builder
```
public static WebRxStreamableServerTransportProvider.Builder builder()
```

类 WebRxStreamableServerTransportProvider

嵌套类概要

字段概要

方法概要

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

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

字段详细资料

MESSAGE_EVENT_TYPE

ENDPOINT_EVENT_TYPE

DEFAULT_BASE_URL

方法详细资料

toHttpHandler

getMcpEndpoint

protocolVersions

setSessionFactory

notifyClients

closeGracefully

builder