README

Symfony2 Bundle for EventBand 框架

快速开始

将 event-band 添加到 symfony2 项目中

运行以下命令

$ composer require "event-band/symfony-bundle:~1.0"
$ composer require "event-band/amqplib-transport:~1.0"

简单配置

创建一个事件

创建一个事件，继承 EventBand\Adapter\Symfony\SerializableSymfonyEvent

<?php
namespace Acme\EventBundle\Event;
use EventBand\Adapter\Symfony\SerializableSymfonyEvent;

class EchoEvent extends SerializableSymfonyEvent
{
    /**
     * @var string
     **/
    protected $message;

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

    public funciton getMessage()
    {
        return $this->message;
    }
    
    protected function toSerializableArray()
    {
        $array = parent::toSerializableArray();
        $array['message'] = $this->message;

        return $array;
    }
    
    protected function fromUnserializedArray(array $data)
    {
        parent::fromUnserializedArray($data);
        $this->message = $data['message'];
    }
}

创建一个监听器

然后创建一个监听器

<?php
namespace Acme\EventBundle\Event;

class EchoEventListener
{
    public function onEchoEvent(EchoEvent $event)
    {
        // don't do such things on production
        echo $event->getMessage();
        echo "\n";
    }
}

并在 services.xml 中注册监听器

<service id="acme.event_bundle.event.event_listener" class="Acme\EventBundle\EchoEventListener">
     <tag name="kernel.event_listener" event="event.echo" method="onEchoEvent"/>
</service>

配置 bands

将以下行添加到您的 config.yml 中

event_band:
     publishers:
         acme.echo.event.publisher:
             events: ["event.echo"]
             transport:
                 amqp:
                     exchange: acme.echo.event.exchange
     consumers:
         acme.echo.event: ~

将 band 信息添加到监听器以使其异步

在事件监听器标签中添加参数 band 和消费者名称，以显示它属于哪个消费者。

<service id="acme.event_bundle.event.event_listener" class="Acme\EventBundle\EchoEventListener">
     <tag name="kernel.event_listener" event="event.echo" method="onEchoEvent" band="acme.echo.event"/>
</service>

创建 AMQP 配置

此步骤不是必需的，但拥有此配置非常有用。在 event_band 空间下，将以下行添加到您的 config.yml 中

    transports:
         amqp:
             driver: amqplib
             connections:
                 default:
                     exchanges:
                         acme.echo.event.exchange: ~
                     queues:
                         acme.echo.event:
                             bind:
                                 acme.echo.event.exchange: ['event.echo']

现在您可以使用 app/console event-band:setup amqp:default 命令自动创建/修改所有交换机、队列和绑定。

使用异步事件

在您的代码中某个位置，使用事件调度器以通常的方式分发 EchoEvent。

$dispatcher = $this->getContainer()->get('event_dispatcher');
$dispatcher->dispatch('event.echo', new EchoEvent('Hi, guys!'));

运行此代码时，事件将被推送到 acme.echo.event 队列。现在运行带有您的消费者名称的命令 event-band:dispatch acme.echo.event。

sh$ app/cosole event-band:dispatch acme.echo.event
Hi, guys!

... 得到收益。

使用 JMSSerializer

添加依赖

运行 composer require "event-band/jms-serializer:~1.0" 命令

创建一个事件

<?php
namespace Acme\EventBundle\Event;

class EchoEvent implements \EventBand\Event
{
    /**
     * @var array
     * @JMS\Serializer\Annotation\Type("array")
     */
    private $data;

    public function __construct($message)
    {
        $this->date['message'] = $message;
    }

    public function getMessage()
    {
        return $this->data['message'];
    }
}

配置

在您的 config.yml 中 'event_band' 部分，添加以下行

serializers:
        serializer:
            jms:
                format: json

所有其他设置类似。