RxSwift 簡單使用和與swift的寫法對(duì)比

RxSwift特點(diǎn)

swift是一門靜態(tài)語言漫蛔，不像OC那樣可以動(dòng)態(tài)的傳輸數(shù)據(jù)發(fā)送消息蕉堰，RxSwift可以彌補(bǔ)swift的這種語言特性旅掂。
RxSwift函數(shù)響應(yīng)式編程思想泽台，其代碼可讀性強(qiáng)什荣、復(fù)用性高、容易理解怀酷、很穩(wěn)定稻爬，抽象了異步編程統(tǒng)一代碼風(fēng)格。

函數(shù)響應(yīng)式編程FRP(Function Reactive Programming)

1蜕依、函數(shù)式是以函數(shù)作為參數(shù)的編程方式

函數(shù)式例子：

        //獲取大于3的數(shù)字之后將其加1桅锄，并取結(jié)果中的偶數(shù)

        let array = [1, 2, 3, 4, 5, 6, 7]
        for num in array {
            if (num > 3) {
                let number = num + 1
                if (number % 2 == 0) {
                    print(number)
                }
            }
        }

        //函數(shù)式寫法：filter函數(shù)參數(shù)是一個(gè)閉包，$0 > 3表示取數(shù)組第一個(gè)值大于3
        array.filter { $0 > 3 }
            .filter { ($0 + 1) % 2 == 0 }
            .forEach { print($0) }

對(duì)比之后發(fā)現(xiàn)函數(shù)式可讀性和可操作性更強(qiáng)

2样眠、響應(yīng)式：RxSwift 簡單使用
KVO

KVO是runtime的運(yùn)行時(shí)機(jī)制友瘤，在靜態(tài)語言swift里無法執(zhí)行，需要加上@objc dynamic才能執(zhí)行檐束，@objc的意思是使用OC訪問這段代碼辫秧，dynamic是開啟運(yùn)行時(shí)功能

swift寫法：

//  LYPerson.swift
class LYPerson: NSObject {
    @objc dynamic var name:String = "ly"
}

//  ViewController.swift
    override func viewDidLoad() {
        super.viewDidLoad()
        self.setupKVO()
    }
    func setupKVO() {
        self.person.addObserver(self, forKeyPath: "name", options: .new, context: nil)
    }
    
    override func touchesBegan(_ touches: Set<UITouch>, with event: UIEvent?) {
        person.name = "\(person.name) + "
    }
    
    override func observeValue(forKeyPath keyPath: String?, of object: Any?, change: [NSKeyValueChangeKey : Any]?, context: UnsafeMutableRawPointer?) {
        print(change as Any)
    }
    
    deinit {
        self.person.removeObserver(self, forKeyPath: "name", context: nil)
    }

/*
輸出結(jié)果：
Optional([__C.NSKeyValueChangeKey(_rawValue: new): ly + , __C.NSKeyValueChangeKey(_rawValue: kind): 1])
Optional([__C.NSKeyValueChangeKey(_rawValue: new): ly +  + , __C.NSKeyValueChangeKey(_rawValue: kind): 1])
*/

RxSwift寫法：

//  ViewController.swift
    func setupKVO() {
        self.person.rx.observeWeakly(String.self, "name")
            .subscribe(onNext: { (value) in
                print(value as Any)
            })
            .disposed(by: disposeBag)
    }

/*
輸出結(jié)果：
Optional("ly")
Optional("ly + ")
Optional("ly +  + ")
*/
Button

swift寫法：

