Symfony DDD+事件溯源中关联对象的持久化与查询问题

在Event Sourcing结合DDD的架构里，处理关联对象的核心原则是领域事件只传递标识，而非完整的实体/投影对象——这也是你遇到序列化和级联持久化问题的根源。我来一步步帮你梳理解决方案：

1. 重构领域事件，传递用户标识而非UserView对象 #

你的StreamWasCreated事件目前依赖查询侧的UserViewInterface，这是典型的层间耦合问题。领域事件属于领域层，不应该依赖查询层的投影模型。我们需要把事件的构造参数换成用户的UUID：

// 原来的事件构造函数
// public function __construct(UuidInterface $streamUuid, UserViewInterface $user)

// 重构后的事件构造函数
public function __construct(
    private readonly UuidInterface $streamUuid,
    private readonly UuidInterface $userId,
    // 其他必要的业务字段，比如流名称等
) {}

这样做的好处：

• 事件序列化时只需要处理简单的UUID类型，完全避免复杂对象的序列化问题
• 领域层不再依赖查询层的投影，符合DDD的边界隔离原则

2. 调整投影处理器，通过标识关联已存在的UserView #

当处理StreamWasCreated事件生成StreamView投影时，我们需要从查询仓储中通过userId获取已存在的UserView对象，再关联到StreamView上：

// StreamProjector.php
public function handleStreamWasCreated(StreamWasCreated $event): void
{
    // 从UserView仓储中查询已存在的用户投影
    $userView = $this->userViewRepository->find($event->userId());
    
    if (!$userView) {
        // 根据业务场景处理，比如抛出异常（因为创建Stream前User应该已经存在）
        throw new \RuntimeException(sprintf('User with ID %s not found', $event->userId()->toString()));
    }

    // 创建StreamView并关联已查询到的UserView
    $streamView = new StreamView(
        $event->streamUuid(),
        $userView,
        // 其他流属性
    );

    $this->streamViewRepository->save($streamView);
}

这种方式不会触发Doctrine的级联持久化，因为UserView是从EntityManager管理的仓储中获取的已持久化对象，而非新创建的实例。

3. 理解领域层与查询层的边界 #

你之前的错误本质是混淆了领域层和查询层的职责：

• 领域层（Stream实体、StreamWasCreated事件）只负责处理业务规则，传递必要的业务标识（比如userId），不关心查询侧的投影结构
• 查询层（StreamView、UserView）是为了优化查询而构建的读模型，应该通过领域事件触发，从仓储中关联已存在的投影对象

4. 可选：传递值对象补充用户信息（如果需要） #

如果你的业务需要在事件中传递少量用户信息（比如用户名，避免查询时再次关联），可以定义一个可序列化的值对象，而非传递完整的UserView：

// 定义UserInfo值对象
class UserInfo
{
    public function __construct(
        public readonly UuidInterface $userId,
        public readonly string $username
    ) {}

    // 实现JsonSerializable接口，确保可序列化
    public function jsonSerialize(): array
    {
        return [
            'userId' => $this->userId->toString(),
            'username' => $this->username,
        ];
    }

    // 静态方法用于从数组反序列化
    public static function fromArray(array $data): self
    {
        return new self(
            Uuid::fromString($data['userId']),
            $data['username']
        );
    }
}

然后在StreamWasCreated事件中传递这个值对象，投影处理时既可以用userId关联UserView，也可以直接使用值对象里的信息填充视图。

内容的提问来源于stack exchange，提问作者Lukas Koza