17370845950

RxCpp 的核心是 Observable 和 Observer 模式，通过操作符编排异步数据流；例如 rxcpp::observable::just(1,2,3) 创建同步序列并用 subscribe 输出。

RxCpp 是 C++ 的响应式编程库，它让异步数据流的处理变得像操作容器一样直观：可组合、可订阅、可变换。入门关键不是学一堆新语法，而是理解“Observable（可观测序列）”和“Observer（观察者）”这两个核心角色，以及如何用操作符（如 map、filter、subscribe_on）编排事件流。

从一个最简 Observable 开始

不用线程、不接网络，先看数据怎么“发出来”：

• 用 rxcpp::observable::just(1, 2, 3) 创建一个立即发出 1、2、3 的同步序列；
• 用 .subscribe([](int v) { std::cout 接收并打印 —— 这就是最基础的 Observer；
• 注意：subscribe() 调用后，数据立刻推送到 lambda，整个过程是同步阻塞的，没有后台线程。

让事件真正“异步”起来

响应式真正的价值在于解耦执行时机。RxCpp 提供调度器（Scheduler）控制在哪跑：

• 用 rxcpp::observe_on_event_loop() 或 rxcpp::synchronize_new_thread() 获取调度器；
• 链式调用 .observe_on(scheduler) 把后续操作切到目标线程；
• 例如：定时发数 —— rxcpp::observable::interval(std::chrono::seconds(1)) 默认在事件循环中每秒发一个 long 值，配合 take(5) 可限制次数。

常用操作符组合数据流

就像 STL 算法操作 vector，RxCpp 操作符对 Observable 做声明式变换：

• .map([](int x) { return x * x; })：一对一转换；
• .filter([](int x) { return x % 2 == 0; })：筛选偶数；
• .merge(other_obs)：把两个流合并成一个时间有序的流；
• .flat_map([](int x) { return rxcpp::observable::just(x, x+1); })：每个输入展开为多个输出。

资源管理与生命周期要主动管

RxCpp 不自动管理订阅生命周期，忘了取消可能引发崩溃或重复回调：

• auto sub = obs.subscribe(...); 返回 rxcpp::subscription 对象；
• 调用 sub.unsubscribe() 可随时终止接收；
• 更安全的做法是用 composite_subscription 统一管理多个订阅，在作用域结束时自动清理。

基本上就这些。RxCpp 入门不复杂但容易忽略细节：别急着上多线程，先搞懂同步流怎么走；操作符链写得再漂亮，没管好 subscription 就等于埋雷。动手写三五个小例子，比如“按钮点击 → 请求网络 → 更新 UI”，很快就能体会到响应式对事件驱动逻辑的简化效果。