AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

初识RxSwift初识RxSwift

2023-09-03 159
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 初识RxSwift

1. 函数式编程（Functional Programming，简称FP）

主要思想是把函数看做是“第一等公民”，函数与其他数据类型一样，可以赋值给其他变量，也可以作为函数的参数，以及函数的返回值，类似于下面这样

func sum(_ a: Int, _ b: Int) -> Int { a + b }
func sub(_ a: Int, _ b: Int) -> Int { a - b }
print(sum(sub(20, 10), sub(40, 20)))//10 + 20 = 30

2. 响应式编程（Rective Programming，简称RP）

主要是为了简化异步编程，提供一种更优雅的数据绑定，一般与函数式结合在一起，所以也会叫做函数响应式编程（Functional Rective Programming，简称FRP）

有人这样理解函数响应式编程，比如c = a + b，变量c为变量a与变量b的和，当执行完这条语句之后，当我们再次改变变量a或者变量b的值的时候，c不会变化，而函数响应式编程就是为了实现当变量a或变量b变化的时候，变量c也跟着变化的。


3. 响应式编程框架

ReactiveCocoa（RAC）：有OC和Swift两个版本

ReactiveX：有很多语言的版本，比如RxJava，RxJS，RxPHP，RXSwift，RxKotlin等，其中RxSwift（RectiveX for Swift），为RectiveX的Swift版本；

RxSwift：RectiveX标准API的Swift实现，不包括iOS相关的任何内容

RxCocoa：基于RxSwift，给iOS的UI控件扩展了很多Rx特性


4. RxSwift常用事件回调

iOS中的回调方式有非常多的种类，UIKit主要进行的事件处理Target-Action、delegate、Block、NotifcationCenter、KVO监听。而原生开发中，触发对象与响应方法是分离的，如UIButton的初始化和点击响应方法是分离的。RxSwift恰好能以统一的形式来解决跨类调用的问题，也包装了UIKit事件处理、NotifcationCenter、KVO等常见的场景，让代码整合的更加统一。


01. 按钮点击 

let button = UIButton(type: .custom)
button.frame = CGRect(x: 100, y: 100, width: 100, height: 100)
button.backgroundColor = .red
view.addSubview(button)
button.rx.tap.subscribe(onNext: {
    print("button click")
}).disposed(by: disposeBag)
let button = UIButton(type: .custom)
button.frame = CGRect(x: 100, y: 100, width: 100, height: 100)
button.backgroundColor = .red
view.addSubview(button)
button.rx.tap.subscribe(onNext: {
    print("button click")
}).disposed(by: disposeBag)


02. 手势 

let tap = UITapGestureRecognizer()
view.addGestureRecognizer(tap)
tap.rx.event.subscribe {
    print("gesture click ", $0)
}.disposed(by: disposeBag)
let tap = UITapGestureRecognizer()
view.addGestureRecognizer(tap)
tap.rx.event.subscribe {
    print("gesture click ", $0)
}.disposed(by: disposeBag)


03. 文本输入监听

let textField = UITextField(frame: CGRect(x: 200, y: 100, width: 101, height: 100))
textField.borderStyle = .line
view.addSubview(textField)
textField.rx.text.orEmpty.changed.throttle(.milliseconds(100), scheduler: MainScheduler.instance).subscribe { (text) in
    print(text)
}.disposed(by: disposeBag)
let textField = UITextField(frame: CGRect(x: 200, y: 100, width: 101, height: 100))
textField.borderStyle = .line
view.addSubview(textField)
textField.rx.text.orEmpty.changed.throttle(.milliseconds(100), scheduler: MainScheduler.instance).subscribe { (text) in
    print(text)
}.disposed(by: disposeBag)


04. 代理监听


