com.agentclientprotocol.sdk.client.transport

类 StdioAcpClientTransport

java.lang.Object

com.agentclientprotocol.sdk.client.transport.StdioAcpClientTransport

所有已实现的接口:

AcpClientTransport, AcpTransport

public class StdioAcpClientTransport
extends java.lang.Object
implements AcpClientTransport

Implementation of the ACP Stdio transport that communicates with an agent process 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.

This is a full-featured transport with:

• Thread-safe message processing with dedicated schedulers
• Proper resource management and graceful shutdown
• Error stream handling
• Backpressure support via Reactor Sinks

构造器概要

构造器

构造器和说明
StdioAcpClientTransport(AgentParameters params) Creates a new StdioAcpClientTransport with the specified parameters using the default JsonMapper.
StdioAcpClientTransport(AgentParameters params, McpJsonMapper jsonMapper) Creates a new StdioAcpClientTransport with the specified parameters and JsonMapper.

方法概要

限定符和类型	方法和说明
void	awaitForExit() Waits for the agent process to exit.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Gracefully closes the transport by destroying the process and disposing of the schedulers.
reactor.core.publisher.Mono<java.lang.Void>	connect(java.util.function.Function<reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>> handler) Starts the agent process and initializes the message processing streams.
reactor.core.publisher.Sinks.Many<java.lang.String>	getErrorSink()
protected java.lang.ProcessBuilder	getProcessBuilder() Creates and returns a new ProcessBuilder instance.
protected void	handleOutbound(java.util.function.Function<reactor.core.publisher.Flux<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Flux<AcpSchema.JSONRPCMessage>> outboundConsumer)
reactor.core.publisher.Mono<java.lang.Void>	sendMessage(AcpSchema.JSONRPCMessage message) Sends a message to the peer asynchronously.
void	setStdErrorHandler(java.util.function.Consumer<java.lang.String> errorHandler) Sets the handler for processing transport-level errors.
<T> T	unmarshalFrom(java.lang.Object data, TypeRef<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

从接口继承的方法 com.agentclientprotocol.sdk.spec.AcpClientTransport

setExceptionHandler

从接口继承的方法 com.agentclientprotocol.sdk.spec.AcpTransport

close, protocolVersions

构造器详细资料

StdioAcpClientTransport

public StdioAcpClientTransport(AgentParameters params)

Creates a new StdioAcpClientTransport with the specified parameters using the default JsonMapper.

参数:

params - The parameters for configuring the agent process

StdioAcpClientTransport

public StdioAcpClientTransport(AgentParameters params,
                               McpJsonMapper jsonMapper)

Creates a new StdioAcpClientTransport with the specified parameters and JsonMapper.

参数:

params - The parameters for configuring the agent process

jsonMapper - The JsonMapper to use for JSON serialization/deserialization

方法详细资料

connect

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

Starts the agent process and initializes the message processing streams. This method sets up the process with the configured command, arguments, and environment, then starts the inbound, outbound, and error processing threads.

指定者:

connect 在接口中 AcpClientTransport

参数:

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.

抛出:

java.lang.RuntimeException - if the process fails to start or if the process streams are null

getProcessBuilder

protected java.lang.ProcessBuilder getProcessBuilder()

Creates and returns a new ProcessBuilder instance. Protected to allow overriding in tests.

返回:

A new ProcessBuilder instance

setStdErrorHandler

public void setStdErrorHandler(java.util.function.Consumer<java.lang.String> errorHandler)

Sets the handler for processing transport-level errors.

The provided handler will be called when errors occur during transport operations, such as connection failures or protocol violations.

参数:

errorHandler - a consumer that processes error messages

awaitForExit

public void awaitForExit()

Waits for the agent process to exit.

抛出:

java.lang.RuntimeException - if the process is interrupted while waiting

sendMessage

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

从接口复制的说明: AcpTransport

Sends a message to the peer asynchronously.

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

指定者:

sendMessage 在接口中 AcpTransport

参数:

message - the AcpSchema.JSONRPCMessage to be sent to the peer

返回:

a Mono that completes when the message has been sent

handleOutbound

protected void handleOutbound(java.util.function.Function<reactor.core.publisher.Flux<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Flux<AcpSchema.JSONRPCMessage>> outboundConsumer)

closeGracefully

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

Gracefully closes the transport by destroying the process and disposing of the schedulers. This method sends a TERM signal to the process and waits for it to exit before cleaning up resources.

指定者:

closeGracefully 在接口中 AcpTransport

返回:

A Mono that completes when the transport is closed

getErrorSink

public reactor.core.publisher.Sinks.Many<java.lang.String> getErrorSink()

unmarshalFrom

public <T> T unmarshalFrom(java.lang.Object data,
                           TypeRef<T> typeRef)

从接口复制的说明: AcpTransport

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

指定者:

unmarshalFrom 在接口中 AcpTransport

类型参数:

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