ReactiveCocoa(OC版)

2017-06-20 本文已影响69人 OneAlon

一.`Getting started`项目中使用`ReactiveCocoa`

在这里笔者使用Cocoapods安装ReactiveCocoa,在项目中创建podfile文件,使用的是2.5版本.

platform :ios, '8.0'
#use_frameworks!

target '你的项目名称’ do
  pod 'ReactiveCocoa', '~> 2.5’
end

执行安装命令

pod install --no-repo-update

二.ReactiveCocoa常见类

1.RACSignal信号类
RACSignal信号类表示当数据改变时,在信号内部会利用订阅者发送数据.RACSignal默认是一个冷信号,只有被订阅以后才会变成热信号.
RACSignal信号类的简单使用:

    // 1.创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 3.利用订阅者发送数据
        // 只有当有订阅者订阅时,才会调用这个block
        [subscriber sendNext:@"这是发送的数据"];
        return nil;
    }];
    
    // 2.订阅信号
    [signal subscribeNext:^(id x) {
       NSLog(@"接收到数据:%@",x);
    }];

2.RACSubscriber订阅者
RACSubscriber是一个协议,任何遵循RACSubscriber协议的对象并且实现协议方法都可以是一个订阅者,订阅者可以帮助信号发送数据.
RACSubscriber协议中有四个方法.

- (void)sendNext:(id)value;
- (void)sendError:(NSError *)error;
- (void)sendCompleted;
- (void)didSubscribeWithDisposable:(RACCompoundDisposable *)disposable;

3.RACDisposable
RACDisposable用于取消订阅和清理资源,当信号发送完成或发送错误时会自动调用.

    // 1.创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 3.利用订阅者发送数据
        [subscriber sendNext:@"这是发送的数据"];
        // 如果为未调用,当信号发送完成或发送错误时会自动调用
        return [RACDisposable disposableWithBlock:^{
            NSLog(@"资源被清理了");
        }];
    }];
    
    // 2.订阅信号
    [signal subscribeNext:^(id x) {
       NSLog(@"接收到数据:%@",x);
    }];

4.RACSubject信号提供者
RACSubject继承RACSignal,又遵循了RACSubscriber协议,所以既可以充当信号,又可以发送信号,通常用它代替代理.

    // 1.创建信号
    RACSubject *subject = [RACSubject subject];
    
    // 2.订阅信号
    [subject subscribeNext:^(id x) {
       NSLog(@"接收到数据:%@",x);
    }];
    
    // 3.发送信号
    [subject sendNext:@"发送数据"];

RACSubject的底层实现

在执行[RACSubject subject]时,RACSubject会在初始化时创建disposable对象属性和subscribers订阅者数组.

image.png

在执行subscribeNext订阅信号时,会创建一个订阅者RACSubscriber,并将订阅者RACSubscriber添加到subscribers订阅者数组.

image.png

在执行sendNext发送信号时,会遍历subscribers订阅者数组,执行sendNext

image.png

5.RACReplaySubject
RACReplaySubject重复提供信号类，RACSubject的子类.由于RACReplaySubject的底层实现和RACSubject不同,RACReplaySubject可以先发送数据,再订阅信号.

    // 1.创建信号
    RACReplaySubject *replaySubject = [RACReplaySubject subject];
    
    // 2.订阅信号
    [replaySubject subscribeNext:^(id x) {
        NSLog(@"订阅信号,%@",x);
    }];
    
    // 3.发送数据
    [replaySubject sendNext:@"发送的数据"];

RACReplaySubject的底层实现

在执行[RACReplaySubject subject]时,创建一个valuesReceived数组

image.png

在执行subscribeNext时,创建订阅者,遍历valuesReceived数组,利用订阅者执行sendNext发送valuesReceived中的数据.

image.png

在执行sendNext时,将要发送的数据保存到valuesReceived数组中,执行sendNext

image.png

6.RACMulticastConnection
我们在使用RACsignal,RACReplaySubject或者RACReplaySubject时,当一个信号被多个订阅者订阅时,在信号内部的block或被调用多次,有时这样并不能满足我们的需求,我们想要信号被多个订阅者订阅时,信号内部的block只被执行一次,那么RACMulticastConnection就能帮助我们完成需求.

    // 1.创建信号
    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        // 3.发送数据
        NSLog(@"发送数据");
        [subscriber sendNext:@"发送数据"];
        return nil;
    }];
    
    RACMulticastConnection *connection = [signal publish];
    
    // 2.订阅信号
    [connection.signal subscribeNext:^(id x) {
        NSLog(@"接收到数据1:%@",x);
    }];
    [connection.signal subscribeNext:^(id x) {
        NSLog(@"接收到数据2:%@",x);
    }];
    
    // 4.激活信号
    [connection connect];

在log中的打印如下

2017-06-20 16:55:50.809 MVVMRACDemoOC[2848:856666] 发送数据
2017-06-20 16:55:50.810 MVVMRACDemoOC[2848:856666] 接收到数据1:发送数据
2017-06-20 16:55:50.810 MVVMRACDemoOC[2848:856666] 接收到数据2:发送数据

