RxCpp 的核心是 Observable 和 Observer 模式，通过操作符编排异步数据流；例如 rxcpp::observable<int>::just(1,2,3) 创建同步序列并用 subscribe 输出。
RxCpp 是 C++ 的响应式编程库，它让异步数据流的处理变得像操作容器一样直观：可组合、可订阅、可变换。入门关键不是学一堆新语法，而是理解“Observable（可观测序列）”和“Observer（观察者）”这两个核心角色，以及如何用操作符（如 map、filter、subscribe_on）编排事件流。
从一个最简 Observable 开始
不用线程、不接网络，先看数据怎么“发出来”：
- 用
rxcpp::observable<int>::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 做声明式变换：
立即学习“C++免费学习笔记（深入）”；
-
.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”，很快就能体会到响应式对事件驱动逻辑的简化效果。
