极客时间已完结课程限时免费阅读

25 | 怎样构建底层的发布和订阅事件总线？

25 | 怎样构建底层的发布和订阅事件总线？-极客时间

25 | 怎样构建底层的发布和订阅事件总线？

2019-05-07 戴铭 来自北京
《iOS开发高手课》
课程介绍

讲述：冯永吉

时长09:16大小8.46M

你好，我是戴铭。今天，我来跟你聊聊怎么构建事件总线。
事件总线是对发布和订阅设计模式的一种实现，通过发布、订阅可以将组件间一对一和一对多的耦合关系解开。这种设计模式，特别适合数据层通过异步发布数据的方式告知 UI 层订阅者，使得 UI 层和数据层可以不用耦合在一起，在重构数据层或者 UI 层时不影响业务层。
现在，我们先一起来捋一下 iOS 系统里有没有现成可用的技术，当数据层异步发布数据后，可以通过 Delegate 回调给 UI 层来进行展示，但是这个只适合一对一的模式。如果异步处理完后，还需要将数据发布给其他 UI 进行处理和展示的话，就需要继续发布给其他 Delegate，从而造成 Delegate 套 Delegate 的情况。
使用 Block 和使用 Delegate 的情况类似。如果需要不断异步发布给下一个数据订阅者的话，也会出现 Block 回调嵌套其他 Block 回调的情况。
iOS 系统里也有一对多模式的技术，比如 KVO 和 NSNotificationCenter。
使用 KVO 是强依赖属性的，只要更新了属性就会发布给所有的观察者，对应关系过于灵活，难以管控和维护。NSNotificationCenter 也有类似的问题，通过字符串来维护发布者和订阅者之间的关系，不仅可读性差，而且和 KVO 一样面临着难以管控和维护的情况。
总的来说，由于 Delegate 和 Block 只适合做一对一数据传递，KVO 和 NSNotificationCenter 虽然可以支持一对多的数据传递，但存在过于灵活而无法管控和维护的问题，而事件总线需要通过发布和订阅这种可管控方式实现一对一和一对多数据传递。由此可以看出，iOS 现有的 Delegate、Block、KVO、NSNotificationCenter 等技术并不适合来做事件总线。
既然 iOS 系统提供的技术没有适合做事件总线的，那么有没有好的第三方库可以处理事件总线呢？
其实，响应式第三方库 ReactiveCocoa 和 RxSwift 对事件总线的支持是没有问题的，但这两个库更侧重的是响应式编程，事件总线只是其中很小的一部分。所以，使用它们的话，就有种杀鸡焉用牛刀的感觉。
那么，事件总线有没有小而美的第三方库可用呢？

Promise

现在前端领域有一种模式叫作 Promise，这是一种专门针对异步数据操作编写的一套统一规则的模式。
本质上，这种模式本质是通过 Promise 对象保存异步数据操作，同时 Promise 对象提供统一的异步数据操作事件处理的接口。这样，事件总线的数据订阅和数据发布事件，就可以通过 Promise 对象提供的接口实现出来，比以前通过 Delegate 回调处理异步事件来说更加合理。
接下来，我们再一起看看，Promise 模式中的 Promise 对象是怎么运作的。
Promise 的概念最早是在 E 语言中被提出的。C++ 11 以 std :: promise 模板形式加入到标准库中，随后出现了 CommonJS Promises/A 规范，jQuery 将这个规范实现后引入到 jQuery 1.5 版本中。
Promise 模式大受欢迎后， ECMAScript 6 将其写入了语言标准，统一了用法，并提供了原生 的 Promise 对象。 Promise 对象里保存有异步事件，Promise 的统一接口，使得其他异步操作都能够用相同的接口来处理事件。
Promise 对象会有三种状态，分别是 pending、fulfilled、rejected：
pending 表示 Promise 对象当前正在等待异步事件处理中；
fulfilled 指的是 Promise 对象当前处理的异步事件已经成功完成；
rejected 表示 Promise 对象当前处理的异步事件没有成功。
Promise 对象还有两个重要的方法，分别是 then 和 catch。Promise 对象每次执行完 then 和 catch 方法后，这两个方法会返回先前的 Promise 对象，同时根据异步操作结果改变 Promise 对象的状态。
then 和 catch 方法与 Promise 对象状态更改关系，如下图所示：
如上图所示，执行 then 方法后返回的 Promise 对象是 rejected 状态的话，程序会直接执行 catch 方法。then 方法执行的就是订阅操作，Promise 对象触发 then 方法就是事件总线中的发布操作，then 方法执行完返回 Promise 对象能够继续同步执行多个 then 方法，由此，实现了一个发布操作对应多个订阅事件。
有了 Promise 对象后，整个异步发布和订阅操作都以同步操作的方式表现出来了。Promise 对象不仅能够避免回调层层嵌套，而且通过 Promise 的统一接口，使得事件总线的发布和订阅操作更加规范和易用。

