io.modelcontextprotocol.client.transport

类 WebRxStreamableHttpTransport

java.lang.Object

io.modelcontextprotocol.client.transport.WebRxStreamableHttpTransport

所有已实现的接口:

McpClientTransport, McpTransport

public class WebRxStreamableHttpTransport
extends java.lang.Object
implements McpClientTransport

An implementation of the Streamable HTTP protocol as defined by the 2025-03-26 version of the MCP specification.

The transport is capable of resumability and reconnects. It reacts to transport-level session invalidation and will propagate appropriate exceptions to the higher level abstraction layer when needed in order to allow proper state management. The implementation handles servers that are stateful and provide session meta information, but can also communicate with stateless servers that do not provide a session identifier and do not support SSE streams.

This implementation does not handle backwards compatibility with the "HTTP with SSE" transport. In order to communicate over the phased-out 2024-11-05 protocol, use HttpClientSseClientTransport or WebRxSseClientTransport.

另请参阅:

Streamable HTTP transport specification

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	WebRxStreamableHttpTransport.Builder Builder for WebRxStreamableHttpTransport.

方法概要

限定符和类型	方法和说明
static WebRxStreamableHttpTransport.Builder	builder(org.noear.solon.net.http.HttpUtilsBuilder webClientBuilder) Create a stateful builder for creating WebRxStreamableHttpTransport instances.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the transport connection and releases any associated resources asynchronously.
reactor.core.publisher.Mono<java.lang.Void>	connect(java.util.function.Function<reactor.core.publisher.Mono<McpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<McpSchema.JSONRPCMessage>> handler) Used to register the incoming messages' handler and potentially (eagerly) connect to the server.
java.util.List<java.lang.String>	protocolVersions()
reactor.core.publisher.Mono<java.lang.Void>	sendMessage(McpSchema.JSONRPCMessage message) Sends a message to the peer asynchronously.
void	setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler) Sets the exception handler for exceptions raised on the transport layer.
<T> T	unmarshalFrom(java.lang.Object data, com.fasterxml.jackson.core.type.TypeReference<T> typeRef) Unmarshals the given data into an object of the specified type.

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

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

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

close

方法详细资料

protocolVersions

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

指定者:

protocolVersions 在接口中 McpTransport

builder

public static WebRxStreamableHttpTransport.Builder builder(org.noear.solon.net.http.HttpUtilsBuilder webClientBuilder)

Create a stateful builder for creating WebRxStreamableHttpTransport instances.

参数:

webClientBuilder - the HttpUtilsBuilder to use

返回:

a builder which will create an instance of WebRxStreamableHttpTransport once WebRxStreamableHttpTransport.Builder.build() is called

connect

public reactor.core.publisher.Mono<java.lang.Void> connect(java.util.function.Function<reactor.core.publisher.Mono<McpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<McpSchema.JSONRPCMessage>> handler)

从接口复制的说明: McpClientTransport

Used to register the incoming messages' handler and potentially (eagerly) connect to the server.

指定者:

connect 在接口中 McpClientTransport

参数:

handler - a transformer for incoming messages

返回:

a Mono that terminates upon successful client setup. It can mean establishing a connection (which can be later disposed) but it doesn't have to, depending on the transport type. The successful termination of the returned Mono simply means the client can now be used. An error can be retried according to the application requirements.

setExceptionHandler

public void setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler)

从接口复制的说明: McpClientTransport

Sets the exception handler for exceptions raised on the transport layer.

指定者:

setExceptionHandler 在接口中 McpClientTransport

参数:

handler - Allows reacting to transport level exceptions by the higher layers

closeGracefully

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

从接口复制的说明: McpTransport

Closes the transport connection and releases any associated resources asynchronously.

指定者:

closeGracefully 在接口中 McpTransport

返回:

a Mono that completes when the connection has been closed.

sendMessage

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

从接口复制的说明: McpTransport

Sends a message to the peer asynchronously.

This method handles the transmission of messages to the server in an asynchronous manner. Messages are sent in JSON-RPC format as specified by the MCP protocol.

指定者:

sendMessage 在接口中 McpTransport

参数:

message - the McpSchema.JSONRPCMessage to be sent to the server

返回:

a Mono that completes when the message has been sent

unmarshalFrom

public <T> T unmarshalFrom(java.lang.Object data,
                           com.fasterxml.jackson.core.type.TypeReference<T> typeRef)

从接口复制的说明: McpTransport

Unmarshals the given data into an object of the specified type.

指定者:

unmarshalFrom 在接口中 McpTransport

类型参数:

T - the type of the object to unmarshal

参数:

data - the data to unmarshal

typeRef - the type reference for the object to unmarshal

返回:

the unmarshalled object