PHP 7: 真实世界的应用开发
  • 前言
  • 模块一
    • 第一章、建立基础
      • PHP 7 安装注意事项
      • 使用内置的 PHP web 服务器
      • 创建一个 MySQL 测试数据库
      • 安装 PHPUnit
      • 实现类的自动加载
      • 抓取一个网站
      • 建立一个深度网络扫描器
      • 创建一个 PHP 5 到 PHP 7 代码转换器
    • 第二章、使用 PHP 7 高性能特性
      • 了解抽象语法树
      • 理解句法分析中的差异
      • 理解 foreach() 处理中的差异
      • 使用 PHP 7 增强功能提高性能
      • 遍历海量文件
      • 将电子表格上传到数据库
      • 递归目录迭代器
    • 第三章、使用 PHP 函数
      • 函数开发
      • 数据类型提示
      • 使用返回值数据类型
      • 使用迭代器
      • 使用生成器编写自己的迭代器
    • 第四章、使用 PHP 面向对象程序设计
      • 类的开发
      • 类的扩展
      • 使用静态属性和方法
      • 使用命名空间
      • 定义可见性
      • 使用接口
      • 使用特性
      • 实现匿名类
    • 第五章、与数据库的交互
      • 使用PDO连接数据库
      • 构建一个 OOP SQL 查询生成器
      • 处理分页
      • 定义实体以匹配数据库表
      • 将实体类与RDBMS查询绑定
      • 将二次查找嵌入到查询结果中
      • 实现jQuery DataTables的PHP查找
    • 第六章、建立可扩展的网站
      • 创建通用表单元素生成器
      • 创建一个HTML单选元素生成器
      • 创建一个HTML选择元素生成器
      • 实现表单工厂
      • 链式 $_POST 过滤器
      • 链式 $_POST 验证器
      • 将验证绑定到表单
    • 第七章、访问Web服务
      • 在PHP和XML之间转换
      • 创建一个简单的REST客户端
      • 创建一个简单的REST服务器
      • 创建一个简单的SOAP客户端
      • 创建一个简单的SOAP服务器
    • 第八章、处理日期/时间和国际化方面
      • 在视图脚本中使用 emoji
      • 转换复杂字符
      • 从浏览器数据获取语言环境
      • 按地区设置数字格式
      • 按地区处理货币
      • 按地区设置日期/时间格式
      • 创建一个HTML国际日历生成器
      • 构建一个周期性事件生成器
      • 不使用gettext处理翻译
    • 第九章、开发中间件
      • 使用中间件进行认证
      • 使用中间件实现访问控制
      • 使用高速缓存提高性能
      • 实施路由选择
      • 进行框架间的系统调用
      • 使用中间件来跨语言
    • 第十章、高级算法
      • 使用 getter 和 setter
      • 实现一个链表
      • 建立冒泡排序
      • 实现一个堆栈
      • 构建一个二分法查找类
      • 实现一个搜索引擎
      • 显示多维数组并累计总数
    • 第十一章、软件设计模式的实现
      • 创建数组到对象的转化器
      • 构建对象到数组到转化器
      • 实施策略模式
      • 定义一个映射器
      • 实现对象关系映射
      • 实施发布/订阅设计模式
    • 第十二章、提高网站安全
      • 过滤$_POST数据
      • 验证$_POST数据
      • 保护PHP session
      • 用令牌保护表格的安全
      • 建立一个安全的密码生成器
      • 带有验证码的安全保护表格
      • 不使用mcrypt进行加密/解密
    • 第十三章、最佳实践、测试和调试
      • 使用特征和接口
      • 通用异常处理程序
      • 通用错误处理程序
      • 编写一个简单的测试
      • 编写测试套件
      • 生成虚假的测试数据
      • 使用session_start参数自定义会话
    • PSR-7
  • 模块二
  • 模块三
    • GoF 设计模式
      • 结构型
      • 行为型
      • 小结
    • SOLID 设计原则
      • 开闭原则
      • 里氏替换原则
      • 接口隔离原则
      • 依赖反转原则
      • 小结
    • 模块化网店应用的需求规范
      • 线框设计
      • 定义技术栈
      • 小结
    • Symfony 概述
      • 创建一个空白项目
      • 使用 Symfony 控制台
      • 控制器
      • 路由
      • 模板
      • 表单
      • 配置 Symfony
      • bundle 系统
      • 数据库和 Doctrine
      • 测试
      • 验证
      • 小结
    • 构建核心模块
    • 构建目录模块
    • 构建客户模块
    • 构建支付模块
    • 构建发货模块
    • 构建销售模块
    • 总结
