转载

ReactiveCocoa系列之signal流程详解

投稿文章，作者：蜻蜓点水

如下图，信号的创建到事件的分发再到事件的最终执行流程图。可以看到，信号的整体实现还是比较复杂的。因RAC的学习资料不多，而且其实现流程本官一直没看到，故作此文。

信号的实现分为七步骤，每一步骤代表一个圆。希望通过剖析信号的实现步骤，能够让新手同志对RAC有更为全面的理解。阅读此文可以结合源码看，会有更好的效果。

Signal实现流程图

第一步：初始化信号。这里有两个很重要的两个概念--“内部分发器、事件源”。这两个概念是本人自己的理解，在你还木有形成自己的独到理解之前，可以暂时这样理解。请不要执着于概念，概念只是帮你理解，当你真正理解，概念就变得不再重要。在初始化里面，主要是生成了一个“内部分发器”，并且立即执行“事件源”。

内部分发器：初始化时候创建，它也是一个Observer类。只是它比较特殊，它的初始化注定了它只是用来分发事件。如下图：obs就是一个分发器，在分发sendNext()或者sendFaild()等事件后，“内部分发器”就会执行的指定的源码，即图二的源码。这段源码最主要的功能就是遍历“观察者集合”并分发事件给相应的“观察者”，观察者就会执行相应的操作啦。详细源码可以参看源项目。

ReactiveCocoa系列之signal流程详解

图一

如下是信号的初始化源码的一部分。事件发生了--obs.sendNext(5)，观察者们纷纷行动起来（执行相应操作）！这里的操作就是上图闭包内的“print(value)”。

ReactiveCocoa系列之signal流程详解

图二

事件源：这又是干嘛的？看如下的源代码就知道它是一个函数，初始化后会立即执行。你可以在signal初始化的时候在这个事件源里面写事件（请求网络等等）。

ReactiveCocoa系列之signal流程详解

图三

第二步：信号创建好了，接下来当然是观察并执行相应的操作了。如图一的代码：sig.observeNext闭包，这就是观察者收到分发的事件后要干的事：打印value。那么在sig.observeNext时，signal都干了什么呢？请看第三步。

第三步：调用observeNext后就走到下面这个方法里了，很明显，它根据next(value)函数初始化一个“观察者”，这个观察者很重要，就是这个观察者会收到“内部分发器”的广播，然后执行事件对应的操作。怎么做到的呢? 请往下看。

第四步：首图第四步的所谓监听观察者可能有些不当，其实就是将观察者加入集合，有事发生，告诉这些观察者。如下，就是调用一个observe函数。

ReactiveCocoa系列之signal流程详解

图四

第五步：根据上下文调用，接着是进入了如下的方法。看到insert方法了吧，信号即signal就是当你调用observeNext/failed等后（图一的sig.observeNext闭包），观察者就被塞进了“观察者集合”里，也就是塞进了atomicObservers。内部分发器分发事件后，会遍历这个“集合”，让所有观察者执行各自的操作。

ReactiveCocoa系列之signal流程详解