com.agentclientprotocol.sdk.client.transport

类 WebSocketSolonAcpClientTransport

java.lang.Object

com.agentclientprotocol.sdk.client.transport.WebSocketSolonAcpClientTransport

所有已实现的接口:

AcpClientTransport, AcpTransport

public class WebSocketSolonAcpClientTransport
extends java.lang.Object
implements AcpClientTransport

Implementation of the ACP WebSocket transport for clients that communicates with an agent using WebSocket connections.

Messages are exchanged as JSON-RPC messages over WebSocket text frames.

Key features:

• Zero external dependencies (uses JDK built-in WebSocket)
• Thread-safe message processing with dedicated schedulers
• Proper resource management and graceful shutdown
• Backpressure support via Reactor Sinks

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	DEFAULT_ACP_PATH Default path for ACP WebSocket endpoints

构造器概要

构造器

构造器和说明
WebSocketSolonAcpClientTransport(java.net.URI serverUri, McpJsonMapper jsonMapper) Creates a new WebSocketAcpClientTransport with the specified server URI and JsonMapper.

方法概要

限定符和类型	方法和说明
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<AcpSchema.JSONRPCMessage>,reactor.core.publisher.Mono<AcpSchema.JSONRPCMessage>> handler) Used to register the incoming messages' handler and potentially (eagerly) connect to the agent.
WebSocketSolonAcpClientTransport	connectTimeout(java.time.Duration timeout) Sets the connection timeout for WebSocket establishment.
reactor.core.publisher.Mono<java.lang.Void>	sendMessage(AcpSchema.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, 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.AcpTransport

close, protocolVersions

字段详细资料

DEFAULT_ACP_PATH

public static final java.lang.String DEFAULT_ACP_PATH

Default path for ACP WebSocket endpoints

另请参阅:

常量字段值

构造器详细资料

WebSocketSolonAcpClientTransport

public WebSocketSolonAcpClientTransport(java.net.URI serverUri,
                                        McpJsonMapper jsonMapper)

Creates a new WebSocketAcpClientTransport with the specified server URI and JsonMapper.

参数:

serverUri - The WebSocket URI to connect to (e.g., "ws://localhost:8080/acp")

jsonMapper - The JsonMapper to use for JSON serialization/deserialization

方法详细资料

connectTimeout

public WebSocketSolonAcpClientTransport connectTimeout(java.time.Duration timeout)

Sets the connection timeout for WebSocket establishment.

参数:

timeout - The connection timeout

返回:

This transport for chaining

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)

从接口复制的说明: AcpClientTransport

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

指定者:

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.

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

closeGracefully

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

从接口复制的说明: AcpTransport

Closes the transport connection and releases any associated resources asynchronously.

指定者:

closeGracefully 在接口中 AcpTransport

返回:

a Mono that completes when the connection has been closed.

setExceptionHandler

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

从接口复制的说明: AcpClientTransport

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

指定者:

setExceptionHandler 在接口中 AcpClientTransport

参数:

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

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