设计模式第八讲-观察者模式

284 阅读4分钟

前言

设计模式停更了好久, 发现兜兜转转回来, 还是离开不了那些个套路.

今天我们主要讲解下 观察者模式, 可能你听这个名字感觉很熟, 如果给你说下还可以称它为 发布订阅 模式的话, 相信你对它就毫不陌生了.

观察者模式定义了一种一对多的依赖关系, 让多个观察者对象同时监听某一个主题对象, 这个主题发生变化时, 通知所有的观察对象. 总的来说, 观察者是解除耦合的重要手段.

V1 这个需求很简单, 怎么实现他不管

叮叮叮..

  • 产品经理: 我需要实现一个用户登陆的接口, 这个接口很重要也很简单, 赶紧实现下, 上去一梭子搞完节前就上线.
  • 小明: 好的, 经理

登陆代码:

class Login
{
    /**
     * 处理登陆
     *
     * @return array
     */
    public function handleLogin($param)
    {

        $isLogin = false;
        //执行登陆
        switch ($this->doLogin($param)) {
            case 0:
                $message = '登陆成功';
                $isLogin = true;
                break;
            case 1:
                $message = '帐号或密码不对';
                break;
            case 2:
                $message = '账号已失效';
                break;
            default:
                $message = '登陆失败';

        }

        return [
            'isLogin' => $isLogin,
            'message' => $message,
        ];
    }

    /**
     * 执行具体登陆操作
     *
     * @return int
     */
    public function doLogin($param)
    {
        //dododo
        return rand(0, 2);
    }
}

这里我们为了演示, 在实际执行登陆方法中随机返回 0~2,对应返回不回的提示信息.

执行如下

$result = (new Login)->handleLogin(['email'=>'1350495180@qq.com','passwd'=>'123456']);
echo json_encode($result, JSON_UNESCAPED_UNICODE);

output:
{"isLogin":false,"message":"帐号或密码不对"}
{"isLogin":true,"message":"登陆成功"}
{"isLogin":false,"message":"账号已失效"}

V2 我们还得记录下登陆的一些信息

叮叮叮...

  • 产品经理: 登陆是实现了, 但我们还需要一些数据用作分析, 这个需求同样很简单, 直接在上一次的登陆代码那插入一个保存就可以

  • 小明: 好的呢经理.

public function handleLogin($param)
{
    $isLogin = false;
    //执行登陆
    switch ($this->doLogin($param)) {
       .....
    }

    $param['isLogin'] = $message;
    $this->_saveLoginLog($param);
    
    return [
        'isLogin' => $isLogin,
        'message' => $message,
    ];
}

/**
 * 添加登陆日志
 *
 * @param $param
 * @return bool
 */
private function _saveLoginLog($param)
{
    $param['client_ip'] = $this->get_real_ip();
    $this->loginLogModel->insert($param);
    return true;
}

V3 我们得给再做更多的事情

叮叮叮...

  • 产品经理: 还是得升级下这个登陆接口, 这个系统数据很重要, 我们应该给系统管理员发邮件信息, 再给归属帐号发条登陆短信提醒安全系数就会更高了, 再在那加点逻辑, 这个功能不复杂.
  • 小明: 这个事情不好做, 这样改下去会很乱.
  • 产品经理: 你们怎么架构是你们的事情, 你实现这个功能需要多久
  • 小明: 经理给我一天可以吗
  • 产品经理: 我不认为这个事情有多难, 找个实习生最多一小时搞定, 这个功能很紧急, 如果做不了的话, 我们可以把你领导叫来一起沟通下, 你的时间我接受不了

  • 小明: 别呀, 我试试还不行嘛.

开发至今, 我才发现这是一个越来越大的陷阱, 我没有意识到这点, 即使一个简单的登陆接口, 每次改完都得重测一遍, 一直变来变去, 思考着该怎么去重构我得代码.

观察者模式 v1

class Login implements LoginSubjectInterface
{

    private $observers;

    public function __construct()
    {
        $this->observers = [];
    }

    /**
     * 加入观察者
     *
     * @param LoginObserverInterface $loginSubject
     */
    public function attach(LoginObserverInterface $loginObserver)
    {
        $this->observers[] = $loginObserver;
    }

    /**
     * 移除观察者
     *
     * @param LoginObserverInterface $loginObserver
     */
    public function detach(LoginObserverInterface $loginObserver)
    {
        //todo
    }

    /**
     * 通知观察者事件
     */
    public function notify()
    {
        foreach ($this->observers as $observer) {
            $observer->doNotify();
        }
    }
    public function notify()
    {
        foreach ($this->observers as $observer) {
            $observer->doNotify();
        }
    }

