RxSwift的介绍与使用
目录
- 一、RxSwift 简介
- 二、核心概念
- 三、基础使用示例
- 3.1、创建 Observable & 订阅事件
- 3.2、操作符链式调用
- 3.3、绑定 UI 控件 (RxCocoa)
- 3.4、网络请求 + 线程切换
- 3.5、组合多个请求 (flatMapLatest)
- 核心操作符速查
- 四、安装方式
- 五、适用场景
一、RxSwift 简介
RxSwift 是 Swift 语言的响应式编程框架，基于 ReactiveX（Reactive Extensions） 标准实现。它通过 观察者模式 和 函数式编程 思想，简化异步事件处理和数据流管理，特别适合处理 UI 事件、网络请求、数据绑定等场景。
二、核心概念
- Observable：数据源/事件流（被观察者）
- Observer：订阅者（观察者）
- Operator：操作符（转换/过滤/组合数据流）
- Scheduler：线程调度器（管理操作执行线程）
- Disposable：资源管理（取消订阅）
三、基础使用示例
3.1、创建 Observable & 订阅事件
import RxSwiftlet disposeBag = DisposeBag()// 创建 Observable
let stringObservable = Observable.just("Hello RxSwift!")
let numbersObservable = Observable.of(1, 2, 3)// 订阅事件
stringObservable.subscribe(onNext: { print($0) },onError: { print("Error: \($0)") },onCompleted: { print("Completed") }).disposed(by: disposeBag)/* 输出：
Hello RxSwift!
Completed
*/
3.2、操作符链式调用
Observable.of(1, 2, 3, 4, 5).filter { $0 % 2 == 0 } // 过滤偶数.map { $0 * 10 } // 乘以10.subscribe(onNext: { print($0) }).disposed(by: disposeBag)/* 输出：
20
40
*/
3.3、绑定 UI 控件 (RxCocoa)
import RxSwift
import RxCocoaclass ViewController: UIViewController {@IBOutlet weak var textField: UITextField!@IBOutlet weak var label: UILabel!let disposeBag = DisposeBag()override func viewDidLoad() {super.viewDidLoad()// 实时显示文本框内容（忽略空值）textField.rx.text.compactMap { $0 } // 解包非空值.filter { !$0.isEmpty }.bind(to: label.rx.text).disposed(by: disposeBag)}
}
3.4、网络请求 + 线程切换
func fetchUser() -> Observable<User> {return Observable.create { observer inlet task = URLSession.shared.dataTask(with: URL(string: "https://api.example.com/user")!) { data, _, error inif let error = error {observer.onError(error)} else if let data = data {let user = try? JSONDecoder().decode(User.self, from: data)observer.onNext(user!)observer.onCompleted()}}task.resume()return Disposables.create { task.cancel() }}
}// 使用示例
fetchUser().subscribe(on: ConcurrentDispatchQueueScheduler(qos: .background)) // 后台线程请求.observe(on: MainScheduler.instance) // 主线程更新UI.subscribe(onNext: { user inprint("用户名: \(user.name)")},onError: { print("请求失败: \($0)") }).disposed(by: disposeBag)
3.5、组合多个请求 (flatMapLatest)
// 先登录 → 再获取用户信息
func login(username: String, password: String) -> Observable<String> {// 返回token的Observable
}func fetchProfile(token: String) -> Observable<UserProfile> {// 使用token获取用户信息
}login(username: "user", password: "pass").flatMapLatest { token infetchProfile(token: token) // 使用token获取用户信息}.subscribe(onNext: { profile inprint("用户邮箱: \(profile.email)")}).disposed(by: disposeBag)
核心操作符速查
| 操作符 | 作用 |
|---|---|
map | 数据转换 |
filter | 条件过滤 |
flatMap | 扁平化嵌套Observable |
debounce | 防抖动（搜索框场景） |
combineLatest | 合并最新值 |
merge | 合并多个流 |
retry | 失败自动重试 |
四、安装方式
在 Podfile 中添加：
pod 'RxSwift', '~> 6.5'
pod 'RxCocoa', '~> 6.5' # UI扩展
或使用 Swift Package Manager：
dependencies: [.package(url: "https://github.com/ReactiveX/RxSwift.git", .upToNextMajor(from: "6.0.0"))
]
五、适用场景
- 实时搜索（
debounce+flatMapLatest） - 表单验证（
combineLatest多个输入） - 复杂异步依赖操作
- 多数据源绑定同一UI
- 状态管理（替代部分Delegate模式）
提示：RxSwift 学习曲线较陡，建议从简单场景逐步实践，配合 RxMarbles 可视化工具理解操作符行为。