Symfony异步消息Bus执行时出现Doctrine关联实体持久化错误

问题原因 #

异步处理时，你从控制器传递给消息的User实体处于脱管状态（detached）。因为异步消息在独立进程中运行，每个进程的EntityManager完全独立——控制器里的User对象被序列化后传到消息处理器，此时这个对象不在当前EntityManager的管理范围内。当你把它关联到新的Activity并执行persist时，EntityManager会误以为这个User是未持久化的新实体，从而抛出级联持久化的错误。

解决步骤 #

核心思路：不要直接传递实体对象，传递实体ID，在消息处理器中重新从数据库加载User。

1. 修改StartLoadingMessage，改为传递用户ID：

class StartLoadingMessage
{
    public function __construct(private int $userId) {}

    public function getUserId(): int
    {
        return $this->userId;
    }
}

2. 控制器中传递用户ID而非实体：

$userId = $this->getUser()->getId();
$messageBus->dispatch(new StartLoadingMessage($userId));

3. 消息处理器中注入EntityManager，重新加载User：

use Doctrine\ORM\EntityManagerInterface;
use App\Entity\User;

class StartLoadingMessageHandler implements MessageHandlerInterface
{
    public function __construct(
        private StravaRequests $startLoading,
        private EntityManagerInterface $em
    ) {}

    public function __invoke(StartLoadingMessage $message)
    {
        $user = $this->em->getRepository(User::class)->find($message->getUserId());
        
        if (!$user) {
            throw new \RuntimeException('用户不存在');
        }

        $this->startLoading->startLoading($user);
    }
}

4. 原有的Activity持久化和User更新代码无需改动：
   因为现在加载的User处于EntityManager的管理状态（managed），关联到Activity后persist($newActivity)会正常识别User是已存在的实体；更新User属性后直接flush()也能正常同步到数据库，不需要额外调用persist($user)。

额外说明 #

• 你之前设置的cascade:['persist']是针对EntityManager管理中的实体生效的，脱管状态的实体不适用，所以即使加了这个配置也解决不了问题。
• 异步消息中传递实体对象很容易引发这类状态不一致的问题，最佳实践始终是传递实体ID，在处理器中重新加载。

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