Method Receive

pkg/agent/actor.go:174–240

Receive 处理接收到的消息（Actor 核心方法）

(ctx *actor.Context, msg actor.Message)

// Receive 处理接收到的消息（Actor 核心方法）
func (a *AgentActor) Receive(ctx *actor.Context, msg actor.Message) {
	a.mu.Lock()
	a.stats.MessagesReceived++
	a.stats.LastMessageAt = time.Now()
	a.mu.Unlock()

	startTime := time.Now()

	defer func() {
		// 更新统计
		a.mu.Lock()
		a.stats.MessagesHandled++
		latency := time.Since(startTime)
		// 简单的移动平均
		a.stats.AverageLatency = (a.stats.AverageLatency + latency) / 2
		a.mu.Unlock()
	}()

	// 处理系统消息
	switch m := msg.(type) {
	case *actor.Started:
		agentLog.Debug(context.Background(), "agent actor started", map[string]any{"agent_id": a.agent.ID()})
		return

	case *actor.Stopping:
		agentLog.Debug(context.Background(), "agent actor stopping", map[string]any{"agent_id": a.agent.ID()})
		a.handleStop()
		return

	case *actor.Stopped:
		agentLog.Debug(context.Background(), "agent actor stopped", map[string]any{"agent_id": a.agent.ID()})
		return

	case *actor.Restarting:
		agentLog.Debug(context.Background(), "agent actor restarting", map[string]any{"agent_id": a.agent.ID()})
		return

	// 处理 Agent 业务消息
	case *SendMsg:
		a.handleSend(ctx, m)

	case *ChatMsg:
		a.handleChat(ctx, m)

	case *StreamMsg:
		a.handleStream(ctx, m)

	case *ToolCallMsg:
		a.handleToolCall(ctx, m)

	case *DirectToolCallMsg:
		a.handleDirectToolCall(ctx, m)

	case *BatchToolCallMsg:
		a.handleBatchToolCall(ctx, m)

	case *GetStatusMsg:
		a.handleGetStatus(ctx, m)