Php 如果在 APIPlatform 3.1 中的同一资源上使用处理器，Messenger 将无法工作

一种可能的解决方案是在您第一次保留Entity之后，在您的Processor中发送Message.可能不是那么干净，因为它需要更多的代码，但您可以更多地控制如何以及何时处理Message.此外，您也可以用DelayStamp来发送它.

在您的处理器中，我会像这样dispatch the Message:

final class MyEntityProcessor implements ProcessorInterface
{
    
    public function __construct(
        private ProcessorInterface $persistProcessor,
        private MessageBusInterface $bus,
    ) {
    }

    public function process($data, Operation $operation, array $uriVariables = [], array $context = [])
    {
        $result = $this->persistProcessor->process($data, $operation, $uriVariables, $context);

        // $data should be your MyEntity Entity.
        $this->bus->dispatch(new GenerateThumbMessage($data), [
            // wait 5 seconds before processing
            new DelayStamp(5000),
        ]);
        
        return $result;
    }
}

Create the Message,App\Message\GenerateThumbMessage.php:

class GenerateThumbMessage
{

    public function __construct(private readonly MyEntity $myEntity) {}

    public function getMyEntity(): MyEntity
    {
        return $this->myEntity;
    }

}

然后是create your MessageHandler App\Message\GenerateThumbMessageHandler.php:

final class GenerateThumbMessageHandler implements MessageHandlerInterface
{
    public function __construct(private EntityManagerInterface $em) {}

    public function __invoke(GenerateThumbMessage $generateThumbMessage)
    {
        $myEntity = $generateThumbMessage->getMyEntity();
        
        // your long running function to generate a thumbnail

        $this->em->persist($myEntity);
        $this->em->flush();
    }
}

您的messenger.yaml配置应该如下所示:

framework:
    messenger:
        transports:
            async: 'doctrine://default'

        routing:
            'App\Message\GenerateThumbMessage': async

在配置中，您已将Message配置为进行异步处理，而不是使用Entity.

类似的解决方案可以在API Platform documentation