Method processMessage

pkg/actor/system.go:487–535

processMessage 处理单条消息

(cell *actorCell, env envelope)

// processMessage 处理单条消息
func (s *System) processMessage(cell *actorCell, env envelope) {
	// panic 恢复
	defer func() {
		if r := recover(); r != nil {
			if s.config.PanicHandler != nil {
				s.config.PanicHandler(cell.pid, env.message, r)
			}
			// 触发监督策略
			s.handleFailure(cell, env.message, r)
		}
	}()

	// 创建上下文，支持 Request/Response
	ctx := &Context{
		Self:     cell.pid,
		Sender:   env.sender,
		Parent:   cell.parent,
		Children: s.getChildrenPIDs(cell),
		system:   s,
		ctx:      cell.ctx,
		message:  env.message,
	}

	// 如果是 Request 模式，设置响应通道和请求 context
	if env.response != nil {
		ctx.responseChan = env.response
		ctx.requestCtx = env.ctx
	}

	// 处理系统消息
	switch msg := env.message.(type) {
	case *PoisonPill:
		// 发送 Stopping 消息
		cell.actor.Receive(ctx, &Stopping{})
		return

	case *Watch:
		cell.watchers[msg.Watcher.ID] = msg.Watcher
		return

	case *Unwatch:
		delete(cell.watchers, msg.Watcher.ID)
		return
	}

	// 处理用户消息
	cell.actor.Receive(ctx, env.message)
	atomic.AddInt64(&s.stats.ProcessedMsgs, 1)
}

// handleFailure 处理 Actor 失败
func (s *System) handleFailure(cell *actorCell, msg Message, err any) {