7.RACCommand
RACCommand是处理事件的类,可以把事件如何处理,事件中的数据如何传递，包装到这个类中.
使用一个demo说明RACCommand:监听按钮的点击,发送网络请求.

    // 1.创建命令
    RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
        NSLog(@"接收到命令:%@", input);
        // 返回一个信号,不能为空.(信号中的信号)
        // 3.创建信号用来传递数据
        return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
            [subscriber sendNext:@"信号中的信号发送的数据"];
            // 注意:数据传递完成,要调用sendCompleted才能执行完毕
            [subscriber sendCompleted];
            return nil;
        }];
    }];
    self.command = command;
    
    // 2.订阅信号中的信号(必须要在执行命令前订阅)
    [command.executionSignals.switchToLatest subscribeNext:^(id x) {
        NSLog(@"接收到信号中的信号发送的数据:%@",x);
    }];
    
    
    // 4.执行命令
    [command execute:@1];
    
    [[command.executing skip:1] subscribeNext:^(id x) {
        if ([x boolValue] == YES) {
            NSLog(@"正在执行");
        }else{
            NSLog(@"未开始/执行完成");
        }
    }];

在log中的打印

2017-06-20 17:26:28.013 MVVMRACDemoOC[3166:970238] 接收到命令:1
2017-06-20 17:26:28.016 MVVMRACDemoOC[3166:970238] 正在执行
2017-06-20 17:26:28.016 MVVMRACDemoOC[3166:970238] 接收到信号中的信号发送的数据:信号中的信号发送的数据
2017-06-20 17:26:28.017 MVVMRACDemoOC[3166:970238] 未开始/执行完成

三.常见宏

RAC(TARGET, [KEYPATH, [NIL_VALUE]])给某个对象的某个属性做绑定.

// 只要passwordTextField内容变化,accountTextField的text就会跟着改变
RAC(self.accountTextField, text) = self.passwordTextField.rac_textSignal;

RACObserve(self, name)监听某个对象的某个属性,返回信号

    // 监听passwordTextField背景色的改变
    [RACObserve(self.passwordTextField, backgroundColor) subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

@weakify(Obj)和@strongify(Obj)一般用来防止循环引用,组合使用.
RACTuplePack把数据包装成RACTuple（元组类）

    // 把参数中的数据包装成元组
    RACTuple *tuple = RACTuplePack(@1,@2);

RACTupleUnpack把RACTuple（元组类）解包成对应的数据

    // 把参数中的数据包装成元组
    RACTuple *tuple = RACTuplePack(@"OneAlon",@"HangZhou");

    // 解包元组，会把元组的值，按顺序给参数里面的变量赋值
    RACTupleUnpack(NSString *name,NSNumber *address) = tuple;

四.常见用法

代替代理
代替代理有两种方法,一种是使用RACSubject代替代理,另一种是使用rac_signalForSelector方法代替代理.
这里模拟一个需求:自定义一个红色的view,在view中有一个按钮,监听按钮的点击.
如果不使用RAC,在红色的view中定义一个代理属性,点击按钮的时候通知代理做事情.
如果使用RAC,直接让红色的view调用rac_signalForSelector方法即可.

    [[self.redView rac_signalForSelector:@selector(buttonClick:)] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

2.代替KVO
监听红色view的背景色的改变

    [[self.redView rac_valuesAndChangesForKeyPath:@"backgroundColor" options:NSKeyValueObservingOptionNew observer:nil] subscribeNext:^(id x) {
        NSLog(@"%@",x);
    }];

3.监听事件

    [[self.button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
        NSLog(@"按钮被点击了");
    }];

4.代替通知

    [[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(id x) {
        NSLog(@"键盘弹出");
    }];

5.监听文本框文字改变

   [_textField.rac_textSignal subscribeNext:^(id x) {

       NSLog(@"文字改变了%@",x);
   }];

6.处理当界面有多次请求时，需要都获取到数据时，才能展示界面,rac_liftSelector:withSignalsFromArray:Signals

五.`Demo`

做了一个小demo,仅供学习使用.

六.参考文献

Objc中国 MVVM 介绍
 ReactiveCocoa 和 MVVM 入门
 最快让你上手ReactiveCocoa之基础篇
 最快让你上手ReactiveCocoa之进阶篇
 学习视频

ReactiveCocoa(OC版)

一.`Getting started`项目中使用`ReactiveCocoa`

二.ReactiveCocoa常见类

三.常见宏

四.常见用法

五.`Demo`

六.参考文献

猜你喜欢

热点阅读

ReactiveCocoa(OC版)

一.Getting started项目中使用ReactiveCocoa

二.ReactiveCocoa常见类

三.常见宏

四.常见用法

五.Demo

六.参考文献

猜你喜欢

热点阅读

一.`Getting started`项目中使用`ReactiveCocoa`

五.`Demo`