在講RACMulticastConnection之前我們先來看一個例子醇蝴。
// 1.創(chuàng)建信號
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
NSLog(@"請求網(wǎng)絡(luò)數(shù)據(jù)");
// 3.成功獲取網(wǎng)絡(luò)返回的數(shù)據(jù)弃理，發(fā)送數(shù)據(jù)
[subscriber sendNext:@"發(fā)送數(shù)據(jù)"];
return nil;
}];
// 2.訂閱信號
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"訂閱者一 訂閱信號:%@",x);
}];
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"訂閱者二 訂閱信號:%@",x);
}];
[signal subscribeNext:^(id _Nullable x) {
NSLog(@"訂閱者三 訂閱信號:%@",x);
}];
打印結(jié)果
2017-05-31 19:12:06.220 RACDemo[1332:258342] 請求網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 19:12:06.221 RACDemo[1332:258342] 訂閱者一 訂閱信號:發(fā)送數(shù)據(jù)
2017-05-31 19:12:06.221 RACDemo[1332:258342] 請求網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 19:12:06.221 RACDemo[1332:258342] 訂閱者二 訂閱信號:發(fā)送數(shù)據(jù)
2017-05-31 19:12:06.221 RACDemo[1332:258342] 請求網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 19:12:06.222 RACDemo[1332:258342] 訂閱者三 訂閱信號:發(fā)送數(shù)據(jù)
你發(fā)現(xiàn)問題了嗎？
這里有一個問題，就是我們每次訂閱信號的時候色解，它都會去請求一次網(wǎng)絡(luò)數(shù)據(jù)茂嗓。
但實際上，我們并不需要這么頻繁的請求網(wǎng)絡(luò)數(shù)據(jù)科阎，我們只需要確保第一次拿到網(wǎng)絡(luò)返回的數(shù)據(jù)后述吸，在接下來的每一次訂閱中，直接拿到第一次獲取到的網(wǎng)絡(luò)數(shù)據(jù)就好了锣笨。
針對這種情況蝌矛，我們就可以使用 RACMulticastConnection.
不管訂閱多少次信號，只會請求一次網(wǎng)絡(luò)數(shù)據(jù)
RACMulticastConnection 使用例子
// 1. 創(chuàng)建信號
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
NSLog(@"請求網(wǎng)絡(luò)數(shù)據(jù)");
// 成功獲取網(wǎng)絡(luò)返回的數(shù)據(jù)错英，發(fā)送數(shù)據(jù)
[subscriber sendNext:@"發(fā)送網(wǎng)絡(luò)數(shù)據(jù)"];
return nil;
}];
// 2. 把信號轉(zhuǎn)換成連接類
// 這里除了用publish創(chuàng)建朴读，也可以用-muticast:方法創(chuàng)建
RACMulticastConnection *connection = [signal publish];
// 3. 訂閱連接類的信號
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"連接類訂閱者一 訂閱信號:%@",x);
}];
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"連接類訂閱者二 訂閱信號:%@",x);
}];
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"連接類訂閱者三 訂閱信號:%@",x);
}];
// 4. 連接
[connection connect];
打印結(jié)果：
2017-05-31 20:36:08.569 RACDemo[1645:604549] 請求網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 20:36:08.569 RACDemo[1645:604549] 連接類訂閱者一 訂閱信號:發(fā)送網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 20:36:08.569 RACDemo[1645:604549] 連接類訂閱者二 訂閱信號:發(fā)送網(wǎng)絡(luò)數(shù)據(jù)
2017-05-31 20:36:08.569 RACDemo[1645:604549] 連接類訂閱者三 訂閱信號:發(fā)送網(wǎng)絡(luò)數(shù)據(jù)
這樣子我們就解決了頻繁訪問網(wǎng)絡(luò)的問題。其實RACMulticastConnection主要就避免了多次調(diào)用創(chuàng)建信號中的block走趋。
接下來讓我們看看 RACMulticastConnection 底層是怎么實現(xiàn)的衅金。
- 第一步創(chuàng)建RACSignal(原始信號)
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber> _Nonnull subscriber) {
// block調(diào)用時刻：當RACMulticastConnection 調(diào)用 connect 方法的時候
// subscribe 此時的本質(zhì)是一個 RACSubject.
// RACSubject sendNext: 遍歷訂閱者數(shù)組，讓訂閱者數(shù)組里面的每一個訂閱者 都去調(diào)用他們的nextBlock簿煌。
// 上面三句看不懂氮唯，沒關(guān)系，記著姨伟，接著往下看
NSLog(@"請求網(wǎng)絡(luò)數(shù)據(jù)");
// 成功獲取網(wǎng)絡(luò)返回的數(shù)據(jù)惩琉，發(fā)送數(shù)據(jù)
[subscriber sendNext:@"發(fā)送網(wǎng)絡(luò)數(shù)據(jù)"];
return nil;
}];
- 第二步，將信號轉(zhuǎn)換成連接類RACMulticastConnection夺荒。首先通過[signal publish]在底層創(chuàng)建一個RACSubject,再把RACSubject和RACSignal保存到RACMulticastConnection中瞒渠，RACMulticastConnection中的_sourceSignal == RACSignal，_signal == RACSubject技扼。
// signal 是 RACSignal 信號類
RACMulticastConnection *connection = [signal publish];
// RACSignal class
- (RACMulticastConnection *)publish {
// 創(chuàng)建一個 RACSubject 信號類
RACSubject *subject = [[RACSubject subject] setNameWithFormat:@"[%@] -publish", self.name];
// 返回連接類 RACMulticastConnection
RACMulticastConnection *connection = [self multicast:subject];
return connection;
}
- (RACMulticastConnection *)multicast:(RACSubject *)subject {
[subject setNameWithFormat:@"[%@] -multicast: %@", self.name, subject.name];
// 創(chuàng)建連接類RACMulticastConnection伍玖，傳入一個RACSignal和一個RACSubject，self就是RACSignal
RACMulticastConnection *connection = [[RACMulticastConnection alloc] initWithSourceSignal:self subject:subject];
return connection;
}
// RACMulticastConnection class
- (instancetype)initWithSourceSignal:(RACSignal *)source subject:(RACSubject *)subject {
NSCParameterAssert(source != nil);
NSCParameterAssert(subject != nil);
self = [super init];
// _sourceSignal 是 RACSignal, _signal 是 RACSubject
_sourceSignal = source;
_serialDisposable = [[RACSerialDisposable alloc] init];
_signal = subject;
return self;
}
- 第三步剿吻，訂閱連接類信號窍箍。
[connection.signal subscribeNext:^(id _Nullable x) {
NSLog(@"連接類訂閱者一 訂閱信號:%@",x);
}];
上面說過了，connection.signal 中的signal就是RACSubject丽旅，在前兩章有說過椰棘，RACSubject訂閱信號的原理是 創(chuàng)建訂閱者，保存nextBlock,將創(chuàng)建的訂閱者存放到一個訂閱者數(shù)組里面中去榄笙。
- 第四步邪狞，連接。[connection connect] 內(nèi)部會訂閱RACSignal(原始信號)茅撞，并且訂閱者是RACSubject帆卓。訂閱RACSignal杆逗，會調(diào)用第一步中的block。
[connection connect];
- (RACDisposable *)connect {
BOOL shouldConnect = OSAtomicCompareAndSwap32Barrier(0, 1, &_hasConnected);
if (shouldConnect) {
// 重點這句鳞疲，self.sourceSignal 就是RACSignal,_signal就是RACSubject.
//此處RACSignal訂閱信號罪郊，訂閱者就是RACSubject
// 訂閱RACSignal，會調(diào)用第一步中創(chuàng)建信號的block尚洽。
self.serialDisposable.disposable = [self.sourceSignal subscribe:_signal];
}
return self.serialDisposable;
}
總結(jié)
RACMulticastConnection 使用并不難悔橄，理解的話可能會有點繞。如果單純看我寫的可能會看不懂腺毫，建議自己去看下源碼癣疟，可能更好理解一點。
自己在這里繼續(xù)做下對RACMulticastConnection簡短的總結(jié)
1.創(chuàng)建RACSignal（原始信號） + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
2.創(chuàng)建連接 RACMulticastConnection *connection = [signal publish];
2-1 connection 里面就包含了兩個信號(sourceSignal,_signal)潮酒，一個是我們自己創(chuàng)建的RACSignal(原始信號),另外一個就是它在底層幫我們創(chuàng)建的RACSubject睛挚。
3.訂閱connection.signal 信號，其實就是訂閱RACSubject信號急黎。創(chuàng)建訂閱者扎狱，訂閱者保存nextBlock,將訂閱者保存到一個數(shù)組中。
4.連接[connection connect]勃教。
4-1.訂閱RACSignal(原始信號)淤击，訂閱者就是RACSubject
4-2.訂閱原始信號，就會調(diào)用原始信號中的didSubscribe
4-3.在didSubscribe中故源，拿到訂閱者污抬，調(diào)用sendNext，其實是調(diào)用RACSubject的sendNext
4-4.RACSubject調(diào)用sendNext绳军，其實就是會遍歷RACSubject所有訂閱者發(fā)送信號印机，調(diào)用它們保存的nextBlock.
