Function main

examples/a2a/main.go:46–201

()

}

func main() {
	fmt.Println("=== A2A 协议示例 ===")
	fmt.Println()

	// 1. 创建 Actor System
	system := actor.NewSystem("a2a-demo")
	defer system.Shutdown()
	fmt.Println("✅ Actor System 已创建")
	fmt.Println()

	// 2. 创建并注册 Agent Actor
	agent := &SimpleAgent{}
	system.Spawn(agent, "demo-agent")
	fmt.Println("✅ Agent Actor 已注册: demo-agent")
	fmt.Println()

	// 3. 创建 A2A Server
	taskStore := a2a.NewInMemoryTaskStore()
	a2aServer := a2a.NewServer(system, taskStore)
	fmt.Println("✅ A2A Server 已创建")
	fmt.Println()

	// 4. 获取 Agent Card
	fmt.Println("--- 步骤 1: 获取 Agent Card ---")
	card, err := a2aServer.GetAgentCard("demo-agent")
	if err != nil {
		log.Fatalf("获取 Agent Card 失败: %v", err)
	}

	cardJSON, _ := json.MarshalIndent(card, "", "  ")
	fmt.Printf("Agent Card:\n%s\n\n", cardJSON)

	// 5. 发送消息 (message/send)
	fmt.Println("--- 步骤 2: 发送消息 (message/send) ---")
	params := a2a.MessageSendParams{
		Message: a2a.Message{
			MessageID: "msg-001",
			Role:      "user",
			Parts: []a2a.Part{
				{Kind: "text", Text: "你好! 这是一个 A2A 协议测试消息。"},
			},
			Kind: "message",
		},
		ContextID: "context-001",
	}
	paramsJSON, _ := json.Marshal(params)

	req := &a2a.JSONRPCRequest{
		JSONRPC: "2.0",
		ID:      "req-001",
		Method:  "message/send",
		Params:  json.RawMessage(paramsJSON),
	}

	ctx := context.Background()
	resp := a2aServer.HandleRequest(ctx, "demo-agent", req)

	if resp.Error != nil {