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

初识RxSwift初识RxSwift

2023-09-03 326
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 初识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
目录
相关文章
众所周知
|
存储 iOS开发
iOS 开发，如何进行应用的本地化（Localization）？
iOS 开发，如何进行应用的本地化（Localization）？
众所周知
403 2
Martin6
|
3月前
Vite使用svg-企业级开发(支持本地svg和网络svg渲染)
本教程介绍如何在Vite项目中集成SVG图标插件。首先安装`vite-plugin-svg-icons`，配置插件指向SVG图标目录，并注册全局组件。接着创建SVG图标组件，支持内部图标与外部图片展示。通过简单配置，即可在页面中灵活使用各类SVG图标，提升开发效率。
Martin6
198 0
sunyalei
|
8月前
|
开发工具 Android开发 iOS开发
flutter 环境配置
flutter 环境配置
sunyalei
1479 63
阿里云开发者
|
7月前
|
人工智能 分布式计算 大数据
MCP、MaxFrame与大数据技术全景解析
本文介绍了 MCP 协议、MaxFrame 分布式计算框架以及大数据基础设施建设的相关内容。MCP（Model Context Protocol）是一种开源协议，旨在解决 AI 大模型与外部数据源及工具的集成问题，被比喻为大模型的“USB 接口”，通过统一交互方式降低开发复杂度。其核心架构包括 Client、Server、Tool 和 Schema 四个关键概念，并在百炼平台中得到实践应用。MaxFrame 是基于 Python 的高性能分布式计算引擎，支持多模态数据处理与 AI 集成，结合 MaxCompute 提供端到端的数据处理能力。
阿里云开发者
596 5
WhatsXie
|
Web App开发 前端开发 Android开发
iOS 唤起 APP: Universal Link(通用链接)（下）
iOS 唤起 APP: Universal Link(通用链接)（下）
WhatsXie
1807 0
iOS 唤起 APP: Universal Link(通用链接)（下）
岭南it阁
|
项目管理 Python
如何在Mac上安装多个Python环境
在你的Mac上使用多个Python环境可以对项目管理很有帮助，特别是在同时处理不同Python版本或不同的包需求时。在这篇文章中，我们将向你展示如何在Mac上轻松地安装和管理多个Python环境。
岭南it阁
422 5
如何在Mac上安装多个Python环境
砖业洋__
|
XML Java 数据格式
Spring高手之路18——从XML配置角度理解Spring AOP
本文是全面解析面向切面编程的实践指南。通过深入讲解切面、连接点、通知等关键概念，以及通过XML配置实现Spring AOP的步骤。
砖业洋__
347 6
Spring高手之路18——从XML配置角度理解Spring AOP
cy6s2s5ao5drg
|
存储 Swift
RxSwift+MVVM项目实战-多分组UITableView结合RxDataSources的使用
RxSwift+MVVM项目实战-多分组UITableView结合RxDataSources的使用
cy6s2s5ao5drg
671 0
郏国上
|
编解码 图计算 iOS开发
iPhone手机屏幕尺寸与倍图计算公式（更新至iPhone 14 Plus）
iPhone手机屏幕尺寸与倍图计算公式（更新至iPhone 14 Plus）
郏国上
892 0
sunrr
|
前端开发 开发者
在HTML中，可以使用字符实体`&copy;`来显示版权符号
【4月更文挑战第30天】在HTML中，可以使用字符实体`&copy;`来显示版权符号
sunrr
2656 2

热门文章

最新文章

  • 1
    sudo apt-get update提示E: 仓库 “http://mirrors.aliyun.com/ubuntu eoan Release” 没有 Release 文件。亲试解决办法
  • 2
    Apache Flink 的迁移之路，2 年处理效果提升 5 倍
  • 3
    kettle用命令行执行ktr和kjb
  • 4
    阿里云商标优选官网入口链接地址（明码标价）
  • 5
    Mysql5.7安装超详细教学
  • 6
    docker pull 相关配置
  • 7
    ? error: cannot open C:\Users???\AppData\Local\Temp\main.obj.5136.0.jom for write
  • 8
    adpatch options=hotpatch 适用于大小小于1M 的小补丁，不适合大补丁
  • 9
    Current Analysis：安全和价值是物联网最大障碍
  • 10
    CentOS虚拟机如何设置共享文件夹，并在Windows下映射网络驱动器？
  • 1
    Coze vs Dify vs n8n：三大AI智能体开发平台全面对比
    106
  • 2
    2025年开源AI知识库深度体验：PandaWiki重新定义企业知识管理
    91
  • 3
    Oracle 数据塑形：行列转换与集合运算
    44
  • 4
    构建AI智能体：五十三、反应式应急+深思式优化：反应速度与规划智慧的平衡
    68
  • 5
    云时代的身份安全：别再靠“密码123456”扛风险了
    61
  • 6
    别再把 Collector 当黑箱：OpenTelemetry Collector 拓展与自定义处理器实战指南
    59
  • 7
    为什么企业离不开元数据管理？——因为数据混乱，比加班更可怕！
    36
  • 8
    《游戏公会系统激活活跃度与筑牢归属感的实战指南》
    55
  • 9
    《新手零抵触的教学引导设计指南》
    37
  • 10
    阿里云搭建网站收费标准:自建网站、云小智AI建站和云企业官网价格更新
    53

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    阿里云服务器快照备份数据怎么下载到本地保存？