ReactiveCocoa學(xué)習(xí)總結(jié)

ReactiveCocoa是一個FRP的思想在Objective-C中的實現(xiàn)框架，主要為了改善以下幾個問題：

1 傳統(tǒng)iOS開發(fā)過程中，狀態(tài)以及狀態(tài)之間依賴過多的問題
2 傳統(tǒng)MVC架構(gòu)的問題：Controller比較復(fù)雜，可測試性差
3 提供統(tǒng)一的消息傳遞機制

在我們現(xiàn)在的開發(fā)工作中，RAC主要是為了實現(xiàn)MVVM框架，因為RAC的信號機制很容易將某一個變量的變化與界面元素關(guān)聯(lián)，所以非常容易應(yīng)用Model-View-ViewModel 框架。通過引入ViewModel層，然后用RAC將ViewModel與View關(guān)聯(lián)，View層的變化可以直接響應(yīng)ViewModel層的變化，這使得Controller變得更加簡單。目前如果要實現(xiàn)iOS的MVVM，需要實現(xiàn)數(shù)據(jù)綁定的功能，因此RAC目前是不可缺少的。

我們可能會在ViewModel里寫的代碼

- (RACCommand *)loadCommand
{
    @weakify(self);
    if (!_loadCommand) {
        _loadCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
            @strongify(self);
            return [[self.model fetchResultInfoSignal] doNext:^(ResultInfo *resultInfo) {
                @strongify(self);
                self.resultInfo = resultInfo;
            }];
        }];
    }
    return _loadCommand;
}
 
 
- (RACSignal *)fetchResultInfoSignal
{
    @weakify(self);
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        @strongify(self);
        [self fetchResultInfoFinished:^(ResultInfo *resultInfo, NSError *error) {
            if (error) {
                [subscriber sendError:error];
            } else {
                [subscriber sendNext:resultInfo];
                [subscriber sendCompleted];
            }
        }];
        return nil;
    }];
}
[[self.viewModel.loadCommand execute:nil] subscribeCompleted:^{
    // do next Operation
}];

而背后的原理是怎樣的呢，可以看一下ReactiveCocoa的源碼實現(xiàn)

RACCommand

在RACCommand.m中，我們可以看到初始化方法

- (id)initWithSignalBlock:(RACSignal * (^)(id input))signalBlock {
    return [self initWithEnabled:nil signalBlock:signalBlock];
}

初始化方法中調(diào)用了- (id)initWithEnabled:(RACSignal *)enabledSignal signalBlock:(RACSignal * (^)(id input))signalBlock
初始化了command中的signalBlock，并且初始化了activeExecutionSignals、executing、errors、enabled等
在- (RACSignal *)execute:(id)input 中

RACSignal *signal = self.signalBlock(input);
RACMulticastConnection *connection = [[signal subscribeOn:RACScheduler.mainThreadScheduler] multicast:[RACReplaySubject subject]];

使用了self.signalBlock，使用了connection進行連接

[self addActiveExecutionSignal:connection.signal];
[connection.signal subscribeError:^(NSError *error) {
    @strongify(self);
    [self removeActiveExecutionSignal:connection.signal];
} completed:^{
    @strongify(self);
    [self removeActiveExecutionSignal:connection.signal];
}];

并把connection.signal加入到activeExecutionSignal中，執(zhí)行完了移除信號
我們可以看到RACCommand執(zhí)行，返回值類型為RACSignal，我們可以繼續(xù)對RACSignal進行操作

RACSignal

RAC的核心就是RACSignal，那什么是RACSignal呢
RACSignal是RACStream的子類，RACStream是一個抽象類，描述了值的流動。 RACSignal通過createSignal進行創(chuàng)建，該方法會調(diào)用RACDynamicSignal子類的createSignal方法
createSignal的參數(shù)為一個block，block的參數(shù)是支持RACSubscriber協(xié)議的id類型，返回值為RACDisposable

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

RACDynamicSignal中會把block保存到didSubscribe中，didSubscribe和參數(shù)類型一樣的block

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
    RACDynamicSignal *signal = [[self alloc] init];
    signal->_didSubscribe = [didSubscribe copy];
    return [signal setNameWithFormat:@"+createSignal:"];
}

而doNext方法做了什么事情呢

- (RACSignal *)doNext:(void (^)(id x))block {
    NSCParameterAssert(block != NULL);
    return [[RACSignal createSignal:^(id<RACSubscriber> subscriber) {
        return [self subscribeNext:^(id x) {
            block(x);
            [subscriber sendNext:x];
        } error:^(NSError *error) {
            [subscriber sendError:error];
        } completed:^{
            [subscriber sendCompleted];
        }];
    }] setNameWithFormat:@"[%@] -doNext:", self.name];
}

我們可以看到doNext方法是把原來的Signal生成一個新的Signal，新的Signal的didSubscribe會訂閱原來的信號，并且執(zhí)行doNext中的block

RACSubscriber

RACSubscriber協(xié)議里有4個方法，分別是

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

在執(zhí)行sendXXX的方法的時候，實際上執(zhí)行的是

@property (nonatomic, copy) void (^next)(id value);
@property (nonatomic, copy) void (^error)(NSError *error);
@property (nonatomic, copy) void (^completed)(void);

對應(yīng)的block，block的內(nèi)容是在

+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
    RACSubscriber *subscriber = [[self alloc] init];
    subscriber->_next = [next copy];
    subscriber->_error = [error copy];
    subscriber->_completed = [completed copy];
    return subscriber;
}