    /**
     * 处理登陆
     *
     * @return array
     */
    public function handleLogin($param)
    {

        $isLogin = false;
        //执行登陆
        switch ($this->doLogin($param)) {
            case 0:
                $message = '登陆成功';
                $isLogin = true;
                break;
            case 1:
                $message = '帐号或密码不对';
                break;
            case 2:
                $message = '账号已经被禁用';
                break;
            default:
                $message = '登陆失败';

        }

        $this->notify();

        return [
            'isLogin' => $isLogin,
            'message' => $message,
        ];
    }
}

登陆成功观察者 interface

namespace App;

interface LoginObserverInterface
{
    public function doNotify();
}

发送邮件登陆提醒类

class LoginEmailNotify implements LoginObserverInterface
{

    private $loginSubject;

    public function __construct(LoginSubjectInterface $loginSubject)
    {
        $this->loginSubject = $loginSubject;
        $this->loginSubject->attach($this);
    }

    public function doNotify()
    {
        echo '发送邮件登陆提醒' . PHP_EOL;
    }
}

发送短信通知类

class LoginDisable implements LoginObserverInterface
{
    
    private $loginSubject;
    
    public function __construct(LoginSubjectInterface $loginSubject)
    {
        $this->loginSubject = $loginSubject;
        $this->loginSubject->attach($this);
    }

    public function doNotify()
    {
        echo '微信推送充值链接' . PHP_EOL;
    }
}

测试

$loginObject = new Login();
new LoginEmailNotify($loginObject);
new LoginPhoneMsgNotify($loginObject);

$result = $loginObject->handleLogin(['email' => '1350495180@qq.com', 'passwd' => '123456']);

output:
发送邮件登陆提醒
发送短信通知
{"isLogin":false,"message":"账号已经被禁用"}

我们发现了在观察者类中有一部分重复代码, 每个观察者类中, 就是向被观察者业务类执行 attch 操作, 这部分可以抽出基类作为封装。另外一点没实现的就是 doNotify 必须作为一个参数将当前登陆的帐号或手机号传递过去, 作为发送短信依据.

我们大部分使用观察者都是使用推的模式, 被动接口 notify, 其实还有一种模式为 拉 模式, 其实核心就是在 notify 中返向调用符合自身业务的接口去处理自己的逻辑.

我们尝试使用 SPL 来优化观察者

SPL提供了一组标准数据结构, 下面使用了观察者相关的 SplSubject、SplObserver两种接口使用方式

subject 业务主类

use SplObserver;
use SplObjectStorage;

class Login implements \SplSubject
{

    private $observers;

    public function __construct()
    {
        $this->observers = new SplObjectStorage();
    }

    /**
     * 加入观察者
     *
     * @param SplObserver $loginSubject
     */
    public function attach(SplObserver $loginObserver)
    {
        $this->observers->attach($loginObserver);
    }

    /**
     * 移除观察者
     *
     * @param SplObserver $loginObserver
     */
    public function detach(SplObserver $loginObserver)
    {
        $this->observers->detach($loginObserver);
    }

    /**
     * 通知观察者事件
     */
    public function notify()
    {
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }

    /**
     * 处理登陆
     *
     * @return array
     */
    public function handleLogin($param)
    {

        $isLogin = false;
        //执行登陆
        switch ($this->doLogin($param)) {
            case 0:
                $message = '登陆成功';
                $isLogin = true;
                break;
            case 1:
                $message = '帐号或密码不对';
                break;
            case 2:
                $message = '账号已经被禁用';
                break;
            default:
                $message = '登陆失败';

        }

        $this->notify();

        return [
            'isLogin' => $isLogin,
            'message' => $message,
        ];
    }

    /**
     * 执行具体登陆操作
     *
     * @return int
     */
    public function doLogin($param)
    {
        //dododo
        return rand(0, 2);
    }
}

邮件通知类

use SplObserver;
use SplSubject;

class LoginEmailNotify implements SplObserver
{

    private $loginSubject;

    public function __construct(SplSubject $loginSubject)
    {
        $this->loginSubject = $loginSubject;
        $this->loginSubject->attach($this);
    }

    public function update(SplSubject $subject)
    {
        echo '发送邮件登陆提醒' . PHP_EOL;
    }
}

短信通知类

use SplObserver;
use SplSubject;

class LoginPhoneMsgNotify implements SplObserver
{

    private $loginSubject;
    
    public function __construct(SplSubject $loginSubject)
    {
        $this->loginSubject = $loginSubject;
        $this->loginSubject->attach($this);
    }
    
    public function update(SplSubject $subject)
    {
        echo '发送短信通知' . PHP_EOL;
    }
}

以上代码我们使用了php spl内部封装好的 SplSubject、SplObserver的接口, 以及 SplObjectStorage 对象存储类. 当然在方便的同时也带来了缺失部分灵活性, 例如通知观察者只能实现 update 类接口.

结论

小明和产品经理结局是?