如下图，信号的创建到事件的分发再到事件的最终执行流程图。可以看到，信号的整体实现还是比较复杂的。因RAC的学习资料不多，而且其实现流程本官一直没看到，故作此文。
信号的实现分为七步骤，每一步骤代表一个圆。希望通过剖析信号的实现步骤，能够让新手同志对RAC有更为全面的理解。阅读此文可以结合源码看，会有更好的效果。
流程图
第一步：初始化信号。这里有两个很重要的两个概念--“内部分发器、事件源”。这两个概念是本人自己的理解，在你还木有形成自己的独到理解之前，可以暂时这样理解。请不要执着于概念，概念只是帮你理解，当你真正理解，概念就变得不再重要。在初始化里面，主要是生成了一个“内部分发器”，并且立即执行“事件源”。
内部分发器：初始化时候创建，它也是一个Observer类。只是它比较特殊，它的初始化注定了它只是用来分发事件。如下图：obs就是一个分发器，在分发sendNext()或者sendFaild()等事件后，“内部分发器”就会执行的指定的源码，即图二的源码。这段源码最主要的功能就是遍历“观察者集合”并分发事件给相应的“观察者”，观察者就会执行相应的操作啦。详细源码可以参看源项目。
图一
如下是信号的初始化源码的一部分。事件发生了--obs.sendNext(5)，观察者们纷纷行动起来（执行相应操作）！这里的操作就是上图闭包内的“print(value)”。
图二
事件源：这又是干嘛的？看如下的源代码就知道它是一个函数，初始化后会立即执行。你可以在signal初始化的时候在这个事件源里面写事件（请求网络等等）。
图三
第二步：信号创建好了，接下来当然是观察并执行相应的操作了。如图一的代码：sig.observeNext闭包，这就是观察者收到分发的事件后要干的事：打印value。那么在sig.observeNext时，signal都干了什么呢？请看第三步。
第三步：调用observeNext后就走到下面这个方法里了，很明显，它根据next(value)函数初始化一个“观察者”，这个观察者很重要，就是这个观察者会收到“内部分发器”的广播，然后执行事件对应的操作。怎么做到的呢? 请往下看。
第四步：首图第四步的所谓监听观察者可能有些不当，其实就是将观察者加入集合，有事发生，告诉这些观察者。如下，就是调用一个observe函数。
图四
第五步：根据上下文调用，接着是进入了如下的方法。看到insert方法了吧，信号即signal就是当你调用observeNext/failed等后（图一的sig.observeNext闭包），观察者就被塞进了“观察者集合”里，也就是塞进了atomicObservers。内部分发器分发事件后，会遍历这个“集合”，让所有观察者执行各自的操作。
第六步：观察者到位，即观察者已经在atomicObservers集合里了。接下来“内部分发器”分发事件。怎么分发呢？很简单，就是sendNext/completed/failed/interrupted。图一的“obs.sendNext(5)”就是事件分发的一种（四种）了。
第七步：根据上一步，事件都已经分发了（例如，观察的车辆爆炸了），那接下来就是遍历“观察者集合”，让每个观察者执行自己绑定的操作了（有的观察者拨打120、有的观察者逃跑、有的观察者救人）。当然，现实不会有人故意去观察车辆爆炸，呵呵。
至此，信号的整个流程就实现了。思想似乎很简单，但是一步一步的实现起来，却又并不是那么轻而易举。这其中，RAC的作者肯定是费了一番功夫，而这番功夫，就是值得我们去玩味、去学习的地方。
以上是本人的拙见，如有不足之处，还请指摘！
下一篇将详细阐述SignalProducer的实现流程，理解了Signal和SignalProducer的实现原理，那么对RAC的使用也不会那么困难！
网友评论