func setupButton() {
        self.button.addTarget(self, action: #selector(buttonClick), for: .touchUpInside)
    }
@objc func buttonClick() {
        print("點(diǎn)擊了按鈕")
    }

RxSwift寫法：

//業(yè)務(wù)邏輯和功能邏輯在一起
func setupButton() {
        self.button.rx.tap
            .subscribe(onNext: { () in
               print("點(diǎn)擊事件")
            })
            .disposed(by: disposeBag)

        self.button.rx.controlEvent(.touchUpInside)
            .subscribe(onNext: { () in
                print("點(diǎn)擊事件1")
            })
            .disposed(by: disposeBag)
    }
  • rx實(shí)現(xiàn)：
//協(xié)議拓展
extension ReactiveCompatible {

    /// Reactive extensions. //提供給外界的屬性
    public static var rx: RxSwift.Reactive<Self>.Type

    /// Reactive extensions.
    public var rx: RxSwift.Reactive<Self>
}

/// A type that has reactive extensions. //ReactiveCompatible協(xié)議，實(shí)現(xiàn)此協(xié)議的類都會(huì)擁有rx屬性
public protocol ReactiveCompatible {
    /// Extended type
    associatedtype ReactiveBase //關(guān)聯(lián)類型

    @available(*, deprecated, message: "Use `ReactiveBase` instead.")
    typealias CompatibleType = ReactiveBase

    /// Reactive extensions. //rx的get和set方法被丧，協(xié)議屬性
    static var rx: Reactive<ReactiveBase>.Type { get set }

    /// Reactive extensions. //協(xié)議方法
    var rx: Reactive<ReactiveBase> { get set }
}

/// Extend NSObject with `rx` proxy. //協(xié)議實(shí)現(xiàn)盟戏，NSObject拓展實(shí)現(xiàn)協(xié)議
extension NSObject : ReactiveCompatible {
}
TextField

swift寫法

class ViewController: UIViewController, UITextFieldDelegate {

    override func viewDidLoad() {
        super.viewDidLoad()
        // Do any additional setup after loading the view.
        
        self.setupTextField()
    }

    func setupTextField() {
        self.textField.delegate = self
    }
    
    func textField(_ textField: UITextField, shouldChangeCharactersIn range: NSRange, replacementString string: String) -> Bool {
        print(string)
        return true
    }
}
/*
輸出結(jié)果：
p
o
i
u
y
*/

RxSwift寫法：

func setupTextField() {
        self.textField.rx.text.orEmpty
            .subscribe(onNext: { (text) in
                print(text)
            })
            .disposed(by: disposeBag)

//將textField輸入的值綁定到button的title
        self.textField.rx.text
        .bind(to: self.button.rx.title())
    }
/*
輸出結(jié)果：
p
po
poi
poiu
poiuy
*/
  • bind方法
/**
     Creates new subscription and sends elements to observer(s).
     In this form, it's equivalent to the `subscribe` method, but it better conveys intent, and enables
     writing more consistent binding code.
     - parameter to: Observers to receives events.
     - returns: Disposable object that can be used to unsubscribe the observers.
     */
    public func bind<Observer>(to observers: Observer...) -> Disposable where Observer : ObserverType, Self.Element == Observer.Element
  • title()方法
/// Reactive wrapper for `setTitle(_:for:)` //Binder將拿到的值賦值給button的title
    public func title(for controlState: UIControl.State = []) -> Binder<String?> {
        return Binder(self.base) { button, title -> Void in
            button.setTitle(title, for: controlState)
        }
    }
ScrollView

swift寫法：

class ViewController: UIViewController, UIScrollViewDelegate {
    func setupScrollView() {
        self.scrollView.delegate = self
    }
    
    func scrollViewDidScroll(_ scrollView: UIScrollView) {
        self.view.backgroundColor = UIColor.init(white: scrollView.contentOffset.y/60, alpha: 1.0)
    }
}

RxSwift寫法：

func setupScrollView() {
        self.scrollView.rx.contentOffset
            .subscribe(onNext: { [weak self](content) in
                self?.view.backgroundColor = UIColor.init(white: content.y/60, alpha: 1.0)
            })
            .disposed(by: disposeBag)
    }
gesture手勢

swift寫法：

func setupGesture() {
        let tap = UITapGestureRecognizer()
        self.label.isUserInteractionEnabled = true
        self.label.addGestureRecognizer(tap)
        
        tap.addTarget(self, action: #selector(tapLabel(_ :)))
    }
    
    @objc func tapLabel(_ gesture: UITapGestureRecognizer) {
        print(gesture.view)
    }

RxSwift寫法：

func setupGesture() {
        let tap = UITapGestureRecognizer()
        self.label.isUserInteractionEnabled = true
        self.label.addGestureRecognizer(tap)
        
        tap.rx.event.subscribe(onNext: { (tap) in
            print(tap.view)
        })
        .disposed(by: disposeBag)
    }
NotificationCenter通知，監(jiān)聽鍵盤避免遮擋輸入框

swift寫法：

func setupNotification() {
        NotificationCenter.default.addObserver(self,
                                               selector: #selector(keyboardWillShow(_ :)),
                                               name: UIResponder.keyboardWillShowNotification,
                                               object: nil)
        NotificationCenter.default.addObserver(self,
                                               selector: #selector(keyboardWillHide(_ :)),
                                               name: UIResponder.keyboardWillHideNotification,
                                               object: nil)
    }
    
    @objc func keyboardWillShow(_ notification: Notification) {
        DispatchQueue.main.async {
            
            let user_info = notification.userInfo
            let keyboardRect = (user_info?[UIResponder.keyboardFrameBeginUserInfoKey] as! NSValue).cgRectValue
            
            let y = keyboardRect.origin.y
            let y2 = (self.textField?.frame.origin.y)! + (self.textField?.frame.size.height)! + 5
            let offset_y = y2 > y ? (y2-y):(0)
            
            UIView.animate(withDuration: 0.25, animations: {
                self.view.center = CGPoint.init(x: self.view.center.x, y: self.view.center.y - offset_y)
            })
        }
    }
    
    @objc func keyboardWillHide(_ notification: Notification) {
        DispatchQueue.main.async {
            self.view.center = CGPoint.init(x: self.view.center.x, y: self.view.frame.height/2)
        }
    }
    deinit {
        NotificationCenter.default.removeObserver(self)
    }

RxSwift寫法：

func setupNotification() {
        NotificationCenter.default.rx
            .notification(UIResponder.keyboardWillShowNotification)
            .subscribe(onNext: { (noti) in
                print(noti)
            let user_info = noti.userInfo
            let keyboardRect = (user_info?[UIResponder.keyboardFrameBeginUserInfoKey] as! NSValue).cgRectValue
            
            let y = keyboardRect.origin.y
            let y2 = (self.textField?.frame.origin.y)! + (self.textField?.frame.size.height)! + 5
            let offset_y = y2 > y ? (y2-y):(0)
            
            UIView.animate(withDuration: 0.25, animations: {
                self.view.center = CGPoint.init(x: self.view.center.x, y: self.view.center.y - offset_y)
            })
        })
        .disposed(by: disposeBag)
        NotificationCenter.default.rx
            .notification(UIResponder.keyboardWillHideNotification)
            .subscribe(onNext: { (noti) in
                print(noti)
                self.view.center = CGPoint.init(x: self.view.center.x, y: self.view.frame.height/2)
            })
        .disposed(by: disposeBag)
    }
timer定時(shí)器

swift寫法：（scrollview滾動(dòng)時(shí)定時(shí)器會(huì)停止計(jì)時(shí)）

let timerT = Timer.init(timeInterval: 1, repeats: true) { (kTimer) in
            print(kTimer)
        }
        RunLoop.current.add(timerT, forMode: .default)
        timerT.fire()

RxSwift寫法：（scrollview滾動(dòng)事件不影響定時(shí)器計(jì)時(shí)甥桂，實(shí)際是根據(jù)interval發(fā)送響應(yīng)來執(zhí)行操作）

var timer: Observable<Int>!

func setupTimer() {
        timer = Observable<Int>.interval(1, scheduler: MainScheduler.instance)
        timer.subscribe(onNext: { (num) in
            print(num)
        })
        .disposed(by: disposeBag)
    }
  • interval實(shí)現(xiàn)
public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType)
        -> Observable<Element> {
        return Timer(
            dueTime: period,
            period: period,
            scheduler: scheduler
        )
    }
  • timer實(shí)現(xiàn)柿究，TimerSink()實(shí)現(xiàn)定時(shí)
final private class Timer<Element: RxAbstractInteger>: Producer<Element> {
    fileprivate let _scheduler: SchedulerType
    fileprivate let _dueTime: RxTimeInterval
    fileprivate let _period: RxTimeInterval?

    init(dueTime: RxTimeInterval, period: RxTimeInterval?, scheduler: SchedulerType) {
        self._scheduler = scheduler
        self._dueTime = dueTime
        self._period = period
    }

    override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
        if self._period != nil {
            let sink = TimerSink(parent: self, observer: observer, cancel: cancel)
            let subscription = sink.run()
            return (sink: sink, subscription: subscription)
        }
        else {
            let sink = TimerOneOffSink(parent: self, observer: observer, cancel: cancel)
            let subscription = sink.run()
            return (sink: sink, subscription: subscription)
        }
    }
}
  • TimerSink()實(shí)現(xiàn)，通過state的改變達(dá)到計(jì)時(shí)的目的