view.addSubview(scrollView)
scrollView.rx.didScroll.subscribe {[weak scrollView] _ in
    print("开始滚动了 - ", scrollView?.contentOffset.y ?? 0)
}.disposed(by: disposeBag)
scrollView.rx.contentOffset.subscribe {
    print("contentOffset - ", $0.y)
}.disposed(by: disposeBag)
view.addSubview(scrollView)
scrollView.rx.didScroll.subscribe {[weak scrollView] _ in
    print("开始滚动了 - ", scrollView?.contentOffset.y ?? 0)
}.disposed(by: disposeBag)
scrollView.rx.contentOffset.subscribe {
    print("contentOffset - ", $0.y)
}.disposed(by: disposeBag)


05. KVO 

scrollView.rx.observeWeakly(CGPoint.self, "contentOffset").subscribe { (value) in
    print("kvo - contentOffset - ", value)
}.disposed(by: disposeBag)
scrollView.rx.observeWeakly(CGPoint.self, "contentOffset").subscribe { (value) in
    print("kvo - contentOffset - ", value)
}.disposed(by: disposeBag)


06. 通知

NotificationCenter.default.rx.notification(UIApplication.willEnterForegroundNotification).subscribe { (_) in
    print("进入前台")
}.disposed(by: disposeBag)
NotificationCenter.default.rx.notification(UIApplication.didEnterBackgroundNotification).subscribe { (_) in
    print("进入后台")
}.disposed(by: disposeBag)


07. 网络回调

URLSession.shared.rx.response(request: URLRequest(url: URL(string: "https://www.baidu.com")!)).subscribe { (resp, data) in
    print("响应结果code ->", resp.statusCode, "data.count ->", data.count)
}.disposed(by: disposeBag)


08. 定时器

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance).subscribe(onNext: { (res) in
    print(res)
}).disposed(by: disposeBag)
Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance).subscribe(onNext: { (res) in
    print(res)
}).disposed(by: disposeBag)

还有更多控件的使用监听回调，如UITextView、UITableView、UISegmentedControl、UISearchBar等UI控件均可监听，具体可查看RxSwift、RxCocoa源码。

1. 函数式编程（Functional Programming，简称FP）

主要思想是把函数看做是“第一等公民”，函数与其他数据类型一样，可以赋值给其他变量，也可以作为函数的参数，以及函数的返回值，类似于下面这样


func sum(_ a: Int, _ b: Int) -> Int { a + b }
func sub(_ a: Int, _ b: Int) -> Int { a - b }
print(sum(sub(20, 10), sub(40, 20)))//10 + 20 = 30
func sum(_ a: Int, _ b: Int) -> Int { a + b }
func sub(_ a: Int, _ b: Int) -> Int { a - b }
print(sum(sub(20, 10), sub(40, 20)))//10 + 20 = 30

2. 响应式编程（Rective Programming，简称RP）

主要是为了简化异步编程，提供一种更优雅的数据绑定，一般与函数式结合在一起，所以也会叫做函数响应式编程（Functional Rective Programming，简称FRP）

有人这样理解函数响应式编程，比如c = a + b，变量c为变量a与变量b的和，当执行完这条语句之后，当我们再次改变变量a或者变量b的值的时候，c不会变化，而函数响应式编程就是为了实现当变量a或变量b变化的时候，变量c也跟着变化的。


3. 响应式编程框架

ReactiveCocoa（RAC）：有OC和Swift两个版本

ReactiveX：有很多语言的版本，比如RxJava，RxJS，RxPHP，RXSwift，RxKotlin等，其中RxSwift（RectiveX for Swift），为RectiveX的Swift版本；

RxSwift：RectiveX标准API的Swift实现，不包括iOS相关的任何内容

RxCocoa：基于RxSwift，给iOS的UI控件扩展了很多Rx特性


4. RxSwift常用事件回调

iOS中的回调方式有非常多的种类，UIKit主要进行的事件处理Target-Action、delegate、Block、NotifcationCenter、KVO监听。而原生开发中，触发对象与响应方法是分离的，如UIButton的初始化和点击响应方法是分离的。RxSwift恰好能以统一的形式来解决跨类调用的问题，也包装了UIKit事件处理、NotifcationCenter、KVO等常见的场景，让代码整合的更加统一。


