这里所说的通知不是指发给用户看的通知消息，而是系统内部进行消息传递的通知。我在之前也写过一篇文章介绍如何使用 NotificationCenter 来发送、接收通知（点击查看）。
其实 RxSwift 也对 NotificationCenter 进行了扩展，使用起来变得十分简洁，下面通过样例进行演示。
一、系统通知的注册与响应
1，监听应用进入后台的通知
（1）效果图
程序编译运行后，当按下设备的 home 键，程序进入后台的同时会在控制台中输出相关信息。
（2）样例代码
程序进入后台时除了会执行 AppDelegate.swift 里的 applicationDidEnterBackground 方法外，还会发送 UIApplicationDidEnterBackground 通知，这里我们使用 NotificationCenter 的 Rx 扩展方法来监听这个通知。
关于 .takeUntil(self.rx.deallocated)：
它的作用是保证页面销毁的时候自动移除通知注册，避免内存浪费或奔溃。
import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {
let disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
// 监听应用进入后台通知
_ = NotificationCenter.default.rx
.notification(NSNotification.Name.UIApplicationDidEnterBackground)
.takeUntil(self.rx.deallocated) //页面销毁自动移除通知监听
.subscribe(onNext: { _ in
print("程序进入到后台了")
})
}
}
2，监听键盘的通知
（1）效果图
我们分别监听虚拟键盘的打开和关闭通知，并在控制台中输出相关信息。
（2）样例代码
import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {
let disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
//添加文本输入框
let textField = UITextField(frame: CGRect(x:20, y:100, width:200, height:30))
textField.borderStyle = UITextBorderStyle.roundedRect
textField.returnKeyType = .done
self.view.addSubview(textField)
//点击键盘上的完成按钮后，收起键盘
textField.rx.controlEvent(.editingDidEndOnExit)
.subscribe(onNext: { _ in
//收起键盘
textField.resignFirstResponder()
})
.disposed(by: disposeBag)
//监听键盘弹出通知
_ = NotificationCenter.default.rx
.notification(NSNotification.Name.UIKeyboardWillShow)
.takeUntil(self.rx.deallocated) //页面销毁自动移除通知监听
.subscribe(onNext: { _ in
print("键盘出现了")
})
//监听键盘隐藏通知
_ = NotificationCenter.default.rx
.notification(NSNotification.Name.UIKeyboardWillHide)
.takeUntil(self.rx.deallocated) //页面销毁自动移除通知监听
.subscribe(onNext: { _ in
print("键盘消失了")
})
}
}
二、自定义通知的发送与接收
1，基本介绍
通知类型其实就是一个字符串，所以我们也可以使用自己定义的通知（同时还可以传递用户自定义数据）。
2，样例演示
（1）ViewController.swift（我们发出一个携带有自定义数据的通知，同时创建两个观察者来接收这个通知。）
import UIKit
import RxSwift
import RxCocoa
class ViewController: UIViewController {
let disposeBag = DisposeBag()
let observers = [MyObserver(name: "观察器1"),MyObserver(name: "观察器2")]
override func viewDidLoad() {
super.viewDidLoad()
print("发送通知")
let notificationName = Notification.Name(rawValue: "DownloadImageNotification")
NotificationCenter.default.post(name: notificationName, object: self,
userInfo: ["value1":"hangge.com", "value2" : 12345])
print("通知完毕")
}
}
（2）MyObserver.swift（观察者在收到通知后的执行的处理函数中，添加了个 3 秒的等待。）
import UIKit
import RxSwift
import RxCocoa
class MyObserver: NSObject {
var name:String = ""
init(name:String){
super.init()
self.name = name
// 接收通知：
let notificationName = Notification.Name(rawValue: "DownloadImageNotification")
_ = NotificationCenter.default.rx
.notification(notificationName)
.takeUntil(self.rx.deallocated) //页面销毁自动移除通知监听
.subscribe(onNext: { notification in
//获取通知数据
let userInfo = notification.userInfo as! [String: AnyObject]
let value1 = userInfo["value1"] as! String
let value2 = userInfo["value2"] as! Int
print("\(name) 获取到通知，用户数据是［\(value1),\(value2)］")
//等待3秒
sleep(3)
print("\(name) 执行完毕")
})
}
}
（3）运行结果如下。可以看出，通知发送后的执行是同步的，也就是说观察者全部处理完毕后，主线程才继续往下进行。
