智能体间通信协议A2A：原理与Java实践

<dependency>
    <groupId>com.alibaba.cloud.ai</groupId>
    <artifactId>agentscope-core</artifactId>
    <version>0.1.0</version>
</dependency>

import com.alibaba.cloud.ai.agentscope.core.agent.Agent;
import com.alibaba.cloud.ai.agentscope.core.agent.AgentMeta;
import com.alibaba.cloud.ai.agentscope.core.message.Message;

public class CalculatorAgent implements Agent {
    @Override
    public AgentMeta getMeta() {
        // 定义智能体的元信息，包括名称、能力和描述
        return new AgentMeta("CalculatorAgent",
                             "Provides calculation services",
                             new String[]{"calculate", "add", "subtract"});
    }

    @Override
    public Message call(Message request) {
        // 处理请求并返回响应
        String task = request.getContent();
        // 简单的解析逻辑，实际中可能更复杂
        if (task.contains("add")) {
            String result = performAdd(task);
            return new Message("response", result);
        }
        // ... 其他处理逻辑
        return new Message("response", "Unknown task");
    }

    private String performAdd(String task) {
        // 实现具体的计算逻辑
        return "Result: 10";
    }
}

import com.alibaba.cloud.ai.agentscope.core.agent.AgentManager;
import com.alibaba.cloud.ai.agentscope.core.agent.AgentRegistry;

public class AgentSetup {
    public static void main(String[] args) {
        // 初始化AgentManager，它负责管理智能体的注册和发现
        AgentManager manager = new AgentManager();

        // 创建并注册计算器智能体
        CalculatorAgent calculator = new CalculatorAgent();
        manager.registerAgent(calculator);

        // 模拟另一个智能体（请求方）调用计算器智能体
        // 在实际A2A协议中，请求方会通过注册中心发现CalculatorAgent
        Message request = new Message("request", "add 5 and 5");
        Message response = calculator.call(request);

        System.out.println("Response from CalculatorAgent: " + response.getContent());
    }
}

// 伪代码示例：使用A2A客户端调用远程智能体
import com.alibaba.cloud.ai.agentscope.core.client.A2AClient;

public class A2AExample {
    public static void main(String[] args) {
        // 创建A2A客户端，指向注册中心或特定智能体端点
        A2AClient client = new A2AClient("registry-endpoint");

        // 通过智能体名称或能力查找目标智能体
        String targetAgent = "CalculatorAgent";

        // 发送请求
        Message request = new Message("request", "subtract 10 and 3");
        Message response = client.invoke(targetAgent, request);

        System.out.println("Remote Response: " + response.getContent());
    }
}