ReactiveCocoa使用详解01

ReactiveCocoa（简称为RAC）,是由Github开源的一个应用于iOS和OS开发的函数式响应式编程框架，它提供了一系列用来组合和转换值流的 API

一. 什么是响应式变成思想?

学习一个框架以前, 首先要了解这个框架的编程思想, 这里在介绍响应式编程思想以前, 先介绍一下以前接触过的编程思想

1.面向对象

• 万物皆对象
  • 是一类以对象做为基本程序结构单位的程序设计语言
  • 典型的面向对象的编程语言有C++, C#, Java等

2. 面向过程

• 一种以过程为中心的编程思想
• C语言就是一门面向过程的语言

3. 链式编程思想

• 是将多个操做（多行代码）经过点号(.)连接在一块儿成为一句代码,使代码可读性好
• 链式编程特色：方法的返回值是block, block必须有返回值（自己对象），block参数（须要操做的值）
• 典型框架：masonry框架。

4. 函数式编程思想

• 万物皆是流
  • 不须要考虑调用顺序，只须要知道考虑结果
  • 相似于蝴蝶效应，产生一个事件，会影响不少东西，这些事件像流同样的传播出去，而后影响结果
  • 表明：KVO运用

5. 函数式编程思想

• 是把操做尽可能写成一系列嵌套的函数或者方法调用
• 特色: 每一个方法必须有返回值（自己对象）,把函数或者Block当作参数,block参数（须要操做的值）block返回值（操做结果）
• 表明：ReactiveCocoa

6. ReactiveCocoa编程思想

• 函数式编程 Functional Programming
• 响应式编程 Reactive Programming

因此, ReactiveCocoa被描述为函数响应式编程（FRP）框架, 下面具体介绍一下RAC的一些常见类

二. RACSiganl 信号类

• ReactiveCocoa 中最核心的概念之一就是信号RACStream。RACStream中有两个子类——RACSignal 和 RACSequence; 这里咱们就主要说一下RACSignal;
• 在ReactiveCocoa整个库中，RACSignal占据着比较重要的位置，而RACSignal的变换操做更是整个RACStream流操做核心之一
• 下面让咱们俩看一下RACSignal被订阅的完整过程

- (void)test2 {
    //建立信号
    RACSignal *single = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
        //发送消息
        [subscriber sendNext:@"a"];
        [subscriber sendNext:@"b"];
        //发送完成
        [subscriber sendCompleted];
        
        //清空数据
        return [RACDisposable disposableWithBlock:^{
            //当订阅者被消耗的时候就会执行
            //当订阅者发送完成,或者error的时候也会执行
            NSLog(@"RACDisposable的block");
        }];
    }];
    
    //订阅信号
    RACDisposable *disposable = [single subscribeNext:^(id  _Nullable x) {
        NSLog(@"value = %@", x);
    } error:^(NSError * _Nullable error) {
        NSLog(@"error: %@", error);
    } completed:^{
        NSLog(@"completed");
    }];
    
    //释放
    [disposable dispose];
}

复制代码

• 在此以前先看一下RACSignal的一些子类
  • RACDynamicSignal: 动态信号，使用一个 block 来实现订阅行为，咱们在使用 RACSignal 的 +createSignal: 方法时建立的就是该类的实例
  • RACEmptySignal：空信号，用来实现 RACSignal 的 +empty 方法；
  • RACReturnSignal：一元信号，用来实现 RACSignal 的 +return:方法；
  • RACErrorSignal：错误信号，用来实现 RACSignal 的 +error: 方法；
  • RACChannelTerminal：通道终端，表明 RACChannel 的一个终端，用来实现双向绑定

RACSignal在建立信号的时候，底层会调用RACDynamicSignal的createSignal的方法, 以下:

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
	return [RACDynamicSignal createSignal:didSubscribe];
}

复制代码

这里的block是一个 id<RACSubscriber> 类型的subscriber, 而这个RACSubscriber, 咱们能够点进去看一些底层实现, 协议方法以下:

@protocol RACSubscriber <NSObject>
@required

/// Sends the next value to subscribers.
- (void)sendNext:(nullable id)value;

/// Sends the error to subscribers.
- (void)sendError:(nullable NSError *)error;

/// Sends completed to subscribers.
- (void)sendCompleted;

/// Sends the subscriber a disposable that represents one of its subscriptions.
- (void)didSubscribeWithDisposable:(RACCompoundDisposable *)disposable;

复制代码

• RACSignal底层实现：
  • 1.建立信号，首先把didSubscribe保存到信号中，还不会触发。
  • 2.当信号被订阅，也就是调用signal的subscribeNext:nextBlock
    • 2.1 subscribeNext内部会建立订阅者subscriber，而且把nextBlock保存到subscriber中。
    • 2.2 subscribeNext内部会调用siganl的didSubscribe
    • 2.3 当信号订阅完成, 不在发送数据的时候, 最好调用完成发送的[subscriber sendCompleted];
    • 订阅完成的时候, 内部会自动调用[RACDisposable disposable]取消订阅信号
  • 3.siganl的didSubscribe中调用[subscriber sendNext:@1];
    • 3.1 sendNext底层其实就是执行subscriber的nextBlock