final private class TimerSink<Observer: ObserverType> : Sink<Observer> where Observer.Element : RxAbstractInteger  {
    typealias Parent = Timer<Observer.Element>

    private let _parent: Parent
    private let _lock = RecursiveLock()

    init(parent: Parent, observer: Observer, cancel: Cancelable) {
        self._parent = parent
        super.init(observer: observer, cancel: cancel)
    }

    func run() -> Disposable {
        return self._parent._scheduler.schedulePeriodic(0 as Observer.Element, startAfter: self._parent._dueTime, period: self._parent._period!) { state in
            self._lock.lock(); defer { self._lock.unlock() }
            self.forwardOn(.next(state))
            return state &+ 1
        }
    }
}
network網(wǎng)絡(luò)請求

swift寫法：

func setupNetwork() {
    let url = URL(string: "https://www.baidu.com")
        URLSession.shared.dataTask(with: url!) { (data, response, error) in
            print(String.init(data: data!, encoding: .utf8))
        }.resume()
}
/*
輸出結(jié)果：
Optional("<html>\r\n<head>\r\n\t<script>\r\n\t\tlocation.replace(location.href.replace(\"https://\",\"http://\"));\r\n\t</script>\r\n</head>\r\n<body>\r\n\t<noscript><meta http-equiv=\"refresh\" content=\"0;url=http://www.baidu.com/\"></noscript>\r\n</body>\r\n</html>")
*/