中進行賦值的，而subscriberWithNext是在什么時候調(diào)用的呢

- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock error:(void (^)(NSError *error))errorBlock completed:(void (^)(void))completedBlock {
    RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:errorBlock completed:completedBlock];
    return [self subscribe:o];
}

是在Signal被訂閱的時候被調(diào)用，調(diào)用的時候發(fā)現(xiàn)是RACSubscriber的類方法，也就是說RACSubscriber不僅是一個協(xié)議，也存在一個同名的類
RACSubscriber類繼承自NSObject，實現(xiàn)了<RACSubscriber>協(xié)議
那block是如何執(zhí)行的呢

- (void)sendNext:(id)value {
    @synchronized (self) {
        void (^nextBlock)(id) = [self.next copy];
        if (nextBlock == nil) return;
        nextBlock(value);
    }
}

如果block不為空，就執(zhí)行block中的內(nèi)容，參數(shù)為sendNext的參數(shù)
sendXXX方法是在Signal在createSignal的時候保存在didSubscribe中，而didSubscribe的執(zhí)行時機呢
這個時機就是在RACSignal訂閱的時候返回的[self subscribe:o]中執(zhí)行了didSubscribe，

- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCAssert(NO, @"This method must be overridden by subclasses");
    return nil;
}

RACSignal中的該方法是空，需要子類實現(xiàn)，我們需要查看RACDynamicSignal中的該方法

- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
    NSCParameterAssert(subscriber != nil);
    RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
    subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
    if (self.didSubscribe != NULL) {
        RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
            RACDisposable *innerDisposable = self.didSubscribe(subscriber);
            [disposable addDisposable:innerDisposable];
        }];
        [disposable addDisposable:schedulingDisposable];
    }
    return disposable;
}

其中的didSubscribe就是createSignal時保存的block，所以只有信號被訂閱的時候，創(chuàng)建時的block才會被執(zhí)行

RACDisposable

上一個方法的返回值是RACDisposable，也就是createSignal中的返回值，該對象封裝了訂閱的拆卸和清理工作，RACDisposable如何使用呢

__block int count = 0;
RACSignal *signal = [self signInSignal];
__block RACDisposable *dd = nil;
dd = [signal subscribeNext:^(id x) {
    ++count;
    if (count == 5) {
        [dd dispose];
    }
    NSLog(@"-------%@", x);
}];
  
- (RACSignal *)signInSignal
{
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        RACDisposable *d = [[RACDisposable alloc] init];
        [[RACScheduler mainThreadScheduler] schedule:^{
            int a = 1, b = 1;
            while (!d.disposed) {
                [subscriber sendNext:@(a)];
                int oldB = b;
                b = a + b;
                a = oldB;
            }
        }];
        return d;
    }];   
}

一個簡單的例子，輸出斐波那契數(shù)列，在第五次循環(huán)的時候停止
如果沒有[RACScheduler mainThreadScheduler]的話，循環(huán)會一直循環(huán)下去，不會停止，因為當(dāng)前線程無法得到返回值d，因此不會被終止

冷熱信號

RACSignal通過createSignal創(chuàng)建了冷信號，而RACSubject則可以創(chuàng)建了熱信號，RACSignal的冷信號也可以轉(zhuǎn)化成熱信號
RACSubject是RACSignal的子類，也實現(xiàn)了RACSubscriber協(xié)議

RACSignal *coolSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    [[RACScheduler mainThreadScheduler] afterDelay:1 schedule:^{
        [subscriber sendNext:@5];
    }];
    [[RACScheduler mainThreadScheduler] afterDelay:2 schedule:^{
        [subscriber sendNext:@6];
    }];
    return nil;
}];
 
RACSubject *hotSignal = [RACSubject subject];
[[RACScheduler mainThreadScheduler] afterDelay:3 schedule:^{
   [hotSignal subscribeNext:^(id x) {
       NSLog(@"aaa: %@", x);
   }];
   [coolSignal subscribe:hotSignal];
}];
[[RACScheduler mainThreadScheduler] afterDelay:3.5 schedule:^{
    [hotSignal subscribeNext:^(id x) {
        NSLog(@"bbb: %@", x);
    }];
}];

github博客：https://wf96390.github.io/blog/2016/03/19/ReactiveCocoa/

參考：
ReactiveCocoa2 源碼淺析
RACSignal的Subscription深入分析
細說ReactiveCocoa的冷信號與熱信號

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 前言 之前對RAC有了一個基本的認識，了解了它的作用，以及RAC的運行機制，我們知道只要是信號（RACSignal...
    大大盆子閱讀 4,616評論 0贊 11
  • 前言由于時間的問題，暫且只更新這么多了，后續(xù)還會持續(xù)更新本文《最快讓你上手ReactiveCocoa之進階篇》，目...
    Karos_凱閱讀 1,863評論 0贊 6
  • RAC使用測試Demo下載：github.com/FuWees/WPRACTestDemo 1.ReactiveC...
    FuWees閱讀 6,651評論 3贊 10
  • 1.ReactiveCocoa常見操作方法介紹1.1 ReactiveCocoa操作須知所有的信號（RACSign...
    IIronMan閱讀 2,687評論 2贊 17
  • 文/井溢 人終究都是自私的，在關(guān)鍵時候才能看得出來。永遠不想吃虧的人大有人在，對于這一類人，說再見，祝他們...
    井溢閱讀 165評論 2贊 2

友情鏈接更多精彩內(nèi)容