iOS开发笔记之七十四——FRP与RAC进阶篇（数据黑白板ReactiveDataBoard的介绍）

******阅读完此文，大概需要30分钟******

一、简介

ReactiveDataBoard是一款已经比较成熟的基于RAC的响应式编程组件，它主要用来实现任意模块之间的数据通讯，它可以替代原生的Notification、KVO，delegate、NSUserdefault等数值传递方式。因为它除了可以实时传递数据，比起Notification、KVO等，实现相同的功能，ReactiveDataBoard只需较少的代码，而且几乎无需关心Notification和KVO带来的手动释放、Crash等问题。使用它，可以很好地提高我们的业务开发效率。目前已经广泛地使用在VivaVideo家族产品中，得到业务开发的充分肯定与验证。

组件化代码地址：

https://github.com/Leon0206/ReactiveDataBoard

二、接入说明

ReactiveDataBoard有两种数据板，分别是数据白板类ReactiveWhiteBoard和数据黑板类ReactiveBlackBoard，它们实现原理一致，一个是单例，一个是实例化使用，但是用在不同的业务场景，下面分别进行介绍：

1、数据白板类：ReactiveWhiteBoard

ReactiveWhiteBoard是一个严格的单例，app全局只有一份，推荐在app启动初始化时进行实例化。因为是单例，所以它可以实现内存中任意模块之间的数据实时通讯，具体使用例子如下：

• 1）数据的订阅（必须），首先你需要针对某一个key值进行订阅，代码如下：

[[RACWB addObserver:self forKey:@"rac_test_key"] subscribeNext:^(id  _Nullable x) {
        NSLog(@"RACMainViewController----->%@",x);
    }];
           

因为返回是RACSignal，所以它天然就享受了信号带来的福利；

• 2）数据的发送（必须），然后你需要对指定的key值进行设置：代码如下：

[RACWB setValue:@"value" forKey:@"rac_test_key"];
           

其实除了代替Notification，它本身也可以进行内存缓存的，它的获取value的api如下：

- (id _Nullable )valueForKey:(NSString *_Nonnull)key;
           

• 3) key值数据的移除（可选，但是强烈推荐）， 如果你已经完成你的数据传递，建议针对key值进行remove，代码如下：

- (void)removeObserver:(id _Nullable )obj forKey:(NSString *_Nonnull)key;
- (void)removeAllObjObservers:(id _Nullable )obj;
- (void)removeAllKeyObservers:(NSString *_Nullable)key;
           

比起Notification，它的删除API更加灵活；

• 4) 信号的暂停与重启

- (void)pauseSignalForKey:(NSString *_Nullable)key;

- (void)restartSignalForKey:(NSString *_Nonnull)key;

你可以根据业务需要，先暂停以下信号的发送，需要的时候，可以再此restart它；

三、实现原理

ReactiveDataBoard的实现原理不是很复杂，数据黑板和数据白板的原理是一样的，只是为了适应不同的业务场景才进行区分。

1、ReactiveWhiteBoard的实现

ReactiveWhiteBoard内部维护了两个字典，observers和values，分别用来存储订阅者和要传递的值对象；

• 1）订阅者代码分析：

- (RACSignal *)addObserver:(id)obj forKey:(NSString *)key
{
    if (key.length <= 0) return [RACSignal empty];
    @synchronized (self) {
       [self.flags setValue:@(ReactiveBlackBoardFlagOn) forKey:key];
       NSString *insideKey = [NSString stringWithFormat:@"%@_%@_%p",key,NSStringFromClass([obj class]),obj];
       RACSubject *subject = [RACSubject subject];
       [self.observers setValue:subject forKey:insideKey];
       return subject;
    }
}
           

每次订阅者代码的执行，都会根据key值生成唯一的RACSubject，RACSubject是一个热信号，它可以有多个订阅者，

所以每个key值可以有多个订阅者，为了可以实现达到Notification的针对不同类以及对象来管理信号，维护一个内部的insideKey，用来便于信号的分组管理。

详见：

《FRP与RAC介绍（一）》：https://blog.csdn.net/lizitao/article/details/78721650

• 2）信号发送者代码分析：

这个就比较简单了，如下：

- (void)setValue:(id)value forKey:(NSString *)key
{
    if (key.length <= 0) return;
    @synchronized (self.values) {
        [self.values setValue:value forKey:key];
    }
    if (ReactiveBlackBoardFlagOn == [[self.flags valueForKey:key] integerValue]) {
        NSArray *arr = [self subjectsForKey:key];
        [arr enumerateObjectsUsingBlock:^(RACSubject *subject, NSUInteger idx, BOOL * _Nonnull stop) {
            [subject sendNext:value];
        }];
    }
}
           

当执行信号的发送代码时，首先它会将对应key值的value存储到self.values中，然后根据获取的分组keys去取对应的RACSubjects，执行sendNext:操作，根据《FRP与RAC介绍（一）》文中介绍，这一步是在执行订阅者代码，并将value传递过去。

四、补充说明

• 1、ReactiveWhiteBoard是基于广播Notificaiton设计出来的，但是因为它的订阅者是针对RACSignal进行订阅的，所以不仅可以享受很多RAC的API带来的便利，还支持信号的传递的暂停与重启，于此同时，它也可以作为全局共享内存Dictionary去使用，当然，它的信号的删除也更加灵活。
• 2、能用ReactiveBlackBoard的时候，尽量优先使用ReactiveBlackBoard，简单的业务场景，通讯数据的比较小，可以用ReactiveWhiteBoard，如果业务场景较复杂，推荐ReactiveBlackBoard。
• 3、ReactiveWhiteBoard/ReactiveBlackBoard的使用，不要忘记最终的remove操作，虽然它不会带来像notificaiton和kvo等内存泄露问题，但是由于内部字典的不断增加，最终可能仍会带来内存膨胀的问题。
• 4、ReactiveWhiteBoard是全局的单例，也就意味着它的block回调会持有变量，所以如果订阅者回调里持有self，别忘记__weak __typeof(self) weakSelf = self;
• 5、ReactiveWhiteBoard是采取的观察者设计模式开发的，内部维护了热信号的数组，所以，请首先保证订阅者代码得到执行，否则将不会收到任何数据。
• 6、数据通讯的完全依赖key值，十分灵活，这就意味着key容易重复，因此可能会带来各种问题，所以使用前，请确保你key值的唯一性。
• 7、ReactiveWhiteBoard适用于普通的业务代码数据通讯，跨模块，跨组件等；ReactiveBlackBoard适合作为一个复杂对象（例如，可重复压栈的VC）的属性变量来使用，复杂的业务类建议自带了一份ReactiveBlackBoard，便于内部模块间的数据通讯。

个人公众号：