01. 按钮点击

let button = UIButton(type: .custom)
button.frame = CGRect(x: 100, y: 100, width: 100, height: 100)
button.backgroundColor = .red
view.addSubview(button)
button.rx.tap.subscribe(onNext: {
    print("button click")
}).disposed(by: disposeBag)


02. 手势 

let tap = UITapGestureRecognizer()
view.addGestureRecognizer(tap)
tap.rx.event.subscribe {
    print("gesture click ", $0)
}.disposed(by: disposeBag)
let tap = UITapGestureRecognizer()
view.addGestureRecognizer(tap)
tap.rx.event.subscribe {
    print("gesture click ", $0)
}.disposed(by: disposeBag)


03. 文本输入监听

let textField = UITextField(frame: CGRect(x: 200, y: 100, width: 101, height: 100))
textField.borderStyle = .line
view.addSubview(textField)
textField.rx.text.orEmpty.changed.throttle(.milliseconds(100), scheduler: MainScheduler.instance).subscribe { (text) in
    print(text)
}.disposed(by: disposeBag)
let textField = UITextField(frame: CGRect(x: 200, y: 100, width: 101, height: 100))
textField.borderStyle = .line
view.addSubview(textField)
textField.rx.text.orEmpty.changed.throttle(.milliseconds(100), scheduler: MainScheduler.instance).subscribe { (text) in
    print(text)
}.disposed(by: disposeBag)


04. 代理监听

view.addSubview(scrollView)
scrollView.rx.didScroll.subscribe {[weak scrollView] _ in
    print("开始滚动了 - ", scrollView?.contentOffset.y ?? 0)
}.disposed(by: disposeBag)
scrollView.rx.contentOffset.subscribe {
    print("contentOffset - ", $0.y)
}.disposed(by: disposeBag)


05. KVO

scrollView.rx.observeWeakly(CGPoint.self, "contentOffset").subscribe { (value) in
    print("kvo - contentOffset - ", value)
}.disposed(by: disposeBag)


06. 通知

NotificationCenter.default.rx.notification(UIApplication.willEnterForegroundNotification).subscribe { (_) in
    print("进入前台")
}.disposed(by: disposeBag)
NotificationCenter.default.rx.notification(UIApplication.didEnterBackgroundNotification).subscribe { (_) in
    print("进入后台")
}.disposed(by: disposeBag)


07. 网络回调 

URLSession.shared.rx.response(request: URLRequest(url: URL(string: "https://www.baidu.com")!)).subscribe { (resp, data) in
    print("响应结果code ->", resp.statusCode, "data.count ->", data.count)
}.disposed(by: disposeBag)
URLSession.shared.rx.response(request: URLRequest(url: URL(string: "https://www.baidu.com")!)).subscribe { (resp, data) in
    print("响应结果code ->", resp.statusCode, "data.count ->", data.count)
}.disposed(by: disposeBag)


08. 定时器

Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance).subscribe(onNext: { (res) in
    print(res)
}).disposed(by: disposeBag)

还有更多控件的使用监听回调，如UITextView、UITableView、UISegmentedControl、UISearchBar等UI控件均可监听，具体可查看RxSwift、RxCocoa源码。

