RAC+MVVM开发模式

ReactiveObjC

RAC的目的就是取代iOS中的消息传递机制的 比如 target-action / 代理 / 通知 / kvo / 等等 RAC的本质其实就是KVO+Block对iOS系统事件进行封装

1.例如

button的点击事件

1
2
3
4
5
6
7
RACDisposable* senderDispoable = [[_sender rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
NSLog(@"点击事件.......");
}];
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{

[senderDispoable dispose];  //三秒之后取消订阅 就接收不到事件了 设置_sender.enabled同样有效
});

obj的响应方法

1
2
3
[[self rac_signalForSelector:@selector(viewDidLoad)] subscribeNext:^(RACTuple * _Nullable x) {
/// viewDidLoad
}];

代理d方法

1
2
3
4
5
6
UITableView* table = [UITableView new];
[[self rac_signalForSelector:@selector(tableView:numberOfRowsInSection:) fromProtocol:@protocol(UITableViewDataSource)] subscribeNext:^(RACTuple * _Nullable x) {

NSLog(@"点击了:%@", x.last);
}];
[table reloadData];

通知

1
2
3
4
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"DogNotiName" object:nil] subscribeNext:^(NSNotification * _Nullable x) {

NSLog(@"通知回调....");
}];

KVO

1
2
3
4
5
6
7
8
9
RACDisposable* dispose = [RACObserve(dog, dogName) subscribeNext:^(id  _Nullable x) {

NSLog(@"观察者回调:%@", x);
} error:^(NSError * _Nullable error) {

} completed:^{

}];
//    [dispose dispose]; //取消观察

RAC信号

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
// 1.创建信号
RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
    // 3.发送信号
    [subscriber sendNext:@"ws"];
    NSLog(@"发送信号1");
    [subscriber sendCompleted];
    NSLog(@"发送信号2");
    // 4.取消信号，如果信号想要被取消，就必须返回一个RACDisposable
    // 信号什么时候被取消：1.自动取消，当一个信号的订阅者被销毁的时候机会自动取消订阅，2.手动取消，
    //block什么时候调用：一旦一个信号被取消订阅就会调用
    //block作用：当信号被取消时用于清空一些资源
    
    return [RACDisposable disposableWithBlock:^{
        NSLog(@"取消订阅");
    }];
}] doNext:^(id  _Nullable x) {

    NSLog(@"doNext");
}];

//2. 订阅信号
// 只要订阅信号就会返回一个取消订阅信号的类
RACDisposable *disposable = [signal subscribeNext:^(id x) {
    // block的调用时刻：只要信号内部发出数据就会调用这个block
    NSLog(@"======%@", x);
}];
// 取消订阅
//  [disposable dispose];

登录的逻辑

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
@weakify(self);
void (^loginSucceed)(void) = ^{

    [[NSNotificationCenter defaultCenter] postNotificationName:k_login_succeed_noti object:nil userInfo:nil];
    [self_weak_.signInSender.activity hideAnimated:YES];
    [self_weak_.signInSender setTitle:@"登录成功" forState:0];
    [self_weak_.pwdField resignFirstResponder];
    [self_weak_.userField resignFirstResponder];
    
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(.5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self_weak_ dismissViewControllerAnimated:YES completion:nil];
    });
};

void (^loginFailure)(void) = ^{

    [self_weak_.signInSender.activity hideAnimated:YES];
    [self_weak_.signInSender setTitle:@"登录失败" forState:0];
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(.5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        [self_weak_.signInSender setTitle:@"Sign in" forState:0];
    });
};

