Swift - RxSwift入门介绍

RxSwift介绍

RxSwift 是 ReactiveX 家族的重要一员,还有 RxJava, RxJS, RxKotlin, Rx.NET等等。 ReactiveX是 Reactive Extensions 的缩写，一般简写为Rx。
ReactiveX 官方给Rx的定义是，Rx是一个使用可观察数据流进行异步编程的编程接口。
ReactiveX 不仅仅是一个编程接口，它是一种编程思想的突破，它影响了许多其它的程序库和框架以及编程语言。它拓展了观察者模式，使你能够自由组合多个异步事件，而不需要去关心线程，同步，线程安全，并发数据以及I/O阻塞。
RxSwift 是 Rx 为 Swift 语言开发的一门函数响应式编程语言，它可以代替iOS系统的 Target Action /代理/ 闭包 / 通知 / KVO …..
同时还提供网络、数据绑定、UI事件处理、UI的展示和更新、多线程……

RxSwift优势

RxSwift对使用swift的帮助有如下几点：

RxSwift使得代码复用性较强，减少代码量
RxSwift因为声明都是不可变更，增加代码可读性
RxSwift使得更易于理解业务代码，抽象异步编程，统一代码风格
RxSwift使得代码更易于编写集成单元测试，增加代码稳定性

RxSwift引入

platform :ios, '9.0'
# Comment the next line if you're not using Swift and don't want to use dynamic frameworks
use_frameworks!

target 'RxProject' do
  pod 'RxSwift'
  pod 'RxCocoa'
end

# RxTests 和 RxBlocking 将在单元/集成测试中起到重要作用
target 'YOUR_TESTING_TARGET' do
  pod 'RxBlocking', '~> 5.0'
  pod 'RxTest', '~> 5.0'
end

替换 YOUR_TARGET_NAME 然后在 Podfile 目录下, 终端输入：

$ pod install

RxSwift 与 RxCocoa

我们会在 Swift 项目中引入 RxSwift、RxCocoa 这两个库，他们的作用分别是：

RxSwift：它只是基于 Swift 语言的 Rx 标准实现接口库，所以 RxSwift 里不包含任何 Cocoa 或者 UI方面的类。
RxCocoa：是基于 RxSwift针对于 iOS开发的一个库，它通过 Extension 的方法给原生的比如 UI 控件添加了 Rx 的特性，使得我们更容易订阅和响应这些控件的事件。

RxSwift基础使用

    //MARK: - RxSwift应用-网络请求
    func setupNextwork() {
        let url = URL(string: "https://www.baidu.com")
        URLSession.shared.rx.response(request: URLRequest(url: url!))
            .subscribe(onNext: { (response,data) in
                print(response)
        }).disposed(by: disposeBag)
    }
    
    //MARK: - RxSwift应用-timer定时器
    func setupTimer() {
        timer = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        timer.subscribe(onNext: { (num) in
            print(num)
        })
        .disposed(by: disposeBag)
    }
    
    //MARK: - 通知
    func setupNotification(){
        NotificationCenter.default.rx.notification(UIResponder.keyboardWillShowNotification)
            .subscribe(onNext: { (noti) in
                print(noti)
            })
        .disposed(by: disposeBag)
        
    }
    
    //MARK: - 手势
    func setupGestureRecognizer(){
        let tap = UITapGestureRecognizer()
        self.label.addGestureRecognizer(tap)
        self.label.isUserInteractionEnabled = true
        tap.rx.event.subscribe(onNext: { (tap) in
            print(tap.view)
        })
        .disposed(by: disposeBag)
    }
    
    //MARK: - RxSwift应用-scrollView
    func setupScrollerView() {
        scrollView.rx.contentOffset
            .subscribe(onNext: { [weak self](content) in
                self?.view.backgroundColor = UIColor.init(red: content.y/255*0.8, green: content.y/255*0.6, blue: content.y/255*0.3, alpha: 1)
            })
        .disposed(by: disposeBag)
    }
    
    //MARK: - RxSwift应用-textfiled
    func setupTextFiled() {
        self.textFiled.rx.text.orEmpty
            .subscribe(onNext: { (text) in
               print(text)
            })
            .disposed(by: disposeBag)
    }
    
    //MARK: - RxSwift应用-button响应
    func setupButton() {
        self.button.rx.tap
            .subscribe(onNext: { () in
                print("点击来了")
            })
            .disposed(by: disposeBag)
    }
    
    //MARK: - RxSwift应用-KVO
    func setupKVO() {
        self.person.rx.observeWeakly(String.self, "name")
            .subscribe(onNext: { (value) in
                print(value as Any)
            })
            .disposed(by: disposeBag)
    }

    //MARK: - RxSwift应用-监听键盘
    NotificationCenter.default.rx
.notification(UIResponder.keyboardWillShowNotification)
    .subscribe(onNext: { (notification) in
        //获取值
        let during = notification.userInfo?["UIKeyboardAnimationDurationUserInfoKey"] as? Float
        print(during!)
        //处理事件 ……
    }).disposed(by: disposeBag)

RxSwift核心流程

可观察序列思维导图

Observable核心流程图