AguiRequestProcessor
public class AguiRequestProcessorio/agentscope/core/agui/processor/AguiRequestProcessor.java:66–438AGUI 请求处理器，在智能体、模型与前端之间传递结构化消息和事件。位于 io.agentscope.core.agui.processor 包。核心成员包括 process、resolveAgentId、extractLatestUserMessage、builder。
Core processor for AG-UI requests.
This class encapsulates the common logic for processing AG-UI requests, extracting it from MVC and WebFlux handlers to avoid code duplication.
Responsibilities:
-
Agent ID resolution from multiple sources
-
Message extraction for server-side memory scenarios
-
Agent resolution via
AgentResolver -
Event stream generation via
AguiAgentAdapter
Usage:
`AguiRequestProcessor processor = AguiRequestProcessor.builder()
.agentResolver(resolver)
.config(AguiAdapterConfig.defaultConfig())
.build();
AguiRuntimeContextRequest<?> request = AguiRuntimeContextRequest.builder()
.input(input)
.build();
ProcessResult result = processor.process(request);
Flux<AguiEvent> events = result.events();
`
嵌套类摘要Nested Class Summary
| 类Class | 类型Kind | 说明Description |
|---|---|---|
ProcessResult | 记录record | 承载 Process 结果数据的记录类型。 Result of processing an AG-UI request. |
Builder | 类class | AguiRequestProcessor的构建器。 Builder for AguiRequestProcessor. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public ProcessResult process(AguiRuntimeContextRequest<?> request) | 设置该参数。 Process an AG-UI request and return the result containing agent and event stream. |
public String resolveAgentId(RunAgentInput input, String headerAgentId, String pathAgentId) | 解析智能体标识。 Resolve the agent ID from multiple sources. |
public RunAgentInput extractLatestUserMessage(RunAgentInput input) | 设置该参数。 Extract messages that arrived after the last assistant turn. |
public static Builder builder()static | 创建新的构建器用于 AguiRequestProcessor。 Creates a new builder for AguiRequestProcessor. |
方法详情Method Detail
process
public ProcessResult process(AguiRuntimeContextRequest<?> request)设置该参数。
Process an AG-UI request and return the result containing agent and event stream.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
request | AguiRuntimeContextRequest<?> | 请求（类型 `AguiRuntimeContextRequest`）。The AG-UI request context carrying input, agent IDs, transport details and the native request |
ProcessResultio/agentscope/core/agui/processor/AguiRequestProcessor.java:134–225resolveAgentId
public String resolveAgentId(RunAgentInput input, String headerAgentId, String pathAgentId)解析智能体标识。
Resolve the agent ID from multiple sources.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
input | RunAgentInput | 请求输入。The request input |
headerAgentId | String | 请求头智能体标识（类型 `String`）。The agent ID from HTTP header (may be null) |
pathAgentId | String | 路径智能体标识（类型 `String`）。The agent ID from URL path variable (may be null) |
Stringio/agentscope/core/agui/processor/AguiRequestProcessor.java:276–306extractLatestUserMessage
public RunAgentInput extractLatestUserMessage(RunAgentInput input)设置该参数。
Extract messages that arrived after the last assistant turn.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
input | RunAgentInput | 输入消息（类型 `RunAgentInput`）。The original input |
RunAgentInputio/agentscope/core/agui/processor/AguiRequestProcessor.java:323–364builder
public static Builder builder()创建新的构建器用于 AguiRequestProcessor。
Creates a new builder for AguiRequestProcessor.
Builderio/agentscope/core/agui/processor/AguiRequestProcessor.java:371–373嵌套类详情Nested Class Detail
ProcessResult
public record ProcessResult( Agent agent, Flux<AguiEvent> events, RuntimeContext runtimeContext)承载 Process 结果数据的记录类型。位于 io.agentscope.core.agui.processor 包。核心成员包括 agent、events、runtimeContext、interrupt。
Result of processing an AG-UI request.
Contains the resolved agent (for interrupt handling) and the event stream.
Builder
public static class BuilderAguiRequestProcessor的构建器。位于 io.agentscope.core.agui.processor 包。核心成员包括 agentResolver、config、adapterFactory、runtimeContextResolver、build。
Builder for AguiRequestProcessor.