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

初识RxSwift初识RxSwift

2023-09-03 169
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 初识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
目录
相关文章
音视频牛哥
|
设计模式 安全
如何用C++11实现观察者模式
观察者模式是一种设计模式，定义了对象之间的一对多关系。当一个对象状态发生改变时，它的依赖者都会收到通知并自动更新。在C++11中，可以通过以下方式实现观察者模式：
音视频牛哥
108 0
土木林森
|
9月前
|
安全 Swift iOS开发
【Swift开发专栏】Swift中的属性观察者与KVO
【4月更文挑战第30天】Swift编程语言支持属性观察者（`willSet`和`didSet`）和键值观察（KVO）来响应属性变化。属性观察者在设置前（`willSet`）和设置后（`didSet`）执行代码，可用于数据绑定。KVO是Cocoa/Cocoa Touch中的机制，需`NSObject`子类和`@objc dynamic`属性配合使用。注意在观察者销毁前移除观察，以避免内存问题。示例展示了属性观察者实现简单数据绑定。
土木林森
133 1
cy6s2s5ao5drg
|
前端开发
RxSwift-双向绑定
RxSwift-双向绑定
cy6s2s5ao5drg
317 0
创业之路＆下一个五年
|
设计模式 测试技术
【坦克大战一】——简单实现小结
小时候对于游戏的痴迷让我对于游戏有一种心底的渴望，然而随着时间的推移阅历、经历的增加以及现在从事的编程行业似乎和游戏越来越远；在工作中对技术的要求以及未来技术的分量加上一次偶然的机会重新燃起我对游戏的渴望，不过这次的游戏并不仅仅是痴迷，而是让自己拥有一颗归零的心态在游戏编程的角度去学习那些基础的知识。
创业之路＆下一个五年
100 0
游客cflknejh75ig6
|
设计模式
大话设计模式行为型总结导图
大话设计模式行为型总结导图
游客cflknejh75ig6
68 0
1730617107579634
|
API
探秘 RxJS Observable 为什么要长成这个样子？！
我们都知道 RxJS Observable 最基础的使用方法：是建立 Observable，即调用 .create API
1730617107579634
98 0
Yj家的孺子牛
|
Android开发 索引
EventBus封装到项目架构|青训营笔记
封装该库到自己的项目的目的有两个 便捷绑定和解绑 EventBus 便捷通过 EventBus 发送消息和处理消息 代码美观
Yj家的孺子牛
170 0
EventBus封装到项目架构|青训营笔记
huhansome
|
缓存 监控 Swift
函数式编程框架 ReactiveCocoa 基础入门
函数式编程框架 ReactiveCocoa 基础入门
huhansome
156 0
huhansome
|
缓存 前端开发 API
ReactiveCocoa 进阶，轻松搞定函数式编程框架
函数式编程已经变得越来越流行，而且也有很大的优势，作为iOS开发者，函数式编程框架**ReactiveCocoa**到底怎么使用呢, 接下来我们来深入介绍**ReactiveCocoa**及其在**MVVM**中的用法。
huhansome
209 0
诸葛小愚
|
JavaScript
手写代码：实现一个EventBus
EventBus，事件总线。总线一词来自于《计算机组成原理》中的”系统总线“，是指用于连接多个部件的信息传输线，各部件共享的传输介质。我们通常把事件总线也成为自定义事件，一般包含`on`、`once`、`emit`、`off`等方法。在Vue2中想要实现EventBus比较简单，直接暴露出一个`new Vue()`实例即可，以此为思路，我们应该如何自定义实现EventBus呢?
诸葛小愚
546 0
手写代码：实现一个EventBus

热门文章

最新文章

  • 1
    讨论阶段性给予客户交付物所引发的风险问题
  • 2
    finally关键字小复习
  • 3
    静态变量和成员变量的区别 && 成员变量和局部变量的区别
  • 4
    我的博客即将入驻“云栖社区”，诚邀技术同仁一同入驻。
  • 5
    js获取 日期 星期 时间
  • 6
    Javascript事件集
  • 7
    Ruby中求50之内的素数方法
  • 8
    Unity应用架构设计(3)——构建View和ViewModel的生命周期
  • 9
    北大资源重磅来宜--宜昌未来商业中心将诞生
  • 10
    【android基础】Android中四大组件
  • 1
    Step-Video-T2V：碾压Sora？国产开源巨兽Step-Video-T2V杀到：300亿参数一键生成204帧视频
    62
  • 2
    Unsloth：学生党福音！开源神器让大模型训练提速10倍：单GPU跑Llama3，5小时变30分钟
    89
  • 3
    X-R1：3090也能训7B模型！开源框架X-R1把训练成本打下来了：10美元训出企业级LLM
    39
  • 4
    Cline：29.7K Star！一文详解VSCode最强开源AI编程搭子：一键生成代码+自动跑终端+操控浏览器...
    63
  • 5
    【01】噩梦终结flutter配安卓android鸿蒙harmonyOS 以及next调试环境配鸿蒙和ios真机调试环境-flutter项目安卓环境配置-gradle-agp-ndkVersion模拟器运行真机测试环境-本地环境搭建-如何快速搭建android本地运行环境-优雅草卓伊凡-很多人在这步就被难倒了
    14
  • 6
    新一代 Cron-Job 分布式任务调度平台 正式发布！
    35
  • 7
    菜鸟之路Day15一一IO流（一）
    19
  • 8
    《通义灵码2.0体验感受》
    32
  • 9
    分库分表—2.详细介绍一
    15
  • 10
    Dataphin离线数据开发规范
    24

    • 相关课程

    更多
  • Java面向对象开发
  • 5天玩转Java面向对象编程
  • Java面向对象编程

    • 相关电子书

    更多
  • 用RxSwift写易维护易读的愉悦代码
  • Android组件化实现
  • 为什么要学函数式编程？
    • 下一篇
    阿里云oss简介和如何对接使用