php设计模式之观察者模式

理解观察者模式

观察者模式定义了对象之间一对多的依赖,这样一来,当一个对象改变状态时,它的所有依赖者都会收到通知并自动更新。

不知道大家有没有订杂志的经历,理解了订杂志的应用就能理解观察者模式。想想看,如果我们不去订阅杂志,那么我们想要看最新的杂志,就需要主动去商场或书店去看一看,运气好会有最新杂志买,运气不好的话就会空手而归。但如果我们去订阅了该杂志,那么我们就不需要去商场或书店了,只要有新的杂志,邮局就会主动给我们送过里。但我们取消订阅了,那我们就不在订阅者的名单上,邮局就不会给我们送上来。

观察者模式里有两种角色:发布者、订阅者

发布者需要提供的功能有:订阅、取消订阅、当有新的状态时通知订阅者。当有新的状态通知订阅者后,订阅者会进行相关操作。

应用场景及缺点

当一个对象状态的改变需要改变其他对象,或实际对象是事先未知的或动态变化的时,可使用观察者模式。

它的缺点是,通知的顺序无法保证。

实现观察者模式

首先我们看一个应用场景:当系统有新的用户注册时我们需要:

  • 向用户发送信息通知
  • 更新总用户数量
  • 向用户赠送一张优惠券

UML类图

20200707113917 - php设计模式之观察者模式

代码实现

PHP 已经定义了 2 个接口用于快速实现观察者模式:SplObserver 和 SplSubject。这里我们不用php提供的接口,自己来完成。

首先定义Observer接口

interface Observer
{
   public function update ($userId);
}

然后是定义subject接口:

interface Subject
{
   public function register (Observer $o);
   public function remove (Observer $o);
   public function notify ($info = null);
}

再实现具体的发布者:

class UserRegisterSubject implements Subject
{
   private $observers = [];

   // 订阅
   public function register(Observer $o)
  {
       if (!in_array($o, $this->observers)) {
           $this->observers[] = $o;
      }
  }

   // 取消订阅
   public function remove(Observer $o)
  {
       if (($k = array_search($o, $this->observers)) >= 0) {
           unset($this->observers[$k]);
      }
  }

   // 通知订阅者
   public function notify($info = null)
  {
       foreach ($this->observers as $o) {
           $o->update($info);
      }
  }

   // 当有新用户注册时,触发notify方法
   public function userAdd ($userId)
  {
       $this->notify($userId);
  }
}

最后是订阅者的代码实现:

class Quan implements Observer
{
   public function update($userId)
  {
       echo "向用户{$userId}发送一张新人优惠券".PHP_EOL;
  }
}

class SendMsg implements Observer
{
   public function update($userId)
  {
       echo "向用户{$userId}发送站内信".PHP_EOL;
  }
}

class UserCnt implements Observer
{
   public function update($userId)
  {
       echo '更新用户总数量'.PHP_EOL;
  }
}

使用php已定义的接口快速实现

发布者代码

class UserRegisterSubject implements \SplSubject
{
   private $observers = [];
   private $userId = 0;

   public function attach (\SplObserver $o)
  {
       if (!in_array($o, $this->observers)) {
           $this->observers[] = $o;
      }
  }

   public function detach(\SplObserver $o)
  {
       if (($k = array_search($o, $this->observers)) >= 0) {
           unset($this->observers[$k]);
      }
  }

   public function notify()
  {
       foreach ($this->observers as $o) {
           $o->update($this);
      }
  }

   // 当有新用户注册时,触发notify方法
   public function userAdd ($userId)
  {
       $this->userId = $userId;
       $this->notify();
  }

   public function getter ($key)
  {
       if (isset($this->$key)) {
           return $this->$key;
      }
  }
}

订阅者代码:


class Quan implements \SplObserver
{
   public function update(\SplSubject $sub)
  {
       echo "向用户{$sub->getter('userId')}发送一张新人优惠券".PHP_EOL;
  }
}

class UserCnt implements \SplObserver
{
   public function update(\SplSubject $sub)
  {
       echo '更新用户总数量'.PHP_EOL;
  }
}

class SendMsg implements \SplObserver
{
   public function update(\SplSubject $sub)
  {
       echo "向用户{$sub->getter('userId')}发送站内信".PHP_EOL;
  }
}

发表评论

电子邮件地址不会被公开。 必填项已用*标注