com.agentclientprotocol.sdk.client

接口 AcpClient

public interface AcpClient

Factory class for creating Agent Client Protocol (ACP) clients. ACP is a protocol that enables applications to interact with autonomous coding agents through a standardized interface.

This class serves as the main entry point for establishing connections with ACP agents, implementing the client-side of the ACP specification. The protocol follows a client-agent architecture where:

• The client (this implementation) initiates connections and sends prompts
• The agent responds to prompts and can request client capabilities (file access, etc.)
• Communication occurs through a transport layer (e.g., stdio) using JSON-RPC 2.0

The class provides factory methods to create either:

• AcpAsyncClient for non-blocking operations with Mono responses
• AcpSyncClient for blocking operations with direct responses (future)

Example of creating a basic asynchronous client:

 // Create transport
 AgentParameters params = AgentParameters.builder("gemini")
     .arg("--experimental-acp")
     .build();
 StdioAcpClientTransport transport = new StdioAcpClientTransport(params, McpJsonMapper.getDefault());

 // Build client
 AcpAsyncClient client = AcpClient.async(transport)
     .requestTimeout(Duration.ofSeconds(30))
     .sessionUpdateConsumer(notification -> {
         System.out.println("Session update: " + notification);
         return Mono.empty();
     })
     .build();

 // Initialize and use
 client.initialize(new AcpSchema.InitializeRequest(1, new AcpSchema.ClientCapabilities()))
     .flatMap(initResponse -> client.newSession(new AcpSchema.NewSessionRequest("/workspace", List.of())))
     .flatMap(sessionResponse -> client.prompt(new AcpSchema.PromptRequest(
         sessionResponse.sessionId(),
         List.of(new AcpSchema.TextContent("Fix the failing test")))))
     .doOnNext(response -> System.out.println("Response: " + response))
     .block();

 client.closeGracefully().block();
 

The client supports:

• Protocol version negotiation and capability exchange
• Optional authentication with various methods
• Session creation and management
• Prompt submission with streaming updates
• File system operations (read/write) through client handlers
• Permission requests for sensitive operations
• Terminal operations for command execution

另请参阅:

AcpAsyncClient, AcpClientTransport

嵌套类概要

嵌套类

限定符和类型	接口和说明
static class	AcpClient.AsyncSpec Asynchronous client specification.
static interface	AcpClient.SyncRequestHandler<T> Functional interface for synchronous request handlers.
static class	AcpClient.SyncSpec Synchronous client specification.

字段概要

字段

限定符和类型	字段和说明
static org.slf4j.Logger	logger
static reactor.core.scheduler.Scheduler	SYNC_HANDLER_SCHEDULER Library-owned scheduler for executing synchronous handlers.

方法概要

限定符和类型	方法和说明
static AcpClient.AsyncSpec	async(AcpClientTransport transport) Start building an asynchronous ACP client with the specified transport layer.
static AcpClient.SyncSpec	sync(AcpClientTransport transport) Start building a synchronous ACP client with the specified transport layer.

字段详细资料

logger

static final org.slf4j.Logger logger

SYNC_HANDLER_SCHEDULER

static final reactor.core.scheduler.Scheduler SYNC_HANDLER_SCHEDULER

Library-owned scheduler for executing synchronous handlers. Uses daemon threads with descriptive names to prevent JVM hang on exit. This follows the best practice of never using global Schedulers.boundedElastic().

方法详细资料

sync

static AcpClient.SyncSpec sync(AcpClientTransport transport)

Start building a synchronous ACP client with the specified transport layer. The synchronous ACP client provides blocking operations. Synchronous clients wait for each operation to complete before returning, making them simpler to use but potentially less performant for concurrent operations.

参数:

transport - The transport layer implementation for ACP communication

返回:

A new builder instance for configuring the client

抛出:

java.lang.IllegalArgumentException - if transport is null

async

static AcpClient.AsyncSpec async(AcpClientTransport transport)

Start building an asynchronous ACP client with the specified transport layer. The asynchronous ACP client provides non-blocking operations using Project Reactor's Mono type. The transport layer handles the low-level communication between client and agent using protocols like stdio.

参数:

transport - The transport layer implementation for ACP communication. Common implementation is StdioAcpClientTransport for stdio-based communication.

返回:

A new builder instance for configuring the client

抛出:

java.lang.IllegalArgumentException - if transport is null