[A2A协议与实现-09].NET SDK客户端的设计与实现

A2A的协议提供了四组核心操作的输入和输出数据结构可以参考我的前面的文章从Protobuf消息详解A2A协议四大核心操作如何进一步知道具体采用的传输协议我就可以直接利用HttpClient来编写A2A客户端代码实际上前面的演示都是这么做得。实际上A2A官方针对.NET的SDK提供了客户端实现。1. IA2AClientA2A协议与实现-03从Protobuf消息详解A2A协议四大核心操作从协议的角度解读了A2A的四组核心操作A2A协议与实现-08基于MAF的A2A Server设计与实现介绍了IA2ARequestHandler接口我们说它是A2A服务端SDK对A2A协议的表达如下这个IA2AClient具有与IA2ARequestHandler接口完全一致的定义则是客户端SDK针对A2A协议的表达。我们自然可以利用它的实现来执行A2A的四组核心操作。publicinterfaceIA2AClient{// 1. Agent调用TaskSendMessageResponseSendMessageAsync(SendMessageRequestrequest,CancellationTokencancellationTokendefault);IAsyncEnumerableStreamResponseSendStreamingMessageAsync(SendMessageRequestrequest,CancellationTokencancellationTokendefault);// 2. 后台任务管理TaskAgentTaskGetTaskAsync(GetTaskRequestrequest,CancellationTokencancellationTokendefault);TaskListTasksResponseListTasksAsync(ListTasksRequestrequest,CancellationTokencancellationTokendefault);TaskAgentTaskCancelTaskAsync(CancelTaskRequestrequest,CancellationTokencancellationTokendefault);IAsyncEnumerableStreamResponseSubscribeToTaskAsync(SubscribeToTaskRequestrequest,CancellationTokencancellationTokendefault);// 3. 基于后台任务的通知推送配置管理TaskTaskPushNotificationConfigCreateTaskPushNotificationConfigAsync(CreateTaskPushNotificationConfigRequestrequest,CancellationTokencancellationTokendefault);TaskTaskPushNotificationConfigGetTaskPushNotificationConfigAsync(GetTaskPushNotificationConfigRequestrequest,CancellationTokencancellationTokendefault);TaskListTaskPushNotificationConfigResponseListTaskPushNotificationConfigAsync(ListTaskPushNotificationConfigRequestrequest,CancellationTokencancellationTokendefault);TaskDeleteTaskPushNotificationConfigAsync(DeleteTaskPushNotificationConfigRequestrequest,CancellationTokencancellationTokendefault);// 4. AgetCard扩展TaskAgentCardGetExtendedAgentCardAsync(GetExtendedAgentCardRequestrequest,CancellationTokencancellationTokendefault);}2. 针对JSON-RPC的实现既然是对A2A协议的表达IA2AClient接口自然与具体的传输协议无关但是具体的实现则不得不考虑底层采用的传输协议。如下所示的A2AClient类型是针对JSON-RPC的实现。我们在初始化A2AClient对象的时候只需要提供A2A Server的基础地址和一个可选的HttpClient对象。具体的实现很简单不外乎就是使用操作对应的Method为请求封装成JSON-RPC封套以POST形式发送。如果采用流式调用由于服务端会采用SSE实时回传生成的内容这里只需要采用对应的方式解析SSE数据项即可。publicsealedclassA2AClient:IA2AClient,IDisposable{publicA2AClient(UribaseUrl,HttpClient?httpClientnull);...}如下所示的是采用A2AClient以阻塞方式调用Agent的例子。usingA2A;usingAzure.AI.Projects;usingDotNetEnv;usingMicrosoft.Agents.AI.Hosting;usingMicrosoft.Extensions.AI;usingOpenAI;usingOpenAI.Responses;usingSystem.ClientModel;Env.Load();varapiKeyEnvironment.GetEnvironmentVariable(OPENAI_API_KEY)!;varendpointEnvironment.GetEnvironmentVariable(OPENAI_BASE_URL)!;varagentnewOpenAIClient(credential:newApiKeyCredential(key:apiKey),options:newOpenAIClientOptions{EndpointnewUri(endpoint)}).GetResponsesClient().AsAIAgent(model:gpt-5.4-mini,name:a2a-agent,instructions: 你是一个深谙中国古代历史的专家善于根据正史以公正客观的态度于人交流历史问题。 对于用户提出的问题请以简介概括性的语言予以答复字数尽量保持在200字以内。);varbuidlerWebApplication.CreateBuilder();buidler.Services.AddA2AServer(agent.Name!).AddAIAgent(agent.Name!,(services,anme)agent);varurlhttp://localhost:3721/;buidler.WebHost.UseUrls(url);varappbuidler.Build();app.MapA2AJsonRpc(agent,/);awaitapp.StartAsync();usingvarclientnewA2AClient(newUri(url));varprompt春秋初霸郑庄公寤生为何没有成为春秋五霸是因为郑国不够强大吗;varrequestnewSendMessageRequest{MessagenewMessage{RoleRole.User,Parts[newPart{Textprompt}]},};varresponseawaitclient.SendMessageAsync(request);foreach(varpartinresponse.Message!.Parts){Console.WriteLine(part.Text);}输出不完全是。郑庄公在春秋初年确实一度称霸尤其在“周郑交质”“射王中肩”等事件后威望很高但郑国的霸业有明显局限 一是国土狭小、人口与资源有限难以长期支撑霸权 二是地处四战之地易受周边大国夹击 三是郑庄公之后继承者能力不足国力很快衰落。 “春秋五霸”本身也是后世概括通常重在齐桓公、晋文公等更具持续影响者所以郑庄公常被视为“春秋初霸”而不列入五霸。如果希望通过逐字输出的效果可以按照如下的方式采用流式调用awaitforeach(varresponseinclient.SendStreamingMessageAsync(request)){foreach(varpartinresponse.Message!.Parts){Console.Write(part.Text);}}3. 针对HTTP-JSON的实现如果A2A Server是采用HTTP-JSON协议构建那么就需要使用如下这个对应的客户端类型A2AHttpJsonClient。它与OpenAIClient具有完全一致的构造函数定义。publicsealedclassA2AHttpJsonClient:IA2AClient,IDisposable{publicA2AHttpJsonClient(UribaseUrl,HttpClient?httpClientnull);...}我们将上面演示的程序切换成HTTP-JSON协议并采用A2AHttpJsonClient作为调用客户端。usingA2A;usingAzure.AI.Projects;usingDotNetEnv;usingMicrosoft.Agents.AI.Hosting;usingMicrosoft.Extensions.AI;usingOpenAI;usingOpenAI.Responses;usingSystem.ClientModel;Env.Load();varapiKeyEnvironment.GetEnvironmentVariable(OPENAI_API_KEY)!;varendpointEnvironment.GetEnvironmentVariable(OPENAI_BASE_URL)!;varagentnewOpenAIClient(credential:newApiKeyCredential(key:apiKey),options:newOpenAIClientOptions{EndpointnewUri(endpoint)}).GetResponsesClient().AsAIAgent(model:gpt-5.4-mini,name:a2a-agent,instructions: 你是一个深谙中国古代历史的专家善于根据正史以公正客观的态度于人交流历史问题。 对于用户提出的问题请以简介概括性的语言予以答复字数尽量保持在200字以内。);varbuidlerWebApplication.CreateBuilder();buidler.Services.AddA2AServer(agent.Name!).AddAIAgent(agent.Name!,(services,anme)agent);varurlhttp://localhost:3721/;buidler.WebHost.UseUrls(url);varappbuidler.Build();app.MapA2AHttpJson(agent,/);awaitapp.StartAsync();usingvarclientnewA2AHttpJsonClient(newUri(url));varprompt春秋初霸郑庄公寤生为何没有成为春秋五霸是因为郑国不够强大吗;varrequestnewSendMessageRequest{MessagenewMessage{RoleRole.User,Parts[newPart{Textprompt}]},};Console.WriteLine(${newstring(-,20)}SendMessageAsync{newstring(-,20)});varresponseawaitclient.SendMessageAsync(request);foreach(varpartinresponse.Message!.Parts){Console.WriteLine(part.Text);}Console.WriteLine(${newstring(-,20)}SendStreamingMessageAsync{newstring(-,20)});awaitforeach(varupdateinclient.SendStreamingMessageAsync(request)){foreach(varpartinupdate.Message!.Parts){Console.Write(part.Text);}}Console.ReadLine();输出--------------------SendMessageAsync-------------------- 不是主要因为“郑国不够强大”而是郑庄公的霸业更偏“春秋初期的权力中心”难以长期维持。 郑庄公确实曾挟强郑、制诸侯、周旋王室一度有霸主气象但郑国地处中原四战之地国小地狭战略纵深不足加之庄公死后国力迅速下滑未能形成持续稳定的霸权体系。 而后来的“五霸”多是长期扩张、能整合资源并持续主盟的强国君主所以郑庄公虽有“初霸”之名终究未列入传统春秋五霸。 --------------------SendStreamingMessageAsync-------------------- 不只是“郑国不够强大”更关键是郑庄公的霸业具有明显的**短暂性和局部性**。 春秋初年“霸”多指能号令诸侯、主持会盟者郑庄公虽曾挟王室、败强邻威震一时但其影响主要限于中原局部且未形成长期稳定的盟主地位。 此后郑国国力有限又屡受宋、楚、齐等国压力难以延续霸权。后来“五霸”之所以被后世定型更多是因为其霸业更持久、影响更大、史书叙事也更集中。