RxSwift寫法：

let url = URL(string: "https://www.baidu.com")
func setupNetwork() {
    URLSession.shared.rx.response(request: URLRequest(url: url!))
            .subscribe(onNext: { (response, data) in
                print(String.init(data: data, encoding: .utf8))
            })
            .disposed(by: disposeBag)
}
/*
輸出結(jié)果：
curl -X GET 
"https://www.baidu.com" -i -v
Success (1246ms): Status 200
Optional("<html>\r\n<head>\r\n\t<script>\r\n\t\tlocation.replace(location.href.replace(\"https://\",\"http://\"));\r\n\t</script>\r\n</head>\r\n<body>\r\n\t<noscript><meta http-equiv=\"refresh\" content=\"0;url=http://www.baidu.com/\"></noscript>\r\n</body>\r\n</html>")
*/
  • response實(shí)現(xiàn)：將request和dataTask放在函數(shù)里實(shí)現(xiàn)黄选，返回response蝇摸、data和error信息
public func response(request: URLRequest) -> Observable<(response: HTTPURLResponse, data: Data)> {
        return Observable.create { observer in

            // smart compiler should be able to optimize this out
            let d: Date?

            if Logging.URLRequests(request) {
                d = Date()
            }
            else {
               d = nil
            }

            let task = self.base.dataTask(with: request) { data, response, error in

                if Logging.URLRequests(request) {
                    let interval = Date().timeIntervalSince(d ?? Date())
                    print(convertURLRequestToCurlCommand(request))
                    #if os(Linux)
                        print(convertResponseToString(response, error.flatMap { $0 as NSError }, interval))
                    #else
                        print(convertResponseToString(response, error.map { $0 as NSError }, interval))
                    #endif
                }
                
                guard let response = response, let data = data else {
                    observer.on(.error(error ?? RxCocoaURLError.unknown))
                    return
                }

                guard let httpResponse = response as? HTTPURLResponse else {
                    observer.on(.error(RxCocoaURLError.nonHTTPResponse(response: response)))
                    return
                }

                observer.on(.next((httpResponse, data)))
                observer.on(.completed)
            }

            task.resume()

            return Disposables.create(with: task.cancel)
        }
    }

