public class StdioServerTransportProvider extends java.lang.Object implements McpServerTransportProvider
| 构造器和说明 |
|---|
StdioServerTransportProvider(McpJsonMapper jsonMapper)
Creates a new StdioServerTransportProvider with the specified ObjectMapper and
System streams.
|
StdioServerTransportProvider(McpJsonMapper jsonMapper,
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.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(McpServerSession.Factory sessionFactory)
Sets the session factory that will be used to create sessions for new clients.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclosepublic StdioServerTransportProvider(McpJsonMapper jsonMapper)
jsonMapper - The JsonMapper to use for JSON serialization/deserializationpublic StdioServerTransportProvider(McpJsonMapper jsonMapper, java.io.InputStream inputStream, java.io.OutputStream outputStream)
jsonMapper - The JsonMapper to use for JSON serialization/deserializationinputStream - The input stream to read fromoutputStream - The output stream to write topublic java.util.List<java.lang.String> protocolVersions()
McpServerTransportProviderBaseprotocolVersions 在接口中 McpServerTransportProviderBasepublic void setSessionFactory(McpServerSession.Factory sessionFactory)
McpServerTransportProvidersetSessionFactory 在接口中 McpServerTransportProvidersessionFactory - the session factory to be used for initiating client sessionspublic reactor.core.publisher.Mono<java.lang.Void> notifyClients(java.lang.String method,
java.lang.Object params)
McpServerTransportProviderBasenotifyClients 在接口中 McpServerTransportProviderBasemethod - the name of the notification method to be called on the clientsparams - parameters to be sent with the notificationMcpSession#sendNotification(String, Map)public reactor.core.publisher.Mono<java.lang.Void> closeGracefully()
McpServerTransportProviderBasecloseGracefully 在接口中 McpServerTransportProviderBaseMono that completes when the connections have been closed.