由 GitBook 提供支持
在本页
  • 如何做...
  • 如何运行...
  • 更多...
  • 参见...
  1. 模块一
  2. 第十一章、软件设计模式的实现

实施发布/订阅设计模式

发布/订阅(Pub/Sub)设计模式通常构成软件事件驱动编程的基础。这种方法允许在不同的软件应用程序之间,或在单个应用程序中的不同软件模块之间进行异步通信。该模式的目的是允许一个方法或函数在一个重要的动作发生时发布一个信号。然后,如果某个信号已经发布,一个或多个类就会订阅并采取行动。

这种操作的例子是当数据库被修改时,或者当用户已经登录时。这种设计模式的另一个常见用途是当一个应用程序提供新闻源时。如果一个紧急的新闻项目已经发布,应用程序将发布这个事实,允许客户端订阅者刷新他们的新闻列表。

如何做...

1.首先,我们定义我们的发布者类,Application\PubSub\Publisher。你会注意到我们使用了两个有用的标准PHP库(SPL)接口,SplSubject和SplObserver。

namespace Application\PubSub;
use SplSubject;
use SplObserver;
class Publisher implements SplSubject
{
  // code
}

2. 接下来,我们添加属性来表示发布者名称、要传递给订阅者的数据以及订阅者数组(也称为听众)。你还会注意到,我们将使用一个链表(第10章,高级算法)来允许优先级。

protected $name;
protected $data;
protected $linked;
protected $subscribers;

3.构造函数初始化了这些属性。我们还抛出了__toString(),以备我们需要快速访问这个发布者的名称。

public function __construct($name)
{
  $this->name = $name;
  $this->data = array();
  $this->subscribers = array();
  $this->linked = array();
}

public function __toString()
{
  return $this->name;
}

4.为了将一个订阅者与这个发布者关联起来,我们定义了 attach(),它在 SplSubject 接口中被指定。我们接受一个SplObserver实例作为参数。请注意,我们需要向 $subscribers 和 $linked 属性添加条目。然后,使用arsort()对$linked进行按值排序,用优先级来表示,它的排序方式是反向的,并保持键。

public function attach(SplObserver $subscriber)
{
  $this->subscribers[$subscriber->getKey()] = $subscriber;
  $this->linked[$subscriber->getKey()] = 
    $subscriber->getPriority();
  arsort($this->linked);
}

5.该接口还要求我们定义detach(),将订阅者从列表中删除。

public function detach(SplObserver $subscriber)
{
  unset($this->subscribers[$subscriber->getKey()]);
  unset($this->linked[$subscriber->getKey()]);
}

6.同样是接口所要求的,我们定义了notify(),它调用所有订阅者的update()。注意,我们在链表中循环,以确保订阅者按优先级顺序被调用。

public function notify()
{
  foreach ($this->linked as $key => $value)
  {
    $this->subscribers[$key]->update($this);
  }
}

7. 接下来,我们定义相应的getter和setter。为了节省篇幅,我们不在这里一一展示。

public function getName()
{
  return $this->name;
}

public function setName($name)
{
  $this->name = $name;
}

8. 最后,我们需要提供一种通过键设置数据项的方法,然后在调用notify()时,订阅者可以使用该方法。

public function setDataByKey($key, $value)
{
  $this->data[$key] = $value;
}