文章标签：
Swift
iOS开发
API
cy6s2s5ao5drg
目录
相关文章
cy6s2s5ao5drg
|
存储 Swift
RxSwift+MVVM项目实战-多分组UITableView结合RxDataSources的使用
RxSwift+MVVM项目实战-多分组UITableView结合RxDataSources的使用
cy6s2s5ao5drg
349 0
cy6s2s5ao5drg
RxSwift+MVVM项目实战-单分组UITableView的使用
RxSwift+MVVM项目实战-单分组UITableView的使用
cy6s2s5ao5drg
260 0
cy6s2s5ao5drg
RxSwift+MVVM项目实战-多分组UITableView+RxDataSources+MJRefresh的使用
RxSwift+MVVM项目实战-多分组UITableView+RxDataSources+MJRefresh的使用
cy6s2s5ao5drg
154 0
cy6s2s5ao5drg
|
JSON HandyJSON Swift
RxSwift+MVVM项目实战-多分组TableView+MJRefresh+RxAlamofire+HandyJSON的使用
RxSwift+MVVM项目实战-多分组TableView+MJRefresh+RxAlamofire+HandyJSON的使用
cy6s2s5ao5drg
342 0
cy6s2s5ao5drg
|
前端开发
RxSwift-双向绑定
RxSwift-双向绑定
cy6s2s5ao5drg
308 0
汤姆z
|
设计模式 消息中间件 安全
2023-7-13-第十八式观察者模式
2023-7-13-第十八式观察者模式
汤姆z
85 0
卡布学安卓
|
Android开发
Livedata用的爽吗，StateFlow你也应该了解一下
Livedata用的爽吗，StateFlow你也应该了解一下
卡布学安卓
770 0
Livedata用的爽吗，StateFlow你也应该了解一下
瓜子三百克
|
Android开发 iOS开发
iOS开发：KVC与KVO
KVC 就是键值编码（key-value-coding)，可以直接访问对象的属性，或者给对象的属性赋值。黑魔法之一，很多高级的iOS开发技巧都是基于KVC实现的。 KVO 是键值观察者（key-value-observing）。实现方式：通过对某个对象的某个属性添加观察者，当该属性改变，就会调用”observeValueForKeyPath:”方法，为我们提供一个“对象值改变了！”的时机进行一些操作。
瓜子三百克
249 0
iOS开发：KVC与KVO
游客k7ja6kkd3nere
|
Android开发 容器
事件分发四部曲之一《深度遍历讲解Android事件分发机制》
事件分发四部曲之一《深度遍历讲解Android事件分发机制》
游客k7ja6kkd3nere
334 0
事件分发四部曲之一《深度遍历讲解Android事件分发机制》
咖啡机（K.F.J）
|
监控 iOS开发
IOS开发－KVO
观察者，观察对象属性的变化，当被观察者该属性发生变化时，观察者会接收到通知，可以在回调函数中做相应的处理
咖啡机（K.F.J）
125 0

热门文章

最新文章

  • 1
    四大触点，教你从“用户视角”构建数据分析体系
  • 2
    《Stata统计分析与应用（第2版）》一3.4 图形的保存、合并及修改
  • 3
    Spring-boot+Dubbo应用启停源码分析
  • 4
    分享一些OpenStack的qcow2格式实例镜像
  • 5
    基于区块链的机器学习模型创建方案
  • 6
    微信web开发者工具无法打开的六种解决方法
  • 7
    RocketMq-Request-Reply消息
  • 8
    [译] 构建世界上最快的会议网站
  • 9
    " "(双引号)与 ' '(单引号)的区别
  • 10
    自定义高效支持点击监听的RecyclerView
  • 1
    AI在电子商务中的个性化推荐系统：驱动用户体验升级
    31
  • 2
    基于AI的网络流量分析：构建智能化运维体系
    27
  • 3
    鸿蒙登录页面好看的样式设计-HarmonyOS应用开发实战与ArkTS代码解析【HarmonyOS 5.0（Next）】
    25
  • 4
    HarmonyOS 5.0 （Next）应用开发实战：使用ArkTS构建开箱即用的登录页面【HarmonyOS 5.0（Next）】
    30
  • 5
    开箱即用的个人主页页面开发实战—基于HarmonyOS 5.0 （Next）和ArkTS的实现【HarmonyOS 5.0（Next）】
    34
  • 6
    《Java 在 3D 视觉与重建领域：开启无限可能之旅》
    22
  • 7
    《Java 情感分析：前沿技术与方法全解析》
    27
  • 8
    《GraalVM：Java AI 应用性能与启动速度的优化利器》
    22
  • 9
    《探索 Apache Spark MLlib 与 Java 结合的卓越之道》
    19
  • 10
    云产品评测
    21

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    【案例实战】SpringBoot整合阿里云文件上传OSS