io.modelcontextprotocol.spec

接口 McpClientTransport

所有超级接口:

McpTransport

所有已知实现类:

StdioClientTransport, WebRxSseClientTransport, WebRxStreamableHttpTransport

public interface McpClientTransport
extends McpTransport

Interface for the client side of the McpTransport. It allows setting handlers for messages that are incoming from the MCP server and hooking in to exceptions raised on the transport layer.

方法概要

限定符和类型	方法和说明
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.
default void	setExceptionHandler(java.util.function.Consumer<java.lang.Throwable> handler) Sets the exception handler for exceptions raised on the transport layer.

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

close, closeGracefully, protocolVersions, sendMessage, unmarshalFrom

方法详细资料

connect

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.

参数:

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

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

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

参数:

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