laravel进阶系列--通过事件和事件监听实现服务解耦

简介

Laravel 事件提供了简单的观察着模式实现,允许你订阅和监听应用中的事件。事件类通常存放在 app/Events 目录。

监听器存放在 app/Listeners. 如果你在应用中没有看到这些目录,不要担心,他们会在你使用Artisan命令生成事件和

监听器的时候自动创建。

事件为应用功能模块解耦提供了行之有效的解决方法,因为单个事件可以有多个监听器而这些监听器之间并不相互依赖。

例如,你可能想要在每次订单发送时给用户发送一个Slack通知,有了事件之后,你大可不必将订单处理代码和Slack

通知代码耦合在一起,而只需要简单触发一个可以被监听器接收并处理为Slack通知的 OrderShipped 事件即可。

注册事件/监听器

Laravel自动的 EventServerProvider 为时间监听其注册提供了方便之所。其中的listen属性包含了事件(键)和对应

监听器(值)数组.如果应用需要,你可以添加多个事件到给数组。下面让我们添加一个 OrderShipped事件:

生成事件/监听器类

当然,手动为每个事件和监听器创建文件是很笨重的,取而代之的,我们只需简单添加监听器和事件到EventServiceProvider

然后运行 event:generate 命令。该命令将会生成罗列在EventServiceProider 中的所有事件和监听器。当然,已存在

的事件和监听器不会被重复创建:

php artisan event:generate

手动注册事件

通常,我们需要通过 EventServiceProider 的$listen 数组注册事件,此外,你还可以在EventServiceProvider 的

boot方法中手动注册基于闭包的事件:

通配符事件监听器

你甚至还可以使用通配符*来注册监听器,这样就可以通过同一个监听器捕获多个事件。通配符监听器接收整个

事件数据数组作为参数:

定义事件

事件类是一个处理与事件相关的简单数据容器,例如,假设我们生成的 OrderShipped事件接收一个Eloquent ORM

对象:

<?php

namespace App\Events;

use App\Order;

use Illuminate\Queue\SerializesModels;

class OrderShipped

{

use SerializesModels;

public $orders;

/*

创建一个新的实践实例

@param Order $order

@return void

*/

public function __construct(Order $order)

{

  $this->order = $order;

}

正如你所看到的,该事件类不包含任何特定逻辑,只是一个存放被购买的Order对象的容器,如果时间对象被序列化的话,

事件使用的SerializeModels trait 将会使用过PHP的serialize函数序列化所有Eloquent模型。

定义监听器

接下来,让我们看看实例事件的监听器,事件监听器在 handle方法中接收事件实例,event:generate 命令将会自动

在 handle方法中导入相应的事件类和类型提示事件。在handle方法内,你可以执行任何需要的逻辑以响应时间:

<?php

namespace App\Listeners;

use App\Events\OrderShipped;

class SendShipmentNotification

{

/*

  创建事件监听器

@return void

*/

public function __construct()

{

}

/*

处理事件

@param OrderShipped $event

@return void

*/

public funcion handle(OrderShipped $event)

{

  //使用 $event->order 发访问订单...

}

}

?>

注: 事件监听器还可以在构造器中类型提示任何需要的依赖,所有事件监听器通过服务器解析,所以依赖会自动注入。

停止事件继续往下传播

有时候,你希望停止事件被传播到其他监听器,你可以通过从监听器的handle方法中返回false来实现。

事件监听器队列

如果监听器将要执行耗时任务比如发送邮件或者发送HTTP请求,那么将监听器放到队列是一个不错的选择。在队列化

监听器之前,确保已经配置好队列并且在服务器或本地环境启动一个队列监听器。

要指定某个监听器需要放到队列,只需要让监听器类实现 ShouldQueue 接口即可,通过Artisan命令event:generate

生成的监听器类已经将这个接口导入当前命名空间,所以你可以直接拿来使用:

<?php

namespace App\Listeners;

user App\Events\OrdersShipped;

use Illuminate\Contracts\Queue\ShowldQueue;

class SendShipmentNotification implements ShouldQueue

{

//

}

就是这么简单!当这个监听器被调用的时候,将会使用Laravel的队列系统通过事件分发器自动推送到队列。如果通过队列

执行监听器的时候没有抛出任何异常,队列任务会在执行完成后被自动删除。

自定义队列链接&队列名称

如果你想要自定义事件监听器使用的队列链接和队列名称,可以在监听器类中定义$connection 和$queue属性:

<?php

namespace App\Listeners;

use App\Events\OrdersShipped;

use Illuminate\Contracts\Queue\ShouldQueue

{

  /*

  任务将被推送到的链接名称

*/

  public $connection = ‘sqs‘;

  /*

  任务将被推送到的链接名称

  @var string|null

  */

  public $queue = ‘listeners‘;

}

手动访问队列

如果你需要手动访问底层队列任务的delete和release方法,在生成的监听器中,默认导入的Illuminate\Queue\InteractsWithQueue

trait 为这两个方法提供了访问权限:

<?php

namespace App\Listeners;

use App\Events\OrderShipped;

use Illuminate\Queue\InteractsWidthQueue;

use Illuminate\Contracts\Queue\ShowldQueue;

class SendShipmentNotification implements ShowldQueue

{

  use InteractsWithQueue;

  public function handle(OrderShipped $event)

