PHP使用标准库spl实现的观察者模式示例

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 28 4

<?php/** * Created by PhpStorm. * User: evolution * Date: 14-12-27 * Time: 下午5:50 */class Login implements SplSubject {  private $storage;  public $status;  public $ip;  const LOGIN_ACCESS = 1;  const LOGIN_WRONG_PASS = 2;  const LOGIN_USER_UNKNOWN = 3;  function __construct(){    $this->storage = new SplObjectStorage();  }  function attach (SplObserver $observer) {    $this->storage->attach($observer);  }  function detach(SplObserver $observer){    $this->storage->detach($observer);  }  function notify(){    foreach ($this->storage as $obs) {      $obs->update($this);    }  }  /**   * @author jichao.wang   * 执行登陆   */  function handleLogin()  {    $ip = rand(1,100);    switch (rand(1, 3)) {      case 1:        $this->setStatus(self::LOGIN_ACCESS, $ip);        $ret = true;        break;      case 2:        $this->setStatus(self::LOGIN_WRONG_PASS, $ip);        $ret = false;        break;      case 3:        $this->setStatus(self::LOGIN_USER_UNKNOWN, $ip);        $ret = false;        break;    }    /**     * handle event     */    $this->notify();    return $ret;  }  /**   * @param $status   * @author jichao.wang   * set login status   */  function setStatus($status,$ip)  {    $this->status = $status;    $this->ip = $ip;  }  /**   * @return mixed   * @author jichao.wang   * get login status   */  function getStatus()  {    return $this->status;  }}/** * 只针对登陆的贯观察者 * Class LoginObserver */abstract class LoginObserver implements SplObserver {  private $login;  function __construct(Login $login){    $this->login = $login;    $login->attach($this);  }  /**   * 对外统一的访问点   * @param SplSubject $subject   */  function update( SplSubject $subject ){    if($subject === $this->login){      $this->doUpdate($subject);    }  }  abstract function doUpdate( Login $login );}/** * Class EmailObserver */class EmailObserver extends LoginObserver{  //不同功能的观察者实现不同的功能  function doUpdate( Login $login ){    $status = $login->getStatus();    if($status == Login::LOGIN_ACCESS){//      $this->sendMail('用户ip:'.$observable->ip.'登陆成功!');      echo __CLASS__.'用户ip:'.$login->ip.'登陆成功!'.'------------------';    }    if($status == Login::LOGIN_WRONG_PASS){//      $this->sendMail('用户ip:'.$observable->ip.'登陆失败，密码错误!');      echo __CLASS__.'用户ip:'.$login->ip.'登陆失败，密码错误!'.'------------------';    }    if($status == Login::LOGIN_USER_UNKNOWN){//      $this->sendMail('用户ip:'.$observable->ip.'登陆失败，无此用户!');      echo __CLASS__.'用户ip:'.$login->ip.'登陆失败，无此用户!'.'------------------';    }  }}//实例化登陆信息$login = new Login();//实现发邮件观察者new EmailObserver($login);//开始登陆$login->handleLogin();

28 4 0

• AngularFire2 观察者

  AngularFire2 文档演示了以下将观察者绑定(bind)到您的 Firebase 可观察对象的模式: this.item = af.database.object('/item'); {{ (

• java - 观察者 - 阻塞队列

  我正在使用观察者模式和 BlockingQueue 添加一些实例。现在在另一种方法中，我正在使用队列，但似乎 take() 一直在等待，即使我这样做: /** {@inheritDoc} */ @Ov

• javascript - Angular 观察者

  我遇到问题 - 创建具有不同属性的订单。在我的工作案例中，用户有大约 10 个不同的属性，每个属性有 3-4 个变体。 我正在使用 Angular js，并编写了两个函数: 二传手 $scope

• magento - 添加额外的项目到购物车(观察者)

  我尝试将额外的产品添加到购物车。我为此创建了一个观察者。 getEvent()->getControllerAction()->getFullActionName() == 'checkout_car

• magento - 添加额外的项目到购物车(观察者)

  我尝试将额外的产品添加到购物车。我为此创建了一个观察者。 getEvent()->getControllerAction()->getFullActionName() == 'checkout_car

• 基于类型的 C# 观察者？

  假设我想创建一组基于类型的观察者。也就是说，当他们收到事件通知时，他们会被告知其中一个参数的类型，然后根据是否可以对该类型进行操作来决定是否采取行动。 有没有简单的方法可以做到这一点？我认为这对于泛型

• java - 观察者/可观察模式

  快速提问。 当 setChanged() 和 notifyObservers() 被调用并且 Observer.update() 运行时，它是否在一个新的 Thread，还是在同一个Thread中？

• Java 观察者/可观察者

  我必须为可观察对象和观察者创建代码。正如您所知，每个观察者都有自己的“更新”方法。 在我的可观察代码中，我使用了“notifyObservers”方法。它的参数是一个字符串数组，其中包含有关我的项目的

• java - 观察者/可观察模式的链接

  是否有一种设计模式可以形成“复合”观察者/可观察对象？ 我的意思是我有一个可观察的 A 通知它的听众一些变化。 每个监听器也是一个可观察对象，并通知自己的监听器(在它执行的某些操作中，哪个操作是由第一

• Android MediatorLiveData 观察者

  我对以下代码为何不起作用感到有点困惑: MutableLiveData mutableTest = new MutableLiveData<>(); MediatorLiveData mediator

• java - 使用导航组件多次触发 LiveData 观察者

  场景:我有两个名为 FirstFragment 的 fragment 和 UnitFragment .我来自 FirstFragment至UnitFragment选择一个单位返回FirstFragme

• RxJS - 多次调用 FlatMap 观察者

  我想了解如何 平面 map 作品。我知道这是处理 Observable> 的一种方式。 无论如何，我正在测试它的行为并陷入困境: let plusDom = document.querySelecto

• design-patterns - 观察者？设计模式

  我有 public class mammal implements Imammle { public String getName() { return "Mammal";

• iphone - 删除 AVPlayerItem 观察者

  如果我使用 KVO 来观察我的播放器项目，如下所示: AVPlayerItem *playerItem = [AVPlayerItem playerItemWithURL:url];

• javascript - Ember.js 观察者

  我想在正在使用的变量上使用观察者，这是我的代码: const get = Ember.get; uploader:Ember.inject.service('uploader'), progressC

• laravel - 在多个记录上触发 Laravel 观察者

  我一直在使用Laravel Observers每当我的模型被删除/更新/保存时处理我的应用程序逻辑。我注意到在某些情况下这些观察者不会被触发。例如，如果我使用 Model::where(active,

• java - 在工作人员中使用 Livedata 观察者

  我有一个工作人员服务来发送一些简单的通知。但现在，我想在发送之前检查数据库中的一些数据。 但是，我不能在工作线程中使用观察者，它必须在主线程中。我有一个错误类型 java.lang.IllegalSt

• java - 仅在用户输入时设置 Editview 观察者？

  我有 2 个字段:美元和日元。当我更改美元字段时，我想在日元字段中显示转换后的数字，反之亦然。 我的问题是这样的: 如果我有 2 个带有观察者的字段，例如: addTextChangedListene

• iphone - 如何移除 KVO 观察者？

  在 View Controller 中，我创建了一个 subview 数组，可以随时从父 View 中删除，因此它们的生命周期比 View Controller 的生命周期短。 创建它们时，我几乎这样

• java - 如何在另一个线程上运行 RxJava 观察者

  如何在另一个线程上运行 RxJava，因为主线程上的工作太多。 我在一个方法内运行观察者，下面是代码 fragment : public void updatePie() { RxJavaPlugin