參考鏈接：
Swift監(jiān)聽鍵盤通知以及做出一些處理
55 - Swift 之 Timer (NSTimer )定時(shí)器

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市办陷，隨后出現(xiàn)的幾起案子貌夕，更是在濱河造成了極大的恐慌，老刑警劉巖懂诗，帶你破解...
    沈念sama閱讀 217,185評(píng)論 6贊 503
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件蜂嗽，死亡現(xiàn)場離奇詭異，居然都是意外死亡殃恒，警方通過查閱死者的電腦和手機(jī)植旧，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,652評(píng)論 3贊 393
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門辱揭，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人病附，你說我怎么就攤上這事问窃。” “怎么了完沪？”我有些...
    開封第一講書人閱讀 163,524評(píng)論 0贊 353
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵域庇，是天一觀的道長。 經(jīng)常有香客問我覆积，道長听皿，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 58,339評(píng)論 1贊 293
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任宽档，我火速辦了婚禮尉姨，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘吗冤。我一直安慰自己又厉，他們只是感情好，可當(dāng)我...
    茶點(diǎn)故事閱讀 67,387評(píng)論 6贊 391
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布椎瘟。 她就那樣靜靜地躺著覆致，像睡著了一般。 火紅的嫁衣襯著肌膚如雪肺蔚。 梳的紋絲不亂的頭發(fā)上煌妈，一...
    開封第一講書人閱讀 51,287評(píng)論 1贊 301
  • 城市分裂傳說
    那天，我揣著相機(jī)與錄音婆排，去河邊找鬼声旺。 笑死，一個(gè)胖子當(dāng)著我的面吹牛段只，可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播鉴扫，決...
    沈念sama閱讀 40,130評(píng)論 3贊 418
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼赞枕，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了坪创？” 一聲冷哼從身側(cè)響起炕婶，我...
    開封第一講書人閱讀 38,985評(píng)論 0贊 275
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對(duì)情侶失蹤，失蹤者是張志新（化名）和其女友劉穎莱预，沒想到半個(gè)月后柠掂，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體，經(jīng)...
    沈念sama閱讀 45,420評(píng)論 1贊 313
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡依沮，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,617評(píng)論 3贊 334
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年涯贞，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了枪狂。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,779評(píng)論 1贊 348
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡宋渔，死狀恐怖州疾，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情皇拣，我是刑警寧澤严蓖，帶...
    沈念sama閱讀 35,477評(píng)論 5贊 345
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布，位于F島的核電站氧急，受9級(jí)特大地震影響颗胡，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜吩坝，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,088評(píng)論 3贊 328
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一毒姨、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧钾恢，春花似錦手素、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,716評(píng)論 0贊 22
  • 一樁弒父案泉懦，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至疹瘦，卻和暖如春崩哩，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背言沐。 一陣腳步聲響...
    開封第一講書人閱讀 32,857評(píng)論 1贊 269
  • 情欲美人皮
    我被黑心中介騙來泰國打工邓嘹， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人险胰。 一個(gè)月前我還...
    沈念sama閱讀 47,876評(píng)論 2贊 370
  • 代替公主和親
    正文 我出身青樓汹押，卻偏偏與公主長得像，于是被迫代替她去往敵國和親起便。 傳聞我的和親對(duì)象是個(gè)殘疾皇子棚贾，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,700評(píng)論 2贊 354