  {

    if(true){

    $this->release(30);

  }

  }

}

处理失败任务

有时候队列中的事件监听器可能会执行失败。如果队列中的监听器任务执行时超出了队列进程定义的最大尝试次数,监听器上的

failed方法会被调用,failed方法接收事件实例和导致失败的异常:

分发事件

要分发一个事件,可以传递事件实例到辅助函数event,这个辅助函数会分发事件到所有注册的监听器。由于辅助函数恶女他

全局有效,所以可以在应用的任何地方调用它:

注: 测试的时候,只需要断言特定事件被分发,无需真正触发监听器,Laravel自带的测试函数让这一实现轻而易举

事件订阅者

编写事件订阅者

事件订阅者是指那些在类本身中订阅多个事件的类,通过事件订阅者你可以在单个类中定义多个事件处理器。订阅者需要定义一个

subscibe 方法,该方法中传入一个事件分发器实例。你可以在给定的分发器汇总调用listen方法注册事件监听器

原文地址:https://www.cnblogs.com/simadongyang/p/8455411.html

时间: 2024-10-16 03:22:30

laravel进阶系列--通过事件和事件监听实现服务解耦的相关文章

关于JAVA中事件分发和监听机制实现的代码实例-绝对原创实用

http://blog.csdn.net/5iasp/article/details/37054171 文章标题:关于JAVA中事件分发和监听机制实现的代码实例 文章地址: http://blog.csdn.net/5iasp/article/details/37054171 作者: javaboy2012Email:[email protected]qq:    1046011462 一.场景假设 假设有博客系统中需要实现如下功能: 系统中用户发布文章,修改文章,删除文章时,需要一些相关的操作

spring 自定义事件发布及监听(简单实例)

前言: Spring的AppilcaitionContext能够发布事件和注册相对应的事件监听器,因此,它有一套完整的事件发布和监听机制. 流程分析: 在一个完整的事件体系中,除了事件和监听器以外,还应该有3个概念: 1. 事件源:事件的产生者,任何一个event都必须有一个事件源: 2. 事件广播器:它是事件和事件监听器之间的桥梁,负责把事件通知给事件监听器: 3. 事件监听器注册表:就是spring框架为所有的监听器提供了一个存放的地方: 通过流程图,可以看出它们是如何各司其职的,如下: 其

LINUX启动ORACLE监听和服务

可通过secureCRT或者telnet直接连 启动监听命令:lsnrctl start 成功启动后:sqlplus /nolog 回车 conn / as sysdba 回车 startup 回车 select * from user_tables; 回车 有结果,ok 启动监听和服务成功 附由于无服务导致的错误: 关于ORA-01034和ORA-27101的一种解决方法 1 先看oracle的监听和oracle的服务是否都启动了.启动oracle监听:cmd的命令行窗口下,输入lsnrctl

windows 启动关闭Oracle监听和服务 (转载)

经常要用数据库,让他自己启动的话,开机太慢,所以用命令启动方便点.   1.开启:     在运行中输入cmd,进入控制台,lsnrctl start回车,提示启动监听成功后 net start OracleServiceORCL.2 关闭     在运行中输入cmd,进入控制台,lsnrctl stop回车,提示启动监听成功后 net stop OracleServiceORCL.这样还是不太方便.     在桌面右键,新建一个记事本,输入 lsnrctl start net start Or

windows 启动关闭Oracle监听和服务

经常要用数据库,让他自己启动的话,开机太慢,所以用命令启动方便点.    1.开启:     在运行中输入cmd,进入控制台,lsnrctl start回车,提示启动监听成功后 net start OracleServiceORCL. 2 关闭     在运行中输入cmd,进入控制台,lsnrctl stop回车,提示启动监听成功后 net stop OracleServiceORCL. 这样还是不太方便.     在桌面右键,新建一个记事本,输入 lsnrctl start net start

Oracle监听网络服务全面剖析_超越OCP精通Oracle视频教程培训06

课程目标 Oracle视频教程,风哥oracle教程培训学习内容包括,Oracle监听概念与常用配置文件,监听工具与服务测试,oracle监听静态注册与动态注册,配置oracle第二监听,oracle监听与客户端配置,Oracle监听日志配置与日常维护规范,Oracle监听安全与密码管理及防火墙,db_link与进程,如何跟踪问题深入分析等超越oracle认证的数据库教程 适用人群 IT相关从业人员.Oracle数据库技术人员.想加工资的.想升职的都可以. 课程简介 Oracle监听网络服务全面

巧用 即刻搜索事件 input propertychange 监听输入框字数

实时监听输入框的字数,大于200时,不再输入. 即时搜索: propertychange(ie)和input事件(常用) input是标准的浏览器事件,一般应用于input元素,当input的value发生变化就会发生,无论是键盘输入还是鼠标黏贴的改变都能及时监听到变化 propertychange,只要当前对象属性发生改变.(IE专属的) <div class="container js_container"> <div class="weui-cells

JavaScript之事件概念和监听事件

1.事件的概念: JavaScript使我们有能力创建动态页面,网页中的每一个元素都可以产生某些触发JavaScript函数的事件.我们可以认为事件是可以被JavaScript侦测到的一种行为. 2.事件流: 事件流主要分为冒泡型事件和捕获型事件.IE浏览器目前只支持冒泡型事件,而支持标准DOM的浏览器比如火狐.Chrome等两者都支持. 3.使用返回值改变HTML元素的默认行为: HTML元素大都包含了自己的默认行为,例如:超链接.提交按钮等.我们可以通过在绑定事件中加上"return fal

EditText输入事件截获与监听

本节介绍一下EditText中进行文字截获和事件监听.   预期目标:如下图,输入框中每输入一个字符,下面的TextView可以迅速的显示出来输入框中的内容   1.第一种实现方法:使用setOnKeyListener(),不过这种方式只能监听硬键盘事件 Java代码   edittext.setOnKeyListener(new View.OnKeyListener() { @Override public boolean onKey(View v, int keyCode, KeyEvent