事件
Laravel 事件机制实现了一个简单的观察者模式,来订阅和监听在应用中出现的各种事件,事件类通常被保存在 目录下,而它们的监听器被保存在 app/Listeners
目录下。如果你在应用中看不到这些文件夹也不要担心,当你用 Artisan 命令来生成事件和监听器的时候他们就会被创建了。
事件机制是一种很好的应用解耦方式,因为一个事件可以拥有多个互不依赖的监听器。举例来说,每次你把用户的订单发完货后都会希望给他发个 Slack 通知。这时候你就可以发起一个 OrderShipped
事件,它会被对应的监听器接收到再传递给 Slack 通知模块,这样你就不用把订单处理的代码跟 Slack 通知的代码耦合在一起了。
注册事件和监听器
包含在你 Laravel 应用中的 EventServiceProvider
提供了一个很方便的地方来注册所有的事件监听器。listen
属性是一个数组,它包含了所有事件(键)以及事件对应的监听器(值)。你也可以根据应用需求来增加事件到这个数组,例如,我们增加一个 OrderShipped
事件:
手动创建事件和监听器是很麻烦的,简单的方式是,在 EventServiceProvider
中写上事件和监听器然后使用 event:generate
命令。这个命令会自动生成在 EventServiceProvider
中列出的所有事件和监听器,当然已经存在的事件和监听器将保持不变:
php artisan event:generate
手动注册事件
一般来说,事件必须通过 EventServiceProvider
的 $listen
数组进行注册;不过,你也可以通过 Event
facade 或是 Illuminate\Contracts\Events\Dispatcher
contract 实现的事件发送器来手动注册事件:
/**
* 注册你应用程序中的任何其它事件。
*
* @param \Illuminate\Contracts\Events\Dispatcher $events
* @return void
*/
public function boot(DispatcherContract $events)
{
parent::boot($events);
$events->listen('event.name', function ($foo, $bar) {
//
});
}
一个事件类是包含了相关事件信息的数据容器。例如,假设我们生成的 OrderShipped
事件接收一个 Eloquent ORM 对象:
定义监听器
接下来,让我们看一下例子中事件的监听器。事件监听器的 handle
方法接收了事件实例。event:generate
命令将会在事件的 handle
方法中自动加载正确的事件类和类型提示。在 handle
方法内,你可以运行任何需要响应该事件的业务逻辑。
<?php
namespace App\Listeners;
use App\Events\OrderShipped;
{
/**
* 创建事件监听器。
*
* @return void
*/
public function __construct()
//
}
/**
* 处理事件。
*
* @param OrderShipped $event
* @return void
*/
public function handle(OrderShipped $event)
{
// 使用 $event->order 来访问 order ...
}
}
停止事件传播
有时候,你可能希望停止一个事件传播到其它的监听器。你可以通过在侦听器的 handle
方法中返回 false
来实现。
如果你对监听器要实现耗时任务比如发邮件或者进行 HTTP 请求,那把它放到队列中处理是有好处的。在使用队列化监听器之前,一定要在服务器或者本地开发环境中 并且开启一个队列监听器。
要指定一个监听器应该队列化的话,增加 ShouldQueue
接口到你的监听器类就好了。由 event:generate
Artisan 命令生成的侦听器已经将此接口导入到命名空间了,因此可以像这样来立即使用它:
<?php
namespace App\Listeners;
use App\Events\OrderShipped;
use Illuminate\Contracts\Queue\ShouldQueue;
class SendShipmentNotification implements ShouldQueue
{
//
}
就这样!现在,当这个监听器被调用时,事件分发器会使用 Laravel 的 队列系统 自动将它进行队列化。如果监听器通过队列运行而没有抛出任何异常,则已执行完的任务将会自动从队列中被删除。
手动访问队列
如果你需要手动访问底层队列任务的 delete
和 release
方法,你可以使用 Illuminate\Queue\InteractsWithQueue
trait 来实现。这个 trait 在生成的监听器中是默认加载的,它提供了这些方法:
如果要触发一个事件,你可以发送一个事件的实例到 event
辅助函数。这个函数将会把事件分发到它所有已经注册的监听器上。因为 event
函数是全局可访问的,所以你可以在应用中任何地方调用:
<?php
namespace App\Http\Controllers;
use App\Order;
use App\Events\OrderShipped;
use App\Http\Controllers\Controller;
class OrderController extends Controller
{
/**
* 将传递过来的订单发货
*
* @return Response
public function ship($orderId)
{
$order = Order::findOrFail($orderId);
// 订单的发货逻辑...
event(new OrderShipped($order));
}
}
事件订阅者
事件订阅者是一个在自身内部可以订阅多个事件的类,允许你在单个类内定义多个事件的处理器。订阅者应该定义一个 subscribe
方法,这个方法将被传递过来一个事件分发器的实例。你可以调用事件分发器的 listen
方法来注册事件监听器:
<?php
namespace App\Listeners;
class UserEventListener
{
/**
* 处理用户登录事件。
*/
public function onUserLogin($event) {}
/**
* 处理用户注销事件。
*/
public function onUserLogout($event) {}
/**
* 为订阅者注册监听器。
*
* @param Illuminate\Events\Dispatcher $events
*/
public function subscribe($events)
{
$events->listen(
'App\Events\UserLoggedIn',
'App\Listeners\UserEventListener@onUserLogin'
);
$events->listen(
'App\Events\UserLoggedOut',
'App\Listeners\UserEventListener@onUserLogout'
);
}
}
注册事件订阅者
一旦订阅者被定义,它就可以被注册到事件分发器中。你可以在 EventServiceProvider
中使用 $subscribe
属性注册订阅者。例如,我们增加 UserEventListener
到列表中: