异步 Symfony 事件

Question

我正在尝试使用https://github.com/fervo/FervoDeferredEventBundle 来让异步事件将数据存储在我的数据库中。事件已正确添加到 RabbitMQ 队列，但事件侦听器和事件本身永远不会执行。

我正在尝试两种方式：首先让侦听器完成这项工作，然后手动分派 deferevent。

有什么想法吗？ 谢谢！

我的代码：

在我的控制器中：

$event = new DeferEvent('save.data', new SaveDataEvent($data));
$this->get('event_dispatcher')->dispatch('fervo.defer', $event);

SaveDataEvent.php

<?php

namespace AppBundle\Event;

use Symfony\Component\EventDispatcher\Event;

class SaveDataEvent extends Event
{
    protected $data;

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

    public function getData()
    {
        return $this->data;
    }

    public function saveData()
    {
        $data = $this->getData();
        // do more stuff
    }
}

SaveDataListener.php

<?php

namespace AppBundle\EventListener;

use AppBundle\Event\SaveDataEvent;

class SaveDataListener
{

    /**
     * @var SaveDataEvent
     */
    public function onSendData(SaveDataEvent $event)
    {

        $data = $event->saveData();
    }
}

services.yml

app.save_data_listener:
        class: AppBundle\EventListener\SaveDataListener
        tags:
            -
                name: kernel.event_listener #fervo_deferred_event.listener
                event: send.data

Answer 1

阅读文档，您应该修复services.yml：

app.save_data_listener:
    class: AppBundle\EventListener\SaveDataListener
    tags:
        name: fervo_deferred_event.listener
        event: fervo.defer

如果需要，将fervo.defer 替换为传递给dispatch() 方法的第一个值，它是已调度事件的名称。