PromiseKit

ECMAScript 6 已经内置了 Promise 对象，使得前端开发者无需引入其他库就能够直接使用 Promise 来进行日常开发。随后，Homebrew 的作者 Max Howell 开发了 PromiseKit，将 Promise 标准带到了 iOS 中。所以，现在 iOS 上也有了小而美的事件总线技术。
接下来，我就跟你介绍下如何使用 PromiseKit 吧，相信你一定会有种相见恨晚的感觉。
我们先来看看如何使用 Promise 对象的 then 和 catch 方法。
假设有这么一个需求：
首先，通过一个异步请求获取当前用户信息；
然后，根据获取到的用户信息里的用户编号再去异步请求获取用户的时间轴列表；
最后，将用户的时间轴列表数据，赋值给当前类的时间轴列表属性。
这里，我先给出使用 PromiseKit 实现的具体代码，然后我再和你分析其中的关键步骤。
使用 PromiseKit 实现的代码如下：
firstly {
// 异步获取当前用户信息
fetchUserInfo()
}.then { userInfo in
// 使用异步获取到的用户信息中的 uid 再去异步获取用户的 timeline
fetchUserTimeline(uid: userInfo.uid)
}.then { timeline in
// 记录 timeline
self.timeline = timeline
}.catch {
// 整个方法链的错误都会在这处理
}
可以看出，多次异步请求通过 Promise 的方法调用，看起来就像进行同步操作一样，顺序和逻辑也更加清晰了。使用 then 方法可以让异步操作一个接着一个地按顺序进行。如果异步操作 fetchUserInfo 失败，会返回一个状态是 rejected 的 Promise 对象，返回的这个 Promise 对象会跳过后面所有的 then 方法直接执行 catch 方法。这就和事件总线中发布事件触发后，订阅事件会一个接一个执行是一样的。
除了 then 和 catch 方法以外，PromiseKit 还有一些好用的方法。
比如 always 方法。使用了 always 方法以后， Promise 对象每次在执行方法时，都会执行一次 always 方法。
再比如 when 方法。这个方法的使用场景就是，指定多个异步操作，等这些操作都执行完成后就会执行 when 方法。when 方法类似 GCD 里面的 Dispatch Group，虽然实现的功能一样，但是代码简单了很多，使用起来也更加方便。
PromiseKit 还为苹果的 API 提供了扩展。这些扩展需要单独集成，你可以在PromiseKit 组织页面获取。目前大部分常用的 API 都有扩展，比如 UIKit、Foundation、CoreLocation、QuartzCore、CloudKit 等等，甚至还支持了第三方的框架 Alamofire。
如果你觉得 PromiseKit 提供的扩展还不够，还想让你使用的第三方库也支持 Promises 的话，可以通过 PromiseKit 提供的扩展文档，或者直接查看已支持的第三方库（比如 Alamofire ）的扩展实现，去学习如何让其他库也支持 Promises。

小结

