关于RAC： 代码层面分析信号量的核心概念，信号量是程序中各种事件的承载实例，就像一根管子，一头连接生产者，一边连接消费者。当消费者有消费需求，生产者就生产产品。数据就是这个管子中的产品。期间经过加工处理，最后成为消费者需要的产品，送达消费者手中。并且这些管子还会有合并的情况，管子中任何产品的改变都会影响最后组合成的产品。
如图：查看RAC的头文件，我们发现信号量继承自RACStream,stream可以理解为代码片段的执行流，它就是实例就是信号量。这是一种函数式编程的思想。函数式编程更加注重代码块的复用，我们每一步都在操作数据，却把操作点把从数据本身改变成函数方法上面去，将变量之间建立绑定，这就是响应式编程的内容，所以RAC也可以称作函数响应式编程框架简称FRP。信号量是RAC的核心概念。
接下来，我们要构建一个信号量，进行json数据的网路请求，并进行解析，来加深对信号量的理解。
.h文件
#import "ViewController.h" @import ReactiveCocoa; @interface ViewController () @end @implementation ViewController - (void)viewDidLoad { [super viewDidLoad]; //http://www.orzer.club/test.json [[self signalFormJson:@"http://www.orzer.club/test.json"] subscribeNext:^(id x) { NSLog(@"%@",x[@"data"]); } error:^(NSError * error){ NSLog(@"%@",error); } completed:^{ NSLog(@"错误"); }]; //第二个显著的优势就是信号量简化了多线程的操作的复杂程度 //例如： RACSignal * s=[self signalFormJson:@"http://www.orzer.club/test.json"]; RACSignal * s2=[self signalFormJson:@"http://www.orzer.club/test.json"]; RACSignal * s3=[self signalFormJson:@"http://www.orzer.club/test.json"]; //使用传统的GCD方式异步请求 dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{ //网络请求 dispatch_async(dispatch_get_main_queue(), ^{ //主线程刷新UI }); }); //如果使用同步请求，三个请求完成以后再调用 dispatch_group_t group = dispatch_group_create(); dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{ //并行操作一 //如果并行操作里面，还是一个异步请求，甚至需要用同步锁这样的复杂技术 }); dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{ //并行操作二 }); dispatch_group_notify(group, dispatch_get_main_queue(), ^{ //同步操作 }); //三个信号量的顺序执行，把三个信号量合并成一条管道 [[s merge:s2] merge:s3]; //三个信号量的串行 [[[s then:^RACSignal *{ return s2; }] then:^RACSignal *{ return s3; }] subscribeNext:^(id x) { }]; //同步,将三个信号量并行，三个请求完毕以后才交给订阅者 [[RACSignal combineLatest:@[s,s2,s3]] subscribeNext:^(id x) { }]; } -(RACSignal *)signalFormJson:(NSString *)urlStr{ return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { NSURLSessionConfiguration * c =[NSURLSessionConfiguration defaultSessionConfiguration]; NSURLSession * session =[NSURLSession sessionWithConfiguration:c]; NSURLSessionDataTask * data =[session dataTaskWithURL:[NSURL URLWithString:urlStr] completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) { if(error){ [subscriber sendError:error]; }else{ NSError * e; NSDictionary * jsonDic =[NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:&e]; if(e){ [subscriber sendError:e]; }else{ [subscriber sendNext:jsonDic]; [subscriber sendCompleted]; } } }]; [data resume]; return [RACDisposable disposableWithBlock:^{ }]; }]; }