io.modelcontextprotocol.server.transport

类 StdioServerTransportProvider

java.lang.Object

io.modelcontextprotocol.server.transport.StdioServerTransportProvider

所有已实现的接口:

McpServerTransportProvider

public class StdioServerTransportProvider
extends java.lang.Object
implements McpServerTransportProvider

Implementation of the MCP Stdio transport provider for servers that communicates using standard input/output streams. Messages are exchanged as newline-delimited JSON-RPC messages over stdin/stdout, with errors and debug information sent to stderr.

构造器概要

构造器

构造器和说明
StdioServerTransportProvider() Creates a new StdioServerTransportProvider with a default ObjectMapper and System streams.
StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper) Creates a new StdioServerTransportProvider with the specified ObjectMapper and System streams.
StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper, java.io.InputStream inputStream, java.io.OutputStream outputStream) Creates a new StdioServerTransportProvider with the specified ObjectMapper and streams.

方法概要

限定符和类型	方法和说明
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.util.Map<java.lang.String,java.lang.Object> params) Sends a notification to all connected clients.
void	setSessionFactory(McpServerSession.Factory sessionFactory) Sets the session factory that will be used to create sessions for new clients.

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

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

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

close

构造器详细资料

StdioServerTransportProvider

public StdioServerTransportProvider()

Creates a new StdioServerTransportProvider with a default ObjectMapper and System streams.

StdioServerTransportProvider

public StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Creates a new StdioServerTransportProvider with the specified ObjectMapper and System streams.

参数:

objectMapper - The ObjectMapper to use for JSON serialization/deserialization

StdioServerTransportProvider

public StdioServerTransportProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                    java.io.InputStream inputStream,
                                    java.io.OutputStream outputStream)

Creates a new StdioServerTransportProvider with the specified ObjectMapper and streams.

参数:

objectMapper - The ObjectMapper to use for JSON serialization/deserialization

inputStream - The input stream to read from

outputStream - The output stream to write to

方法详细资料

setSessionFactory

public void setSessionFactory(McpServerSession.Factory sessionFactory)

从接口复制的说明: McpServerTransportProvider

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 在接口中 McpServerTransportProvider

参数:

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.util.Map<java.lang.String,java.lang.Object> params)

从接口复制的说明: McpServerTransportProvider

Sends a notification to all connected clients.

指定者:

notifyClients 在接口中 McpServerTransportProvider

参数:

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

params - a map of 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()

从接口复制的说明: McpServerTransportProvider

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

指定者:

closeGracefully 在接口中 McpServerTransportProvider

返回:

a Mono that completes when the connections have been closed.