在今天这篇文章中，我和你分享了事件总线是什么，以及事件总线解决了什么样的问题。
当工程业务逻辑越来越复杂时，你会发现如果数据层和 UI 层不做解耦，日后想进行重构或者优化就会非常困难。这，也是很多工程前期没有使用事件总线，到了后期会留下大量无法修改的代码的原因所在。
如果使用类似 Promise 这样的技术规范实现事件总线，通过简单、清晰、规范的 Promise 接口将异步的数据获取、业务逻辑、界面串起来，对于日后的维护或重构都会容易很多。

课后小作业

PromiseKit 不仅支持 Swift 语言，还支持 Objective-C。所以，今天的课后作业是，将 PromiseKit 集成到你的 Objective-C 工程中，并对其中一个模块进行改造。
很多优秀工具都是用过才知道好，心动不如行动，你也试试吧。
感谢你的收听，欢迎你在评论区给我留言分享你的观点，也欢迎把它分享给更多的朋友一起阅读。
分享给需要的人，Ta购买本课程，你将得18元
生成海报并分享

赞 3

提建议

© 版权归极客邦科技所有，未经许可不得传播售卖。 页面已增加防盗追踪，如有侵权极客邦将依法追究其法律责任。
上一篇
24 | A/B 测试：验证决策效果的利器
下一篇
26 | 如何提高 JSON 解析的性能？
unpreview
 写留言

精选留言(17)

  • 郑杰
    2019-05-07
    这里只说了 嵌套回调的问题用PromiseKit怎么解决，没说PromiseKit怎么实现事件总线啊
    共 4 条评论
    46
  • zhangkk
    2019-05-07
    如果一对多，多个类之间需要传递一个公共promise对象，来接受catch回调后的通知？
    6
  • GREEN ISLAND
    2019-05-30
    一对多 都没听倒具体用法
    5
  • mosn
    2019-05-07
    PromiseKit 和 Bolts-iOS, 还有 coobjc 哪个好？
    5
  • Calabash_Boy
    2019-07-23
    "NSNotificationCenter是难以管控和维护的",这句话不知大佬是如何理解的?
    共 3 条评论
    1
  • 我唔知点死啊
    2019-05-16
    花了3天的时间，把PromiseKit应用到OC项目中，并修改了注册登录模块。代码简化很多，看起来也很舒服。目前遇到2个问题： 1. 如何延时处理下一个操作？（比如：注册成功后延时2秒再登录） 2. 文章中介绍了always和when方法，而在AnyPromise类文件却没看到它们的踪影。
    共 2 条评论
    1
  • 梅长苏
    2019-05-07
    除了RAC还有纯OC的发布 订阅框架吗？
    1
  • yu
    2019-05-07
    PromiseKit 帶來 delegate 與 block 的解偶，並且增加易讀性與 避免 callback 地獄。項目也正在使用lib, Google 也開源了自己的 Promise lib, Promises, 提供 await 等更加直覺的使用方式，最近打算來評估一下。
    2
  • 享受慢生活🚨🚨
    2020-09-16
    其实ios原生有内部支持的opration q 也是支持的以及swift的result
  • 叶小合
    2019-11-11
    oc开发环境集成PromiseKit 全是错误
  • 徐秀滨
    2019-05-21
    想要让then能够传递参数，那么必须在then的block返回Promise，但是如果block是数据请求，那就会破坏已有的写法。这个要怎么处理呢？
  • 开元₂³³³³³³³
    2019-05-13
    希望大神能讲讲promise的具体应用，知道这个框架，一直无法应用到自己的项目
    共 1 条评论
  • @syj@
    2019-05-09
    事件总线还是没说清楚，讲解的只是把之前的block或者delegate方法换成AnyPromise方法，希望大神详细讲解下一对多的
  • Boomm
    2019-05-09
    简化异步调用为同步书写这一点上，和阿里开源的coobjc很相似，想请教这两者有什么大的区别么？
  • 我的大好时光
    2019-05-07
    👍
  • geeklyc
    2019-05-07
    抢沙发
  • 李志刚
    2019-05-07
    很实用，解决了某个操作依赖多个异步事件的场景，比如登陆操作依赖多个网络请求返回的场景。