/// 点击登录按钮
[[self.signInSender rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {

    [self_weak_.signInSender showSysActivityWithStyle:UIActivityIndicatorViewStyleWhite];
    [self_weak_.signInSender setTitle:@"" forState:0];
    
    /// 请求登录
    [[ServerApiManager api] login:self_weak_.userField.text password:self_weak_.pwdField.text callBack:^(id  _Nullable response, id  _Nullable error) {
    
        if (error) {
            loginFailure();
            return ;
        }
        /// 请求用户信息
        [UserInfo requestUserInfoCallBack:^(id  _Nullable response, id  _Nullable error) {
        
            error == nil ? loginSucceed() : loginFailure();
        }];
    }];
    
}];

信号的组合

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@weakify(self);
RACSignal* singnal = [RACSignal combineLatest:@[self.userField.rac_textSignal, self.pwdField.rac_textSignal] reduce:^id _Nonnull(NSString* account, NSString* password){

/// 用户名长度大于0 且 密码长度大于6 才会产生一次信号
    return @(self_weak_.userField.text.length > 0 && self_weak_.pwdField.text.length >= 6);
}];

/// 产生的信号和登录按钮是否可用关联
RAC(self.signInSender, enabled) = singnal;

/// 当用户名密码长度够时修改按钮UI
[singnal subscribeNext:^(id  _Nullable x) {
    self_weak_.signInSender.alpha = [x boolValue] == YES ? 1.0 : 0.95;
}];

三个滑块和对应三个输入框都可以自定义修改(范围是0~1) 从而影响最后rgb颜色

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
-(void)colorImp1{

    RACSignal* singnal1 =  [self bindAction:_redSlider textFild:_redFild];
    RACSignal* singnal2 =  [self bindAction:_greenSlider textFild:_greenFild];
    RACSignal* singnal3 =  [self bindAction:_blueSlider textFild:_blueFild];
    
    RACSignal* singnal = [[RACSignal combineLatest:@[singnal1,singnal2,singnal3]] map:^id _Nullable(RACTuple * _Nullable value) {
    
        return [UIColor colorWithRed:[value[0] floatValue] green:[value[1] floatValue] blue:[value[2] floatValue] alpha:1];
    }];
    
        RAC(_colorBackview, backgroundColor) = singnal;
    
    }
    
    -(RACSignal* )bindAction:(UISlider*)slider textFild:(UITextField*)textfild{
    
        //通信管道  用于双向绑定 任意一个改变会影响另一个的值
        RACChannelTerminal* sliderChannel = [slider rac_newValueChannelWithNilValue:nil];
        RACChannelTerminal* textFildChannel = [textfild rac_newTextChannel];
        
        //两者相互订阅
        [textFildChannel subscribe:sliderChannel];
        //----订阅的时候 修改返回数据类型用map
        [[sliderChannel map:^id _Nullable(id  _Nullable value) {
        
        return [NSString stringWithFormat:@"%.3f",[value floatValue]];
        }] subscribe:textFildChannel];
        
        
        
        //merge 合并的信号 只要有一个改变了 合并的信号就会被订阅到
        RACSignal* mergeSingnal = [sliderChannel merge:textFildChannel];
        
        return [mergeSingnal merge:textfild.rac_textSignal];
}

RAC与MVVM

1
2
3
4
rac与mvvm结合可以更好的使用mvvm模式
1、数据绑定：作用View和ViewModel之间，但ViewModel中数据因为用户的操作变化时，View更改马上更新。
2、网络请求: 把网络请求封装成Command,在View层触发网络访问
3、Model 数据变化的时候，更新ViewModel数据

VC中的网络请求

1
2
3
4
5
6
7
8
9
10
11
12
@weakify(self);
[self.viewModel.requestCommand.executionSignals.switchToLatest dsz_subscribeNetServiceCallBack:^(id  _Nullable response, id  _Nullable error) {
    if (!error) {
        [self_weak_ reloadData];
    }
    [self_weak_ tableEndRefreshWithNoMoreData:NO];
}];
void (^request)(void) = ^{
    [self.viewModel.requestCommand execute:self.currectSubPath];
};
self.headerRefreshBlock = request;
request();

ViewModel中的请求实现

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
-(RACCommand *)requestCommand{
    if (!_requestCommand) {
        @weakify(self);
        _requestCommand = [RACCommand newCommandWithRsCallBack:^(id input, id<RACSubscriber> subscriber) {
            [self_weak_ requestDataInput:input subscriber:subscriber];
        }];
    }
        return _requestCommand;
}

-(void)requestDataInput:(id)input subscriber:(id<RACSubscriber>)subscriber{

    /// 统一在baseVC中显示tip/成功/失败/加载等
    [self.rsSignal sendNext:JMRS(TITLELOADING, @"更新中...")];
    @weakify(self);
    [[ServerApiManager api] reposSubPaths:self.currectRepoName user:UserInfo.user subpath:chineseUrl(input) callBack:^(id  _Nullable response, id  _Nullable error) {
    
        [self.rsSignal sendNext:JMRS(TITLELOADING, nil)];
        if (!error) {
        
            [self_weak_.rsSignal sendNext:JMRS(TITLELOADING, nil)];
            
            self_weak_.datasArray = response;
            
            [subscriber sendNext:error];
            [subscriber sendCompleted];
            return ;
        }
        [self_weak_.rsSignal sendNext:JMRS(UNKNOW_ERROR, @"请求失败")];
    }];

}

Cell中的数据绑定

1
2
3
4
5
6
7
8
9
10
11
12
13
14
- (void)awakeFromNib {
    [super awakeFromNib];

    RAC(self, fileName.text) = RACObserve(self, subpathInfo.name);
    
    RAC(self, time.text) = [RACObserve(self, subpathInfo.type) map:^id _Nullable(id  _Nullable value) {
        return [value uppercaseString];
    }];
    
    RAC(self, directIcon.hidden) = [RACObserve(self, subpathInfo.type) map:^id _Nullable(id  _Nullable value) {
        return @(![value isEqualToString:@"dir"]);
    }];
}

扫一扫，分享到微信

微信分享二维码

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true