前言
设计模式停更了好久, 发现兜兜转转回来, 还是离开不了那些个套路.
今天我们主要讲解下 观察者模式, 可能你听这个名字感觉很熟, 如果给你说下还可以称它为 发布订阅 模式的话, 相信你对它就毫不陌生了.
观察者模式定义了一种一对多的依赖关系, 让多个观察者对象同时监听某一个主题对象, 这个主题发生变化时, 通知所有的观察对象. 总的来说, 观察者是解除耦合的重要手段.
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 类接口.
结论
小明和产品经理结局是?