在开始MVVM之前，RAC是肯定绕不过去的。MVVM+RAC真的是双剑合璧。今天 我们先来看看RAC的使用和一些原理实现，然后再结合项目中的登录来实践一下。
RACSignal
先从最简单的RACSignal开始，我们先来看看它是怎么创建的。
- (void)viewDidLoad {
[super viewDidLoad];
// Do any additional setup after loading the view from its nib.
[self creatSigal];
}
-(void)creatSigal{
RACSignal *sigal=[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
[subscriber sendNext:@"你个小样"];
return nil;
}];
[sigal subscribeNext:^(id _Nullable x) {
NSLog(@"传递的数据是：----%@",x);
}];
}
输出打印的是：LBDaySurgery(Dev)[10211:3806511] 传递的数据是：----你个小样
上面就创建了一个信号，并且订阅信号，还发送消息了。创建是成功了，但是它具体的原来还不知道啊。不要慌，我们点进方法看看。
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe {
RACDynamicSignal *signal = [[self alloc] init];
signal->_didSubscribe = [didSubscribe copy];
return [signal setNameWithFormat:@"+createSignal:"];
}
创建信号的方法是这么个东西。首先RACDynamicSignal这是个什么，然后再点发现
@interface RACDynamicSignal : RACSignal
它其实就是一个信号，先初始化了RACDynamicSignal，然后下面_didSubscribe这个熟悉嘛，是不是有点像订阅信号，RACDynamicSignal持有了didSubscribe，最后返回了一个信号。这个方法看完了，有一个疑问，didSubscribe这个是用来干嘛的？接着往下看
订阅信号的方法
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
第一行很容易理解，就是创建RACSubscriber(订阅者)，点进去看看它里面的实现
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed {
RACSubscriber *subscriber = [[self alloc] init];
subscriber->_next = [
copy];
subscriber->_error = [error copy];
subscriber->_completed = [completed copy];
return subscriber;
}
我们发现，它初始化了订阅者，然后订阅者持有了next这个block，持有了error、completed，很简单。点进去看[self subscribe:o];的实现
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
NSCParameterAssert(subscriber != nil);
RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
//看的有点懵，上面的对象都不知道是什么 但是didSubscribe这个熟悉啊，在创建信号的时候RACDynamicSignal持有didSubscribe
if (self.didSubscribe != NULL) {
RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{
//这里调用didSubscribe方法，并且把刚才传入的subscriber调用出去
RACDisposable *innerDisposable = self.didSubscribe(subscriber);
[disposable addDisposable:innerDisposable];
}];
[disposable addDisposable:schedulingDisposable];
}
return disposable;
}
现在我们最开始的疑问解开了，didSubscribe的调用。这个方法里能看懂的就是，先判断有没有didSubscribe，有的话就执行这个方法，参数是subscriber订阅者。后面我们在说RACDisposable。
- (void)sendNext:(id)value {
@synchronized (self) {
void (^nextBlock)(id) = [self.next copy];
if (nextBlock == nil) return;
nextBlock(value);
}
}
上面是订阅者发送消息的方法实现，判断有没有nextblock，而这里的nextblock也正是subscriber->_next = [next copy];保存的。如果有 就把发送的消息，传递出去。
上面我们一个一个的都点进去看了他们的具体实现，现在来张图更加直观的看看这个过程
这里面有要说明的是：didSubscribe的参数是RACSubscriber，而在我们发送消息的时候， [subscriber sendNext:@"你个小样"]; 这里的订阅者就是didSubscribe传入的，而订阅者持有nextblock，所以nextBlock(value);消息就传入到订阅的block中了。这就是创建RACSignal的一个流程。
RACDisposable
在上面创建信号的时候，返回了空，但是我们点进方法里面，它应该返回一个RACDisposable。
1.什么是RACDisposable
RACDisposable：用于取消订阅或者清理资源，当信号销毁或者发送错误的时候，就会自动触发。
使用场景：不想监听某个信号时，可以通过它主动取消订阅信号
我们来看看它的使用：
-(void)creatSigal{
RACSignal *sigal=[RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
NSLog(@"创建成功");
[subscriber sendNext:@"你个小样"];
NSLog(@"发送消息之后");
return [RACDisposable disposableWithBlock:^{
NSLog(@"这是什么什么时候调用");
}];
}];
[sigal subscribeNext:^(id _Nullable x) {
NSLog(@"传递的数据是：----%@",x);
}];
}
打印出：2021-04-08 14:08:52.687740+0800 LBDaySurgery(Dev)[10407:3878985] 创建成功
2021-04-08 14:08:52.687781+0800 LBDaySurgery(Dev)[10407:3878985] 传递的数据是：----你个小样
2021-04-08 14:08:52.687795+0800 LBDaySurgery(Dev)[10407:3878985] 发送消息之后
2021-04-08 14:08:52.687819+0800 LBDaySurgery(Dev)[10407:3878985] 这是什么什么时候调用
我们发现信号被销毁以后，就就会调用。
另外我们还可以主动调用 也会销毁
RACDisposable *disposable=[sigal subscribeNext:^(id _Nullable x) {
NSLog(@"传递的数据是：----%@",x);
}];
[disposable dispose];
RACSubject
创建信号当然不是一种方法，还有其他的方法。先上代码
-(void)creatracSubject{
RACSubject *subject=[RACSubject subject];
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"收到的消息是：---%@",x);
}];
//发送消息
[subject sendNext:@"666 666"];
}
LBDaySurgery(Dev)[10505:3899054] 收到的消息是：---666 666
我们点进方法看看它的实现原理
+ (instancetype)subject {
return [[self alloc] init];
}
- (instancetype)init {
self = [super init];
if (self == nil) return nil;
_disposable = [RACCompoundDisposable compoundDisposable];
_subscribers = [[NSMutableArray alloc] initWithCapacity:1];
return self;
}
创建subject对象时，初始化了一个取消信号和一个数组，从名字我们能看出这是用来存放订阅者的。
接着看订阅信号的实现
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock {
NSCParameterAssert(nextBlock != NULL);
RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL];
return [self subscribe:o];
}
好熟悉，和RACSignal一毛一样，但是里面里面的实现就不同了，而且他两也不是同一个类。创建RACSubscriber *o 这个是一样的我们不需要看，主要是下面的[self subscribe:o];
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
NSCParameterAssert(subscriber != nil);
RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable];
subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];
NSMutableArray *subscribers = self.subscribers;
@synchronized (subscribers) {
[subscribers addObject:subscriber];
}
[disposable addDisposable:[RACDisposable disposableWithBlock:^{
@synchronized (subscribers) {
// Since newer subscribers are generally shorter-lived, search
// starting from the end of the list.
NSUInteger index = [subscribers indexOfObjectWithOptions:NSEnumerationReverse passingTest:^ BOOL (id<RACSubscriber> obj, NSUInteger index, BOOL *stop) {
return obj == subscriber;
}];
if (index != NSNotFound) [subscribers removeObjectAtIndex:index];
}
}]];
return disposable;
}
从上面这段代码能看到，是把订阅者都加入到subscribers数组中了。
我们再看发布消息的实现
- (void)enumerateSubscribersUsingBlock:(void (^)(id<RACSubscriber> subscriber))block {
NSArray *subscribers;
@synchronized (self.subscribers) {
subscribers = [self.subscribers copy];
}
//遍历subscribers中的订阅者，然后block传递subscriber
for (id<RACSubscriber> subscriber in subscribers) {
block(subscriber);
}
}
#pragma mark RACSubscriber
- (void)sendNext:(id)value {
[self enumerateSubscribersUsingBlock:^(id<RACSubscriber> subscriber) {
//这里和之前RACSignal发送消息相同
[subscriber sendNext:value];
}];
}
1.创建的subject内部会创建数组_subscribers，用来保存所有的订阅者。
2.订阅信息的时候会创建订阅者
3.发送消息的时候，会依次发送。
-(void)creatracSubject{
RACSubject *subject=[RACSubject subject];
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"收到的消息是：---%@",x);
}];
//发送消息
[subject sendNext:@"666 666"];
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"第二次收到：--%@",x);
}];
[subject sendNext:@"888888"];
}
上面这个会打印出什么呢？在第一次发送消息的时候[subject sendNext:@"666 666"];，会打印出666，当调用到[subject sendNext:@"888888"];，因为subject可以多次订阅，所以不仅第二次会打印，第一次同样也会打印出。所以最后打印出
2021-04-08 15:38:37.497503+0800 LBDaySurgery(Dev)[10525:3913448] 收到的消息是：---666 666
2021-04-08 15:38:37.497542+0800 LBDaySurgery(Dev)[10525:3913448] 收到的消息是：---888888
2021-04-08 15:38:37.497555+0800 LBDaySurgery(Dev)[10525:3913448] 第二次收到：--888888
我们再看下面这段代码
-(void)creatracSubject{
RACSubject *subject=[RACSubject subject];
[subject sendNext:@"888888"];
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"收到的消息是：---%@",x);
}];
}
一运行发现没打印出来，这是为什么呢？这是因为在发送消息是要遍历存放订阅者的数组，但是这个数组现在是空的，它只有在订阅消息的时候才会加入到数组，自然就不会发送消息，也就不会打印出结果。
如果非要把顺序写成先发送消息 在订阅，那么我们可以用RACReplaySubject来实现
-(void)creatReplaySubject{
RACReplaySubject *subject=[RACReplaySubject subject];
[subject sendNext:@"888888"];
[subject subscribeNext:^(id _Nullable x) {
NSLog(@"收到的消息是：---%@",x);
}];
}
