RAC(ReactiveCocoa)介绍（十）——RACMulticastConnection

在实际项目开发过程中，经常会在多处不同地方对同一信号进行订阅。比如：在网络请求时，收到返回数据要针对页面多处进行更新操作。 通常会出现以下RAC写法：

一个信号多个订阅者的错误示范

这样的错误写法打印结果如下：

错误示范的打印结果

从打印结果来看，很明显地RACSignal拥有两个订阅者时，发送信号与销毁信号都执行了两次。当拥有更多订阅者或者需要在发送信号前耗时处理时，这种写法大大降低了运行效率，浪费了不必要的资源。 针对这种情况，就需要使用RACMulticastConnection来处理。 将上述问题代码加入进RACMulticastConnection处理之后

引入RACMulticastConnection之后

这时再查看打印结果

引入RACMulticastConnection打印结果

发送信号时只执行了一次，两个订阅者都收到了各自的订阅信号。

为什么RACMulticastConnection可以实现一次发送多处订阅者就可以收到信号？ 带着问题去查看其内部实现过程

publish方法实现

从上图代码实现中，可以发现RACMulticastConnection是基于RACSubject来实现的，并将RACSubject封装成了RACMulticastConnection对象。打印connection.signal，可以发现是为RACSubject类的对象。 再继续进入至- (instancetype)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject方法中。

RACMulticastConnection内部实现方法

此处使用了方法bool OSAtomicCompareAndSwap32Barrier( int32_t __oldValue, int32_t __newValue, volatile int32_t *__theValue ); 用于将_hasConnected与0(oldValue)进行比较，如果两者是匹配的，则方法结果返回YES并将_hasConnected赋值为1(newValue)。即由未连接状态，修改成已连接状态。 当由未连接状态变为已连接状态时，执行信号的订阅方法。

总结一下RACMulticastConnection实现过程: 1.创建connect，connect.sourceSignal-> RACSignal(原始信号) connect.signal -> RACSubject 2.订阅connect.signal，会调用RACSubject的subscribeNext，创建订阅者，而且把订阅者保存起来，不会执行block。 3.[connect connect]内部会订阅RACSignal(原始信号)，并且订阅者是RACSubject 4.RACSubject的sendNext,会遍历RACSubject所有订阅者发送信号，并执行他们的nextBlock( )