更新Messenger处理程序中的实体(Symfony)

// Step 1: 创建一个消息类
class UpdateEntityMessage
{
    private $entityId;
    private $newProperty;

    public function __construct($entityId, $newProperty)
    {
        $this->entityId = $entityId;
        $this->newProperty = $newProperty;
    }

    public function getEntityId()
    {
        return $this->entityId;
    }

    public function getNewProperty()
    {
        return $this->newProperty;
    }
}

// Step 2: 创建一个消息处理程序
class UpdateEntityHandler implements MessageHandlerInterface
{
    private $entityManager;

    public function __construct(EntityManagerInterface $entityManager)
    {
        $this->entityManager = $entityManager;
    }

    public function __invoke(UpdateEntityMessage $message)
    {
        $entity = $this->entityManager->getRepository(Entity::class)->find($message->getEntityId());
        $entity->setProperty($message->getNewProperty());
        $this->entityManager->flush();
    }
}

// Step 3: 配置Messenger
# config/packages/messenger.yaml
framework:
    messenger:
        buses:
            messenger.bus.default:
                handlers:
                    - App\Message\UpdateEntityHandler

// Step 4: 发送消息
$message = new UpdateEntityMessage($entityId, $newProperty);
$this->dispatchMessage($message);

// Step 5: 处理消息
# Messenger将自动调用UpdateEntityHandler来处理消息