9. 现在我们可以看看Application\PubSub\Subscriber。通常情况下,我们会为每个发布者定义多个订阅者。在这种情况下,我们实现了SplObserver接口。

namespace Application\PubSub;
use SplSubject;
use SplObserver;
class Subscriber implements SplObserver
{
  // code
}

10. 每个订阅者都需要一个唯一的标识符。在这种情况下,我们使用md5()和日期/时间信息,结合一个随机数来创建密钥。构造函数初始化属性如下。订阅者执行的实际逻辑功能是以回调的形式进行的。

protected $key;
protected $name;
protected $priority;
protected $callback;
public function __construct(
  string $name, callable $callback, $priority = 0)
{
  $this->key = md5(date('YmdHis') . rand(0,9999));
  $this->name = $name;
  $this->callback = $callback;
  $this->priority = $priority;
}

11. 当调用发布者上的notifiy()时,就会调用update()函数。我们传递一个发布者实例作为参数,并调用为这个订阅者定义的回调。

public function update(SplSubject $publisher)
{
  call_user_func($this->callback, $publisher);
}

12. 为了方便,我们还需要定义getter和setter。这里没有全部显示出来。

public function getKey()
{
  return $this->key;
}

public function setKey($key)
{
  $this->key = $key;
}

// other getters and setters not shown

如何运行...

在这个例子中,定义一个名为chap_11_pub_sub_simple_example.php的调用程序,该程序设置自动加载并使用相应的类。

<?php
require __DIR__ . '/../Application/Autoload/Loader.php';
Application\Autoload\Loader::init(__DIR__ . '/..');
use Application\PubSub\ { Publisher, Subscriber };

接下来,创建一个发布者实例并分配数据。

$pub = new Publisher('test');
$pub->setDataByKey('1', 'AAA');
$pub->setDataByKey('2', 'BBB');
$pub->setDataByKey('3', 'CCC');
$pub->setDataByKey('4', 'DDD');

现在你可以创建测试订阅者,从发布者那里读取数据并呼应结果。第一个参数是名称,第二个是回调,最后一个是优先级。

$sub1 = new Subscriber(
  '1',
  function ($pub) {
    echo '1:' . $pub->getData()[1] . PHP_EOL;
  },
  10
);
$sub2 = new Subscriber(
  '2',
  function ($pub) {
    echo '2:' . $pub->getData()[2] . PHP_EOL;
  },
  20
);
$sub3 = new Subscriber(
  '3',
  function ($pub) {
    echo '3:' . $pub->getData()[3] . PHP_EOL;
  },
  99
);

为了测试的目的,不按顺序附加订阅者,并调用notify()两次。

$pub->attach($sub2);
$pub->attach($sub1);
$pub->attach($sub3);
$pub->notify();
$pub->notify();

接下来,定义并附加另一个订阅者,该订阅者查看订阅者1的数据,如果不是空的就退出。

$sub4 = new Subscriber(
  '4',
  function ($pub) {
    echo '4:' . $pub->getData()[4] . PHP_EOL;
    if (!empty($pub->getData()[1]))
      die('1 is set ... halting execution');
  },
  25
);
$pub->attach($sub4);
$pub->notify();

这里是输出。请注意,输出的顺序是按优先级排列的(优先级高的先输出),第二块输出被打断。

更多...

与之密切相关的软件设计模式是Observer。其机制类似,但普遍认为的区别是,Observer以同步方式运行,当收到信号(通常也称为消息或事件)时,所有观察者方法都会被调用。而Pub/Sub模式则是异步操作,通常使用消息队列。另一个区别是,在Pub/Sub模式中,发布者不需要知道订阅者。

参见...

上一页实现对象关系映射下一页第十二章、提高网站安全

最后更新于4年前

关于Observer和Pub/Sub模式之间的区别,请参考文章。

http://stackoverflow.com/questions/15594905/difference-between-observer-pub-sub-and-data-binding