Symfony Doctrine EntityManager 无法正确刷新

Question

我有一个棘轮 WebSocket 服务器，其 entityManager 从后端初始化。但是，如果由于 WebSocket 服务器的 entityManager 状态与后端不同而导致前端之一发生某些更改，则新的更改不会反映在前端提供的数据中。 WebSocket 服务器。

为此，我在后端编写了一些侦听器，侦听这些实体中的更改，然后向服务器发送请求，如下所示：

public function postUpdate(Room $entity, LifecycleEventArgs $_)
{
    try {
        Loop::run(function() use ($entityName, $id) {
        $conn = yield connect('ws://localhost:8080');
        yield $conn->send(json_encode(['message' => $entityName, 'data' => ['duid' => $id]]));
        $conn->close();});
    } catch (Exception $e) {}
}

然后，我在 WebSocket 服务器中获取实体并简单地刷新它，如下所示

function onMessage(ConnectionInterface $from, $msg)
{
    try {
        $messageData = json_decode($msg);
        switch ($messageData->message) {
            case BookingSocketActions::ROOM_CHANGED_EVENT:
//                $room = $this->entityManager->getRepository('ResourcesBundle:Room')
//                                            ->find(['id' => $id]);
                $room = $this->entityManager->getRepository('ResourcesBundle:Room')
                                            ->findRoomDetailById($messageData->data->duid);
                // $this->entityManager->clear();
                $this->entityManager->refresh($room);
                break;
        }
    } catch (Exception $ex) {
        $from->send($ex);
    }
}

：奇怪的错误：WebSocket 服务器中刷新的 $entity 的状态总是落后于实体的真实变化。假设我将 $entity->name 从“1”更改为“2”。

刷新后，WebSocket 服务器上的 $entity->name 仍然为“1”。只有当我再次将其更改为其他内容（例如“3”）时，它才会更改为“2”（刷新后）。如果我将其更改为“4”，它将变为“3”，依此类推。

该事件从后端正确触发，并且在服务器上正确获取实体。只是 refresh() 仅适用于对 WebSocket 服务器的第二次请求（因此是第二次刷新），而不适用于第一个请求。

我什至尝试过类似 $entityManager->merge($entity); 但没有结果。

我使用的是 symfony 3.4、doctrine 2.7 和ratchet 0.4.3。

Answer 1

首先可能是检测更新变化而触发的事件。

如果您postPersist，则数据库中的实体不会发生更改。它会在flush发生之前触发。

您需要在flush之后触发发送到套接字服务器的消息。

第二件事是确保entityManager 实例分离并重新加载room 实体实例。这可以

使用$this->entityManager->getUnitOfWork()->clear(Room::class);来完成

在再次查询实体之前

$this->entityManager->getUnitOfWork()->clear(Room::class);
$room = $this->entityManager
        ->getRepository('ResourcesBundle:Room')
        ->findRoomDetailById($messageData->data->duid);

Answer 2

Doctrine 使用 身份映射

Websocket 服务器是一个守护进程，所有清理任务均由开发人员负责

使用

\Doctrine\ORM\EntityManager::find 带有 $lockMode 参数 = \Doctrine\DBAL\LockMode::NONE

或

调用 \Doctrine\ORM\EntityManager::find 之前的 >\Doctrine\ORM\EntityManager::clean 方法