扫一扫体验手机阅读
Oracle 学习之RAC(一) 架构解析
<span type="1" blog_id="1683810" userid='
分享到朋友圈
关注作者，不错过每一篇精彩Oracle RAC技术培训学习——甲骨文【重庆思庄】更专业【oracle培训吧】_百度贴吧
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&签到排名：今日本吧第个签到，本吧因你更精彩，明天继续来努力！
本吧签到人数：0成为超级会员，使用一键签到本月漏签0次！成为超级会员，赠送8张补签卡连续签到：天&&累计签到：天超级会员单次开通12个月以上，赠送连续签到卡3张
关注：390贴子：
Oracle RAC技术培训学习——甲骨文【重庆思庄】更专业收藏
全面推进RAC、Dataguard及IBM小机系列实用技术的培训
思庄中心将紧跟企业前进的步伐，切实实现“学以致用”的承诺，脚踏实地，为社会尽快培养出急需的适用的IT高端人才。中心将以Oracle大型 数据库为核心，针对市场对人才的需求，全面开展进一步提升学员能力的实用技术的培训。目前推出的技能延伸课程有Oracle RAC、Oracle Dataguard、数据库优化、IBM小机及AIX操作系统、SAN光迁存储管理、双机等。
思庄中心开展的各种延伸实用技术培训，将实行对本中心的OCP学员全面打7折的优惠政策，为思庄中心OCP学员能尽快高薪就业铺平道路。中心将为学员提供企业级实验环境和技术现场观摩的机会，为在校大学生提供比在职人员更加优惠的政策或实习的机会。同时感谢各位新老学员的信任！咨询QQ：　地址：重庆市科园三路南方花园B区B座3单元7-4#　邮编：400039 电话：023- 　　手机： 　　传真：023-邮箱：网址：
HACMP 对于初级的 AIX 系统管理员来说是一个必须去掌握的内容，也是成为高级管理员的必经之路。目前，HACMP 的学习内容已经有不少了，但是真正把相关内容总结起来确不是很多。
重庆思庄认证学习中心，拥有10多年数据库、服务器维保经验，拥有大量一、二线工程师教学，精通AIX、HP-UX、linux等类UNIX操作系统，精通HACMP、MC-SG、RHCS等各种主流高可用群集，精通各主流厂商DAS、NAS、SAN存储解决方案及产品。长期从事电信运营商及大型政商客户技术支持服务工作，具有丰富的运维及实施经验。
获得IBM system P CSA /HP HP-UX CSA/Cisco CCNP/ IBM产品解决方案技术专家等证书。具有丰富的UNIX管理培训经验。我们在这里，为您提供了 AIX and UNIX 专区拥有的和 HACMP 相关的培训内容，让您更方面和快捷地获取HACMP 管理技能。 HACMP管理（约14课时）1、高可用性的概念2 、HACMP介绍3 、HACMP cluster中物理组成部分及逻辑组成部分4、安装HACMP for AIX5、单个资源组的主备节点a primary node with standby node6、两个资源组的主备节点互为热备在HACMP 环境下的配置7、HACMP 资源组的startup、fallover 和fallback 策略8、故障诊断方法 能力达标：基础课程包+进阶课程包学习完成之后，能够掌握AIX及高可用群集HACMP的安装、配置和管理,并具备解决相应的系统故障的能力；掌握主流存储阵列的安装、调试、维护，以及SAN网络规划和实施能力。 职业方向：网络存储工程师AIX系统运维工程师AIX系统工程师高级系统架构师信息技术总监系统集成项目经理
登录百度帐号iOS RAC学习之路（二） - 简书
iOS RAC学习之路（二）
之前对RAC有了一个基本的认识，了解了它的作用，以及RAC的运行机制，我们知道只要是信号（RACSignal），我们就能对它进行一顿订阅，然后执行触发操作；接下来我们来学习一下RAC中常用的类以及一系列的用法。
这是一个信号类，表示一个信号源，只要有数据改变就会把数据包装成信号传递出去，它本身不具备发送信号的能力，而是交给内部的一个订阅者(RACSubscriber)去发出，然后当信号被订阅之后，就会在其内部就创建一个订阅者，所以在信号内部就可以发送信号了，之前也对RACSignal做了一个，下面学习一下更多的用法
常用事件处理
Target-Action
[[btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
NSLog(@"%@",x);
[self push];
//因为订阅信号是void返回类型的，所以只能代替void返回类型的delegate
[textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
//x==textField.text
NSLog(@"%@",x);
//直接用宏
[RACObserve(self.view, backgroundColor) subscribeNext:^(id
_Nullable x) {
//x==新背景颜色
NSLog(@"%@",x);
//也可以这样
__weak typeof(self) weakSelf =
[[self.view rac_valuesForKeyPath:@"backgroundColor" observer:weakSelf] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillShowNotification object:nil] subscribeNext:^(NSNotification * _Nullable x) {
//x==userInfo
NSLog(@"%@",x);
flattenMap，map
这是两个映射方法，将源信号内容映射成新的内容，就像signal管道上的中间处理器，从这里走过的signal都会经过一段处理后，变成新的signal继续传输。
//map，将输出NSNumber的signal转换成输出NSString
RACSignal *mapSignal = [[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
}] map:^id _Nullable(id
_Nullable value) {
return [NSString stringWithFormat:@"%@",value];
[mapSignal subscribeNext:^(id
_Nullable x) {
//NSString类型
NSLog(@"x");
//flattenMap，将输出NSNumber的signal转换成输出NSString
RACSignal *mapSignal = [[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
}] flattenMap:^__kindof RACSignal * _Nullable(id
_Nullable value) {
return [RACReturnSignal return:[NSString stringWithFormat:@"%@",value]];
[mapSignal subscribeNext:^(id
_Nullable x) {
//NSString类型
NSLog(@"x");
两者之间的区别就在于，map中Block返回转换对象，flattenMap返回转换对象的信号。一般信号发出的值不是信号，使用map；如果是信号则使用flattenMap，它可以处理信号中的信号。
merge：把多个信号合并成一个信号，只需订阅这一个信号就相当于订阅了多个信号，任何一个信号有新值的时候都会触发调用。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
RACSignal *signal3 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(3)];
RACSignal *mergeSignal = [RACSignal merge:@[signal1,signal2,signal3]];
[mergeSignal subscribeNext:^(id
_Nullable x) {
//分别输出1,2,3
NSLog(@"%@",x);
concat：将多个信号有顺序的连接起来，按照顺序接收信号，但是一定要之前的信号完成了才能发送下一个信号。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
//发送信号完成，表示不再订阅了，内部会自动调用[RACDisposable disposable]取消订阅信号。
[subscriber sendCompleted];
RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
[subscriber sendCompleted];
RACSignal *signal3 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(3)];
[subscriber sendCompleted];
RACSignal *concatSignal = [RACSignal concat:@[signal2,signal1,signal3]];
[concatSignal subscribeNext:^(id
_Nullable x) {
//分别输出2,1,3
NSLog(@"%@",x);
then：用于连接两个信号，内部也是使用concat，当前一个信号完成之后才会连接then返回的信号，但是会忽略前一个信号，只会触发下个信号。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
[subscriber sendCompleted];
RACSignal *thenSignal =
[signal1 then:^RACSignal * _Nonnull{
[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
[subscriber sendCompleted];
[thenSignal subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
zip：将对各信号压缩成一个信号，只有当几个信号同时sendNext的时候才会触发压缩流的next事件，其中每一个信号send的内容都是一一对应的。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
//不会覆盖上一个信号
[subscriber sendNext:@(3)];
RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
RACSignal *zipSignal = [RACSignal zip:@[signal1,signal2]];
[zipSignal subscribeNext:^(id
_Nullable x) {
//输出(1,2)
NSLog(@"%@",x);
combineLatest：将多个信号组合起来，当其中每一个信号都sendNext之后，才会触发组合的信号，其中每一个信号再次sendNext都会覆盖之前的信号内容，返回的是一个RACTuple（元组，类似于NSArray）。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
//将覆盖之前的信号，这就是跟zip的区别
[subscriber sendNext:@(3)];
RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
//如果其中一个信号不sendNext，则不会触发组合信号
RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] ];
[combineSignal subscribeNext:^(id
_Nullable x) {
//输出(3,2)
NSLog(@"%@",x);
rac_liftSelector: withSignalsFromArray:：当信号组中每一个信号都至少一次sendNext之后，将触发Selector方法，类似于combineLatest。
RACSubject *subject1 = [RACSubject subject];
RACSubject *subject2 = [RACSubject subject];
[[self rac_liftSelector:@selector(updateWithParameter1:parameter2:) withSignals:subject1,subject2, nil] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
[subject1 sendNext:@1];
[subject2 sendNext:@2];
reduceEach：一般用于元组，把元组的值聚合成一个值。
RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] ];
RACSignal *reduceSignal = [combineSignal reduceEach:^id (NSNumber *num1,NSNumber *num2){
return @(num1.doubleValue+num2.doubleValue);
[reduceSignal subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
//等同于+ (RACSignal *)combineLatest:(id&NSFastEnumeration&)signals reduce:(id (^)())reduceBlock
RACSignal *combineSignal = [RACSignal combineLatest:@[signal1,signal2] reduce:^id (NSNumber *num1,NSNumber *num2){
return @(num1.doubleValue+num2.doubleValue);
filter：过滤信号，添加筛选条件，只有符合的才会触发调用。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
[subscriber sendNext:@"3"];
RACSignal *filterSignal = [signal1 filter:^BOOL(id
_Nullable value) {
return [value isKindOfClass:[NSNumber class]];
[filterSignal subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
//数组的筛选
RACSequence *sequence = [@[@(1),@(2),@"3"].rac_sequence filter:^BOOL(id
_Nullable value) {
return [value isKindOfClass:[NSNumber class]];
[sequence.signal subscribeNext:^(id
_Nullable x) {
//输出1，2
NSLog(@"%@",x);
distinctUntilChanged：当前值跟上一次的值不同的时候，就会触发调用，否则被忽略。
[textField.rac_textSignal.distinctUntilChanged subscribeNext:^(NSString * _Nullable x) {
//变化时输出变化之后的值
NSLog(@"%@",x);
take：从第一个信号开始设置信号发送的有效的个数。
RACSignal *signal = [[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
[subscriber sendNext:@(2)];
}] take:1];
[signal subscribeNext:^(id
_Nullable x) {
//输出1，因为take为1，所以有效的只有最开始的那一个，其他的忽略掉了
NSLog(@"%@",x);
takeLast：从最后一个开始设置信号发送的有效个数，必须sendCompleted，不然不知道总共多少个信号。
[[[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
[subscriber sendNext:@(2)];
[subscriber sendCompleted];
}] takeLast:1] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
takeUntil：[signal1 takeUntil:signal2]，当signal2已经sendNext或者sendCompleted，signal1就会失效。
RACSignal *signal1 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
RACSignal *signal2 = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(2)];
[[signal1 takeUntil:signal2] subscribeNext:^(id
_Nullable x) {
//什么都不会输出，因为signal2已经sendNext，所以signal1就会失效
NSLog(@"%@",x);
skip：跳跃，从第一个发出的信号开始跳。
[[[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
[subscriber sendNext:@(2)];
[subscriber sendNext:@(3)];
}] skip:2] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
doNext：在执行sendNext之前会执行这个。
[[[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
}] doNext:^(id
_Nullable x) {
x = [NSString stringWithFormat:@"%@haha",x];
//输出1haha，在订阅回调之前执行
NSLog(@"%@",x);
}] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
timeout：在超过设定时间范围之后让信号报错，且不能发送内容。
RACSubject *subject = [RACSubject subject];
[[subject timeout:3 onScheduler:[RACScheduler mainThreadScheduler]] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
} error:^(NSError * _Nullable error) {
//3秒之后输出错误日志
NSLog(@"%@",error);
[subject sendNext:@1];
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(4 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
[subject sendNext:@2];
interval：定时，每隔一定时间发出时间信号。
//RACScheduler:队列
[[RACSignal interval:1 onScheduler:[RACScheduler currentScheduler]] subscribeNext:^(NSDate * _Nullable x) {
//每隔一秒输出当前时间
NSLog(@"%@",x);
delay：延时发送信号
[[[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(1)];
}] delay:3] subscribeNext:^(id
_Nullable x) {
//3秒之后输出1
NSLog(@"%@",x);
retry：重试，只要失败，就会重新执行创建信号中的block,直到成功。
__block NSInteger i = 0;
[[[RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
if (i & 10) {
[subscriber sendNext:@(1)];
[subscriber sendError:nil];
}] retry] subscribeNext:^(id
_Nullable x) {
//重试10次之后输出1
NSLog(@"%@",x);
}error:^(NSError * _Nullable error) {
NSLog(@"%@",error);
throttle：节流，当某个信号发送比较频繁的时候，可以限制在一定之间内不接受信号，等过了这个时间再取最后发送的信号内容发出，类似于bufferWithTime:onScheduler:。
RACSubject *subject = [RACSubject subject];
// [subject bufferWithTime:1 onScheduler:[RACScheduler currentScheduler]];
[[subject throttle:1] subscribeNext:^(id
_Nullable x) {
//输出3，拿到最后发出的内容3
NSLog(@"%@",x);
[subject sendNext:@1];
[subject sendNext:@2];
[subject sendNext:@3];
deliverOn：内容传递切换到指定线程中，副作用在原来线程中,把在创建信号时block中的代码称之为副作用。
subscribeOn：内容传递和副作用都会切换到指定线程中。
RACSubject
信号提供者，本身可以充当信号，又能发送信号，继承自RACSignal，但是底层实现跟RACSignal有些不一样，当订阅信号的时候会创建订阅者并保存订阅响应Block，而发送信号的时候会遍历订阅者，然后分别调用nextBlock。它提供的API很少，但是经常使用，因为它继承自RACSignal。这里顺便来看一下方法 flatten跟switchToLatest，这两个都只能用来处理信号中的信号。
flatten：压平信号中的信号，信号中的信号我们称之为子信号，flatten可以拿到所有子信号发送的值。
RACSubject *subject = [RACSubject subject];
RACSubject *subSubject1 = [RACSubject subject];
RACSubject *subSubject2 = [RACSubject subject];
[subject subscribeNext:^(id
_Nullable x) {
//分别输出subSubject1，subSubject2，但是不能拿到其中的值
NSLog(@"%@",x);
[subject.flatten subscribeNext:^(id
_Nullable x) {
//分别输出1，2, flatten可以拿到所有子信号发送的值
NSLog(@"%@",x);
[subject sendNext:subSubject1];
[subject sendNext:subSubject2];
[subSubject1 sendNext:@1];
[subSubject2 sendNext:@2];
switchToLatest：与flatten相同，压平信号中的信号，不同的是，在存在多个子信号时候只会拿到最新的子信号，然后输出最新的子信号的值。
RACSubject *subject = [RACSubject subject];
RACSubject *subSubject1 = [RACSubject subject];
RACSubject *subSubject2 = [RACSubject subject];
[subject subscribeNext:^(id
_Nullable x) {
//分别输出subSubject1，subSubject2，但是不能拿到其中的值
NSLog(@"%@",x);
[subject.switchToLatest subscribeNext:^(id
_Nullable x) {
//输出2, switchToLatest只会拿到最新的子信号发送的值
NSLog(@"%@",x);
[subject sendNext:subSubject1];
[subject sendNext:subSubject2];
[subSubject1 sendNext:@1];
[subSubject2 sendNext:@2];
RACReplaySubject
重复提供信号类，继承自RACSubject，它可以先发送信号，再订阅信号，原理就是将发送的信号内容保存了起来，当订阅信号的时候再将之前保存的信号，由订阅者一个一个的发送出来，而保存信号的容量由capacity来控制。
RACReplaySubject *replaySubject = [RACReplaySubject replaySubjectWithCapacity:5];
[replaySubject subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
[replaySubject sendNext:@1];
[replaySubject subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
RACMulticastConnection
这是一个组播连接类，是对信号的一个封装处理，当一个信号被多次订阅时，则会多次执行didSubscribe这个Block，造成副作用，而这个类就能避免多次执行didSubscribe，是一对多的单向数据流，一般用来处理信号被多次订阅的情况。
__block int i = 0;
//创建信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id&RACSubscriber&
_Nonnull subscriber) {
[subscriber sendNext:@(i)];
//创建RACMulticastConnection对象
RACMulticastConnection *connect = [signal publish]
[connect.signal subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
[connect.signal subscribeNext:^(id
_Nullable x) {
//输出0,当再次订阅时，不会再执行didSubscribe，所以并没有i++
NSLog(@"%@",x);
[connect connect];
方法解析及实现原理
publish，multicast：这是对RACMulticastConnection初始化方法的一个封装，publish其实就是调用了multicast，并把创建好的RACSubject对象传给它，而multicast也就是调用了RACMulticastConnection的初始化方法，将原始信号传给source，把RACSubject对象传给subject。
当我们订阅connect.signal，其实就是订阅subject，然后将subject的订阅者保存起来，而调用[connect connect]的时候，会订阅原始信号（source），而source的订阅者就是subject，这时候subject就会执行[subject sendNext]，之后就会遍历subject所有的订阅者，逐一发送信号，触发外部subscribeNext回调。
RACCommand
这是一个命令类，可以把事件如何处理，事件中的数据如何传递，包装到这个类中，他可以很方便的监控事件的执行过程，一般来说是在UI上的某些动作来触发这些事件，比如点击一个按钮，RACCommand的实例能够决定是否可以被执行，一般用于网络请求，监控请求过程。
公开的属性及方法
@interface RACCommand: NSObject
//这是一个二阶信号，表示信号中包含子信号，一般使用flatten或switchToLatest来降阶
@property (nonatomic, strong, readonly) RACSignal&RACSignal&ValueType& *& *executionS
//这个信号表示当前RACCommand是否正在执行，YES/NO
@property (nonatomic, strong, readonly) RACSignal&NSNumber *& *
//这个信号表示RACCommand是否可用，如果初始化传NO或者allowsConcurrentExecution=NO，那个这个信号返回NO，否则为YES
@property (nonatomic, strong, readonly) RACSignal&NSNumber *& *
//表示RACCommand执行过程中产生的错误信号，当对错误信号进行处理的时候应该subscribeNext去订阅，而不是subscribeError。
@property (nonatomic, strong, readonly) RACSignal&NSError *& *
//是否允许并发执行，默认为NO
@property (atomic, assign) BOOL allowsConcurrentE
@param signalBlock 返回信号的Block,在其内部进行保存，当进行execute的时候才会调用该Block
@return self
- (instancetype)initWithSignalBlock:(RACSignal&ValueType& * (^)(InputType _Nullable input))signalB
@param enabledSignal 是否可用
@param signalBlock 返回信号的Block,在其内部进行保存，当进行execute的时候才会调用该Block
@return self
- (instancetype)initWithEnabled:(nullable RACSignal&NSNumber *& *)enabledSignal signalBlock:(RACSignal&ValueType& * (^)(InputType _Nullable input))signalB
@param input 输出内容
@return 组播连接对象的signal
- (RACSignal&ValueType& *)execute:(nullable InputType)
使用步骤：
创建命令，初始化RACCommand对象，内部做的事情：
将传入的signalBlock进行保存
初始化自己的4个信号，executionSignals，executing，enabled，errors。
在signalBlock中创建RACSignal，用来做数据传递，如果不需要可以创建空信号[RACSignal empty]。
执行命令execute，内部做的事情：
调用之前保存的signalBlock，并将execute参数带入进去，拿到signalBlock返回的信号。
再将该信号内容切换到主线程，然后multicast成RACMulticastConnection对象，避免多次订阅导致重复创建信号。
将connection.signal
map到executionSignals，当原始信号发送数据的时候，通过switchToLatest或flatten来降阶取值。
//1.创建命令对象
RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
//输出1,由execute传入
NSLog(@"%@",input);
//2.创建信号
return [RACSignal createSignal:^RACDisposable *(id&RACSubscriber& subscriber) {
[subscriber sendNext:@(2)];
// 注意：数据传递完，最好调用sendCompleted，这时命令才执行完毕。
[subscriber sendCompleted];
//获取信号传输的数据
[command.executionSignals.switchToLatest subscribeNext:^(id x) {
NSLog(@"%@",x);
//这里用flatten跟switchToLatest也是一样的
[[command.executionSignals flatten] subscribeNext:^(id
_Nullable x) {
NSLog(@"%@",x);
//监听命令是否执行完毕,初始化时会调用一次，用skip直接跳过。
[[command.executing skip:1] subscribeNext:^(id x) {
if ([x boolValue] == YES) {
// 正在执行
NSLog(@"正在执行");
// 执行完成
NSLog(@"执行完成");
//3.执行命令
RACSignal *connectSignal = [command execute:@1] ;
[connectSignal subscribeNext:^(id
_Nullable x) {
//输出2，connectSignal是connect.signal
NSLog(@"%@",x);
RACChannel
这是一个通道类，可以理解为一个双向的连接，连接的两端都配有RACChannelTerminal（通道终端，继承自RACSignal，且又实现了RACSubscriber协议，所以它可以充当信号，又能发送信号），分别是leadingTerminal，followingTerminal，只要其中任何一端输出信号，另一端都会有相同的信号输出。我们平时很少直接使用RACChannel，而是使用RACChannelTo。
RACChannelTo：使用这个宏要传入相关对象以及它的属性，比如RACChannelTo(view,backgroundColor)，实际上创建了一个RACKVOChannel对象，在内部将其一端的leadingTerminal与view的backgroundColor属性进行绑定，并将其另一端followingTerminal暴露出来，也就是RACChannelTo的返回值，我们可以对followingTerminal进行订阅，拿到view. backgroundColor，同样followingTerminal发送信号也会同步到view.backgroundColor。
用它来实现双向绑定，RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);将button跟view的背景颜色进行绑定，两边相互影响，进行同步。
RACChannelTerminal *followT = RACChannelTo(view,backgroundColor);
[followT subscribeNext:^(id
_Nullable x) {
//每点击一次就输出一次随机颜色
NSLog(@"%@",x);
UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc]init];
[tap.rac_gestureSignal subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
//改变view.backgroundColor
[followT sendNext:RandomColor];
//将_textField.backgroundColor跟view.backgroundColor绑定
RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);
RAC(TARGET, ...)：给某个对象的某个属性进行绑定。
//当textfield开始编辑时，关闭button响应
RAC(_button,enabled) = [[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] mapReplace:@NO];
RACObserve(TARGET, KEYPATH)：KVO，监听某个对象的属性，返回的是信号。
[RACObserve(self.view, backgroundColor) subscribeNext:^(id
_Nullable x) {
//x==新背景颜色
NSLog(@"%@",x);
RACChannelTo：用于双向绑定的一个通道终端。
//将_textField.backgroundColor跟view.backgroundColor绑定
RACChannelTo(button,backgroundColor) = RACChannelTo(view,backgroundColor);
RACTuplePack：将数据包装成RACTuple（元组）。
RACTuple *tuple = RACTuplePack(@1,@2,@"3");
RACTupleUnpack(...)：把元组解包成对应的数据
//传入需要解析生成的变量名，从第一个开始解析
RACTupleUnpack(NSNumber *num1,NSNumber *num2) =
//输出1，2
NSLog(@"%@,%@",num1,num2);
学习改变人生，习惯成就事业。
RAC使用测试Demo下载：github.com/FuWees/WPRACTestDemo 1.ReactiveCocoa简介 ReactiveCocoa（简称为RAC）,是由Github开源的一个应用于iOS和OS开发的新框架,Cocoa是苹果整套框架的简称，因此很多苹果...
在上篇文章中介绍了ReactiveCocoa的基础知识,接下来我们来深入介绍ReactiveCocoa及其在MVVM中的用法。 转载自最快让你上手ReactiveCocoa之进阶篇，稍作修改 常见操作方法介绍 操作须知 所有的信号（RACSignal）都可以进行操作处理，因...
1.ReactiveCocoa常见操作方法介绍1.1 ReactiveCocoa操作须知所有的信号（RACSignal）都可以进行操作处理，因为所有操作方法都定义在RACStream.h中，而RACSignal继承RACStream。 1.2. ReactiveCocoa操...
前言由于时间的问题，暂且只更新这么多了，后续还会持续更新本文《最快让你上手ReactiveCocoa之进阶篇》，目前只是简短的介绍了些RAC核心的一些方法，后续还需要加上MVVM+ReactiveCocoa实战开发。如果喜欢我的文章，可以关注我，也可以来小码哥，了解下我们的...
1.ReactiveCocoa常见操作方法介绍。 1.1 ReactiveCocoa操作须知 所有的信号（RACSignal）都可以进行操作处理，因为所有操作方法都定义在RACStream.h中，而RACSignal继承RACStream。 1.2 ReactiveCoco...
玻尿酸以胶状形态存在于人体皮肤的真皮组织中，储存肌肤水分从而增加皮肤容积，使皮肤看起来饱满、丰盈、有弹性。 玻尿酸会随着人年龄增长而不断流失，使皮肤失去储水的能力，逐渐变得暗沉、老化，小细纹逐渐产生并最终形成皱纹。现如今科技人员利用技术把玻尿酸从动物的结缔组织提取出来，用于...
** 将postman 的请求转换为代码** 点击code 在右上角的下拉框选择对应的语言 Copy to Clipboard ** 运行测试用例 ** 在Tests中添加检查代码 环境变量中设置全局变量 var1 在请求的参数的值中填 {{var1}} 在collect中...
这个场景，你是不是很熟悉：一早到公司，打开电脑，先看下腾讯的迷你新闻页，各种新鲜的娱乐八卦和社会奇闻扑面而来，等什么，点开看啊。等回过神儿来，一个小时已经过去，而你迷迷糊糊的还没有进入状态，更不用提什么进展。注意力就像扑进大海的人，怎么也游不上岸。 又或者，这种情况也是你熟...
网易科技讯3月3日消息据印度经济时报报道，由于扩张过快导致资金紧张，乐视印度将裁员85%，并有可能最终退出印度市场。 报道引用内部知情人士的话称，两位主管智能设备和互联网应用的印度高管也已辞职。乐视印度每月广告开支高达8000万卢比（约合827万人民币），公司在去年已经彻底...