A2A bietet einem KI-Agenten eine Standardmöglichkeit, sich einem anderen Agenten vorzustellen, einen Job oder eine Aufgabe anzunehmen, den Fortschritt zu melden, weitere Informationen anzufordern und nützliche Ergebnisse zurückzugeben – selbst wenn der andere Agent in einem anderen KI-Dienst ausgeführt wird, eine andere Programmiersprache oder ein anderes Agenten-Framework verwendet oder in einer anderen Cloud bereitgestellt wird. Keiner der Agenten muss verstehen, wie der andere aufgebaut ist. Zur Kommunikation und Zusammenarbeit nutzen sie den A2A-Standard.
ADK-Rust A2A Referenzarchitektur
The network contract stays separate from the agent's model, tools, memory, and internal orchestration.
01
Der Agent oder die Anwendung, die einen anderen Agenten auffordert, Arbeit zu erledigen.
Entscheidet, welcher Remote-Spezialist die Aufgabe erhalten soll.
Erkennt die Karte, wählt Streaming und sendet Protokollnachrichten.
02
Der öffentliche Auftrag kann von jedem kompatiblen Kunden verstanden werden.
Name, Fähigkeiten, Endpunkt, Protokollversion, Sicherheit und deklarierte Fähigkeiten.
Version, Inhaltstyp, IDs, Nachrichtenteile, Metadaten, Identität und Einschränkungen.
Versendet JSON-RPC- oder REST-Vorgänge über eine gemeinsame Implementierung.
03
Das Framework führt die Aufgabe aus und erzeugt einen typisierten Fortschritt.
Erstellt den Aufrufkontext und streamt Agentenereignisse.
LLM, Workflow-, Diagramm-, benutzerdefinierte oder Multi-Agent-Logik.
Rust-Werkzeuge und MCP
Sitzungen und Erinnerung
04
Eine validierte Zustandsmaschine macht lang laufende Arbeiten überprüfbar.
Status, Kontext, Verlauf, Artefakte, Metadaten und Push-Konfiguration.
Es werden nur gültige Übergänge akzeptiert; Terminalaufgaben bleiben Terminal.
05
Der Anrufer wählt aus, wie er das Wechselgeld erhalten möchte.
Gibt die vollständige Aufgabe und ihre Artefakte zurück.
Zuerst die Aufgabe, dann Status- und Artefaktaktualisierungen.
06
Lange Aufgaben können später gemeldet werden, ohne dass eine Verbindung offen gehalten wird.
Ein Client lauscht auf Aktualisierungen für eine vorhandene Aufgabe.
Authentifizierte Zustellung mit Wiederholungsversuchen und SSRF-Prüfungen.
Beginnen Sie mit der Idee
Innerhalb eines ADK-Rust-Prozesses können Agenten Rust-Typen, Sitzungen, Tools und direkte Funktionsaufrufe gemeinsam nutzen. Sobald ein Agent einem anderen Dienst – oder einer anderen Organisation – angehört, sind diese privaten Implementierungsdetails kein sicherer Vertrag mehr.
A2A definiert die gemeinsame Sprache an dieser Grenze. Der Anrufer erkennt, was der Remote-Agent anbietet, sendet eine strukturierte Nachricht, verfolgt eine Aufgabe durch bekannte Zustände und empfängt Artefakte, ohne wissen zu müssen, welches Modell, welches Framework oder welche Tools hinter dem Endpunkt ausgeführt werden.
ADK-Rust implementiert A2A v1 in adk-server und verbindet das Protokoll direkt mit dem Runner. Derselbe Agent, den Sie lokal testen, kann zu einem Netzwerkdienst werden, während RemoteA2aAgent es einem anderen ADK-Rust-System ermöglicht, ihn über die normale Agentenschnittstelle zu nutzen.
Agentenkarte
Ein kleines öffentliches Dokument informiert Anrufer über den Namen des Agenten, Endpunkt, Fähigkeiten, Protokollversion, Sicherheitsanforderungen und ob er Streaming oder Benachrichtigungen unterstützt.
Nachricht
Eine Nachricht enthält eine Rolle, eine eindeutige ID und einen oder mehrere Teile wie Text oder strukturierte Daten. Die eindeutige ID ermöglicht sichere Wiederholungsversuche.
Aufgabe
Eine Aufgabe gibt der Remote-Arbeit eine ID, einen Konversationskontext, einen Status, einen Nachrichtenverlauf, Metadaten und alle dabei erzeugten Artefakte.
Artefakt
Ein Artefakt ist ein benanntes Ergebnis, das an die Aufgabe angehängt ist: ein Bericht, eine Entscheidung, ein Plan, eine generierte Datei oder eine andere strukturierte Ausgabe, die ein anderes System verwenden kann.
Folgen Sie einem Job
Ein Anrufer kann auf eine Antwort warten, einen Live-Ereignisstream öffnen, eine bestehende Aufgabe abonnieren oder einen Webhook für spätere Updates registrieren. Aufgabenidentität und -kontext sorgen dafür, dass jeder Bereitstellungsmodus mit derselben Arbeit verknüpft ist.
Task-Zustandsmaschine
A2A leistet mehr als nur die Rückgabe von Text. Es verleiht der Arbeit eine Identität, einen Gesprächskontext, einen aktuellen Zustand, eine Geschichte und Artefakte. ADK-Rust validiert jeden Übergang, bevor er gespeichert wird.
SUBMITTEDDer Server hat die Aufgabe angenommen.
WORKINGDer Agent führt es aus.
INPUT REQUIREDDer Agent benötigt weitere Informationen.
AUTH REQUIREDDer Anrufer muss eine Autorisierung vorlegen.
COMPLETEDArbeit und Artefakte sind fertig.
FAILEDDie Ausführung wurde mit einem Fehler beendet.
CANCELEDEin erlaubter Abbruch beendete die Aufgabe.
REJECTEDDer Server hat die Aufgabe abgelehnt.
INPUT_REQUIRED, sendet der Anrufer eine weitere Nachricht mit derselben Nachricht contextId. ADK-Rust findet die Aufgabe und gibt sie an zurück WORKING, hängt die Nachricht an und setzt den gleichen Job fort.Logikfluss in der realen Welt
A customer tells the company's support agent that an order arrived damaged. The support agent remains responsible for the conversation: it understands the request, keeps the customer informed, collects any missing evidence, and presents the final decision. It does not have direct access to warehouse stock, delivery records, or replacement policy.
Diese Betriebsinformationen gehören zu einem separat eingesetzten Fulfillment-Agenten. Über A2A kann der Support-Mitarbeiter herausfinden, was der Fulfillment-Agent tut, ihm die Untersuchung als Aufgabe senden, den Fortschritt verfolgen, Anfragen nach weiteren Informationen beantworten und die endgültige Ersatzentscheidung erhalten. Jeder Dienst behält seinen eigenen Code, seine eigenen Daten, Tools, Modellanbieter und Sicherheitskontrollen. Sie teilen nur die Nachrichten, den Aufgabenstatus und die Artefakte, die im A2A-Vertrag definiert sind.
Ein Support-Koordinator liest die Karte des Fulfillment-Agenten und bestätigt, dass dieser die Auftragsuntersuchung durchführt und den Fortschritt überträgt.
Es sendet die Bestellnummer, die Anfrage des Kunden, eine eindeutige Nachrichten-ID und einen neuen Konversationskontext.
Der Remote-ADK-Rust-Agent überprüft Bestelltools, Inventar, Lieferhistorie und Unternehmensrichtlinien, ohne diese Interna dem Anrufer preiszugeben.
Wenn ein Schadensnachweis erforderlich ist, wird die Aufgabe zu INPUT_REQUIRED, anstatt zu raten oder stillschweigend fehlzuschlagen.
Der Koordinator stellt die genehmigten Nachweise unter Verwendung derselben contextId bereit; Verlauf und Aufgabenidentität bleiben erhalten.
Die Aufgabe wird mit einem Statusverlauf und einem Artefakt abgeschlossen, das die Ersetzungsentscheidung und die nächsten Schritte enthält.
Sequence diagram
Read from top to bottom. The A2A service owns the network contract and task record. The fulfilment agent owns its reasoning and private tools.
Calling agent
Protocol boundary
ADK-Rust Runner
Orders · inventory · policy
GET /.well-known/agent-card.json
Discover skills and streaming
Agent Card
Fulfilment capability published
SendStreamingMessage
ORD-1042 · messageId msg-order-1042
Runner invocation
Create task and execute agent
order.lookup + policy.check
Use private business tools
Evidence required
Damage photo is missing
INPUT_REQUIRED
Persist state and context
SSE status update
Ask support for evidence
SendMessage · same contextId
Approved photo reference
Resume task
INPUT_REQUIRED → WORKING
inventory.reserve
Reserve replacement stock
Artifact + COMPLETED
Replacement decision
Final SSE events
Auditable result returned
Code- und Drahtantworten
Diese Beispiele verwenden dieselben v1-Operationsnamen, Nachrichtenfelder, Aufgabenstatus und SSE-Antwortformen wie die ADK-Rust-Implementierung. IDs und Bestelldetails sind festgelegt, sodass das gesamte Gespräch leicht zu verfolgen ist.
let fulfilment = LlmAgentBuilder::new("fulfilment")
.description("Investigates orders and delivery")
.model(model)
.instruction(
"Use the approved order, inventory, and policy tools. Ask for evidence when the replacement policy requires it."
)
.build()?;
A2aServer::builder()
.agent(Arc::new(fulfilment))
.agent_card_name("Fulfilment Agent")
.streaming(true)
.build()?
.serve()
.await?;let fulfilment = RemoteA2aAgent::builder("fulfilment")
.description("Investigates orders and delivery")
.agent_url("https://agents.example.com/fulfilment")
.streaming(true)
.build()?;
let support = LlmAgentBuilder::new("support")
.model(model)
.instruction("Own the customer conversation.")
.sub_agent(Arc::new(fulfilment))
.build()?;{
"jsonrpc": "2.0",
"id": "replace-1",
"method": "SendStreamingMessage",
"params": {
"message": {
"messageId": "msg-order-1042",
"role": "ROLE_USER",
"parts": [{
"text": "Investigate damaged order ORD-1042 and prepare a replacement decision."
}]
}
}
}data: {
"jsonrpc":"2.0", "id":"replace-1",
"result":{"task":{
"id":"task-order-1042",
"contextId":"ctx-order-1042",
"status":{"state":"TASK_STATE_SUBMITTED"}
}}
}
data: {
"jsonrpc":"2.0", "id":"replace-1",
"result":{"statusUpdate":{
"taskId":"task-order-1042",
"contextId":"ctx-order-1042",
"status":{"state":"TASK_STATE_WORKING"}
}}
}{
"statusUpdate": {
"taskId": "task-order-1042",
"contextId": "ctx-order-1042",
"status": {
"state": "TASK_STATE_INPUT_REQUIRED",
"message": {
"role": "ROLE_AGENT",
"parts": [{
"text": "Please provide a photo showing the damaged item."
}]
}
}
}
}{
"jsonrpc": "2.0",
"id": "replace-2",
"method": "SendMessage",
"params": {
"message": {
"messageId": "msg-order-1042-photo",
"contextId": "ctx-order-1042",
"role": "ROLE_USER",
"parts": [{
"text": "Evidence received and approved: damage-photo-8841.jpg"
}]
}
}
}{
"artifactUpdate": {
"taskId": "task-order-1042",
"contextId": "ctx-order-1042",
"artifact": {
"artifactId": "replacement-decision-1042",
"name": "Replacement decision",
"parts": [{
"text": "Approved. Reserve SKU-RED-42 and dispatch with priority shipping."
}]
}
}
}
{
"statusUpdate": {
"taskId": "task-order-1042",
"contextId": "ctx-order-1042",
"status": { "state": "TASK_STATE_COMPLETED" }
}
}Der A2A v1 API
ADK-Rust implementiert alle 11 Operationen in A2A v1. Rufen Sie für einen kurzen Job SendMessage auf und warten Sie auf das Ergebnis der Aufgabe. Wenn die Arbeit länger dauern kann, verwenden Sie SendStreamingMessage, um zuerst die Aufgabe zu empfangen, gefolgt von Live-Status- und Artefaktereignissen über SSE.
Mit der zurückgegebenen Aufgaben-ID kann Ihr Client die Verbindung wiederherstellen, ohne den Auftrag erneut zu übermitteln. Es kann den neuesten Status abrufen, verwandte Aufgaben auflisten, weitere Updates abonnieren oder eine Stornierung beantragen. Wenn der Client eine Verbindung nicht offen halten kann, kann er einen authentifizierten Webhook registrieren und den Remote-Agenten spätere Änderungen übermitteln lassen.
Senden Sie eine Nachricht und erhalten Sie entweder eine vollständige Aufgabe oder einen Live-Stream.
SendMessageSendStreamingMessageLesen Sie die aktuelle Arbeit, listen Sie passende Aufgaben auf oder brechen Sie eine Aufgabe ab, wenn ihr Status dies zulässt.
GetTaskListTasksCancelTaskÖffnen Sie ein SSE-Abonnement für Updates einer bereits vorhandenen Aufgabe.
SubscribeToTaskErstellen, lesen, auflisten und entfernen Sie authentifizierte Webhook-Ziele für eine Aufgabe.
CreatePushConfigGetPushConfigListPushConfigsDeletePushConfigFordern Sie die erweiterte Version des veröffentlichten Serviceprofils eines Agenten an.
GetExtendedAgentCardJSON-RPC und REST leiten den Versand an denselben RequestHandler weiter, sodass das Aufgabenverhalten zwischen den Transporten nicht schwankt.
Eingehende A2A-Nachrichten werden zu ADK-Rust-Inhalten. Der Runner führt den ausgewählten Agenten aus und wandelt seine Ereignisse in Aufgabenstatus und Artefakte um.
Eine wiederholte messageId gibt die vorhandene Aufgabe zurück, anstatt dieselbe Arbeit zweimal auszuführen. Produktionsbereitstellungen sollten diese Zuordnung über Neustarts hinweg beibehalten.
Das erste SSE-Ereignis ist die vollständige Aufgabe. Spätere Ereignisse enthalten Status- und Artefaktaktualisierungen, sodass ein Client immer weiß, zu welchem Stream der Stream gehört.
RemoteA2aAgent implementiert die Agenteneigenschaft ADK-Rust. Ein Koordinator kann einen Netzwerkdienst in seine Agentenhierarchie aufnehmen und normale Framework-Ereignisse empfangen.
Versionsaushandlung, Nachrichtenvalidierung, Trägerauthentifizierung, Ratenbegrenzung, Audit-Interceptoren, Webhook-Authentifizierung und SSRF-Prüfungen können den Dienst schützen.
Wählen Sie die richtige Grenze
A2A führt ein Netzwerk, einen öffentlichen Vertrag, Authentifizierung, Fehlerbehandlung und den Remote-Task-Status ein. Diese Kosten sind wertvoll, wenn sie echte Unabhängigkeit schaffen; Sie sind unnötig, wenn jeder Agent bereits im selben Prozess lebt.
Lokaler Subagent
Remote-A2A-Agent
Vom Rust-Agent zum Netzwerkdienst
Der Convenience-Server erstellt eine Axum-Anwendung mit einer Agentenkarte, Sitzungen, A2A-Routen und aktiviertem Streaming. Der Remote-Adapter erkennt diesen Dienst und wandelt seine Aufgabenaktualisierungen wieder in ADK-Rust-Ereignisse um.
use adk_server::a2a::convenience::A2aServer;
let app = A2aServer::quick_start(agent);
let listener = tokio::net::TcpListener::bind(
"0.0.0.0:8080"
).await?;
axum::serve(listener, app).await?;use adk_server::a2a::RemoteA2aAgent;
let fulfilment = RemoteA2aAgent::builder("fulfilment")
.description("Investigates orders and delivery")
.agent_url("https://agents.example.com/fulfilment")
.build()?;
let coordinator = LlmAgentBuilder::new("support")
.model(model)
.sub_agent(Arc::new(fulfilment))
.build()?;RequestHandler::with_runner Pfad, um den Aufgabenspeicher, den Push-Absender, die Agentenkarte, die Runner-Dienste, die JSON-RPC-Route, den REST-Router und die Versionsaushandlungs-Middleware explizit auszuwählen.Vor der Produktion
ADK-Rust stellt die v1-Typen, Handler, Lebenszyklus, Clients, Validierung, Bereitstellungsprimitive und Integration mit Runner bereit. Die Produktionsbereitschaft hängt weiterhin von den für Ihren Dienst ausgewählten Speicher-, Identitäts-, Netzwerk-, Beobachtbarkeits- und Betriebsrichtlinien ab.
Bewerben Sie nur die Fähigkeiten, Bindungen, Streaming, Push-Bereitstellung und Sicherheitsschemata, die die Bereitstellung wirklich unterstützt.
Der enthaltene InMemoryTaskStore und die In-Memory-Idempotenzkarte sind für die Entwicklung nützlich. Langfristige Produktionsarbeiten benötigen Speicher, der Prozessneustarts übersteht.
Authentifizieren Sie eingehende Anrufe und schützen Sie die ausgehende Push-Zustellung. Der HTTP-Push-Sender unterstützt Inhaberanmeldeinformationen, Benachrichtigungstoken, Wiederholungsversuche und die Ablehnung privater Adressen.
Remote-Arbeit kann eine Anfrage überleben. Definieren Sie Client-Timeouts, Stornierungsrichtlinien, Wiederholungsverhalten und was passiert, wenn einer der Dienste nicht verfügbar ist.
Verbinden Sie das Agentensystem
Beginnen Sie mit einer ehrlichen Agentenkarte und einer nützlichen Aufgabe. Fügen Sie Streaming, Multi-Turn-Eingabe, Aufgabenpersistenz, Abonnements, authentifiziertes Push und Grenzkontrollen hinzu, wenn die Arbeit länger und der Dienst wichtiger wird.