com.agentclientprotocol.sdk.agent.transport

类 WebSocketSolonAcpAgentTransport

java.lang.Object

com.agentclientprotocol.sdk.agent.transport.WebSocketSolonAcpAgentTransport

所有已实现的接口:

AcpAgentTransport, AcpTransport

public class WebSocketSolonAcpAgentTransport
extends java.lang.Object
implements AcpAgentTransport

支持多租户的 ACP WebSocket 传输实现。 通过将会话上下文存储在 WebSocket 的属性（attr）中，支持多个客户端同时连接或重复连接。

嵌套类概要

嵌套类

限定符和类型	类和说明
class	WebSocketSolonAcpAgentTransport.AcpWebSocketEndpoint WebSocket 事件监听器实现

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	DEFAULT_ACP_PATH

构造器概要

构造器

构造器和说明
WebSocketSolonAcpAgentTransport(McpJsonMapper jsonMapper)
WebSocketSolonAcpAgentTransport(java.lang.String path, McpJsonMapper jsonMapper)

方法概要

限定符和类型	方法和说明
reactor.core.publisher.Mono<java.lang.Void>	awaitTermination() Returns a Mono that completes when the transport terminates.
reactor.core.publisher.Mono<java.lang.Void>	closeGracefully() Closes the transport connection and releases any associated resources asynchronously.
WebSocketSolonAcpAgentTransport	idleTimeout(java.time.Duration timeout)
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.
reactor.core.publisher.Mono<java.lang.Void>	start(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 start listening for client connections.
<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

另请参阅:

常量字段值

构造器详细资料

WebSocketSolonAcpAgentTransport

public WebSocketSolonAcpAgentTransport(McpJsonMapper jsonMapper)

WebSocketSolonAcpAgentTransport

public WebSocketSolonAcpAgentTransport(java.lang.String path,
                                       McpJsonMapper jsonMapper)

方法详细资料

idleTimeout

public WebSocketSolonAcpAgentTransport idleTimeout(java.time.Duration timeout)

start

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

从接口复制的说明: AcpAgentTransport

Used to register the incoming messages' handler and start listening for client connections.

指定者:

start 在接口中 AcpAgentTransport

参数:

handler - a transformer for incoming messages

返回:

a Mono that terminates upon successful agent setup. The successful termination of the returned Mono simply means the agent can now receive requests. 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)

从接口复制的说明: AcpAgentTransport

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

指定者:

setExceptionHandler 在接口中 AcpAgentTransport

参数:

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

awaitTermination

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

从接口复制的说明: AcpAgentTransport

Returns a Mono that completes when the transport terminates. This is useful for agents that need to block until the transport is done, particularly when using daemon threads.

Example usage:

 transport.start(handler).block();
 transport.awaitTermination().block(); // Block until stdin closes
 

指定者:

awaitTermination 在接口中 AcpAgentTransport

返回:

a Mono that completes when the transport terminates

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