三. 信号提供者: RACSubject

• 信号提供者，本身能够充当信号，又能发送信号
• 先订阅, 在发送信号
• 使用场景:一般用来代替代理/通知

1. RACSubject简单使用

- (void)setRacSubject1 {
    //先订阅, 在发送信号
    //1. 建立信号
    RACSubject *subject = [RACSubject subject];
    
    //2. 订阅
    //内部建立RACSubscriber
    [subject subscribeNext:^(id  _Nullable x) {
        NSLog(@"第一个订阅者--%@", x);
    }];
    
    [subject subscribeNext:^(id  _Nullable x) {
        NSLog(@"第二个订阅者---%@", x);
    }];

    //3. 发送信号
    //遍历全部的订阅者, 执行nextBlock
    [subject sendNext:@2];
    
    /** 打印结果 2018-03-17 20:18:19.782119+0800 ReactiveObjc[23883:1420936] 第一个订阅者--2 2018-03-17 20:18:19.784715+0800 ReactiveObjc[23883:1420936] 第二个订阅者---2 */
}

复制代码

• RACSubject:底层实现和RACSignal不同
  • 1.调用subscribeNext订阅信号，只是把订阅者保存起来，而且订阅者的nextBlock已经赋值了。
  • 2.调用sendNext发送信号，遍历刚刚保存的全部订阅者，一个一个调用订阅者的nextBlock

2. RACReplaySubject简单使用

• 重复提供信号类，RACSubject的子类
• 先发送信号，再订阅信号；
• 使用场景
  • 1. 若是一个信号每被订阅一次，就须要把以前的值重复发送一遍，使用重复提供信号类。
  • 2. 能够设置capacity数量来限制缓存的value的数量，即只缓充最新的几个值

- (void)setReplaySubject {
    //建立信号
    RACReplaySubject *replySub = [RACReplaySubject subject];
    
    //发送信号
    [replySub sendNext:@23];
    [replySub sendNext:@34];
    
    //订阅信号
    // 遍历值，让一个订阅者去发送多个值
    // 只要订阅一次，以前全部发送的值都能获取到.
    [replySub subscribeNext:^(id  _Nullable x) {
        NSLog(@"%@", x);
    }];
    
    /** 2018-03-19 12:01:14.112253+0800 ReactiveObjc[5130:446958] 23 2018-03-19 12:01:14.112511+0800 ReactiveObjc[5130:446958] 34 */
}
复制代码

• RACReplaySubject的底层实现
  • 1. 订阅信号时，内部保存了订阅者，和订阅者响应block
  • 2. 当发送信号的，遍历订阅者，调用订阅者的nextBlock
  • 3. 发送的信号会保存起来，当订阅者订阅信号的时，会将以前保存的信号，一个一个做用于新的订阅者，保存信号的容量由capacity决定，这也是有别于RACSubject的

3. 替代代理/通知

• 这里咱们设想一个反向传值的场景, vc里面有一个自定义的view, 当点击该View的时候, 更换vc的背景颜色
• 一般咱们的作法是使用代理/通知/block

3-1. 下面看一下代理的简单使用

在自定义View中设置协议

#import <UIKit/UIKit.h>

@class SubjectView;
@protocol SubjectDelegate <NSObject>

@optional
- (void)viewWithTap:(SubjectView *)subView;

@end

@interface SubjectView : UIView

@property (nonatomic, weak) id<SubjectDelegate> delegate;


@end

复制代码

在vc中, 遵循代理, 并实现代理方法

/// 代理方法
-(void)viewWithTap:(SubjectView *)subView{
    NSLog(@"完成代理, 点击了view");
    
    UIColor *color = [UIColor colorWithRed:(arc4random() % 255) / 255.0 green:(arc4random() % 255) / 255.0 blue:(arc4random() % 255) / 255.0 alpha:1.0];
    self.view.backgroundColor = color;
}

复制代码

3-1. RACSubject代替代理

在自定义SubjectView.h文件中

#import <UIKit/UIKit.h>
#import <ReactiveObjC.h>

@interface SubjectView : UIView

@property (nonatomic, strong) RACSubject *subject;

@end

复制代码

在自定义SubjectView.m文件中

#import "SubjectView.h"

@implementation SubjectView

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event {
    //发送信号
    [_subject sendNext:self];
}

@end

复制代码

下面看一下在vc中的操做

- (void)setupSubjectView {
    SubjectView *subV = [[SubjectView alloc]init];
    subV.backgroundColor = [UIColor redColor];
    subV.frame = CGRectMake(100, 100, 100, 100);
    RACSubject *subject = [RACSubject subject];
    [subject subscribeNext:^(id  _Nullable x) {
        NSLog(@"完成代理, 点击了view");
        
        UIColor *color = [UIColor colorWithRed:(arc4random() % 255) / 255.0 green:(arc4random() % 255) / 255.0 blue:(arc4random() % 255) / 255.0 alpha:1.0];
        self.view.backgroundColor = color;
    }];
    subV.subject = subject;
    [self.view addSubview:subV];
}
复制代码

• 相关ReactiveObjc的知识点, 后期会持续更新...
• 推荐文章: iOS ReactiveCocoa 最全经常使用API整理