Qt新手如何在Qt Creator中实现Rx响应式编程

Qt生态下做Rx响应式编程分两种方案，根据自己的业务场景选即可，下面是从零开始的操作步骤：

方案1：全功能Rx实现（适配复杂流处理、异步编排场景） #

用RxCpp（C++原生Reactive Extensions实现）+ RxQt（Qt适配层），是目前Qt下最成熟的全功能Rx方案，支持操作符链式调用、线程调度、信号转流、防抖节流等所有Rx标准能力。

配置步骤（Qt Creator内操作） #

• 提前准备好RxCpp、RxQt的头文件源码，两个库都是header-only形态，不需要提前编译，直接放到你项目的third_party第三方依赖目录即可
• 根据你用的构建系统添加对应配置：
  • qmake构建的项目，在.pro文件里追加头文件路径：

    INCLUDEPATH += $$PWD/third_party/rxcpp/Rx/v2/src
    INCLUDEPATH += $$PWD/third_party/rxqt/include
    # 自身业务用到的Qt模块正常引入即可，比如core/gui/widgets/network
    QT += core gui widgets
    

  • CMake构建的项目，在CMakeLists.txt里追加配置：

    include_directories(${PROJECT_SOURCE_DIR}/third_party/rxcpp/Rx/v2/src)
    include_directories(${PROJECT_SOURCE_DIR}/third_party/rxqt/include)
    # 用Qt5就把配置改成对应Qt5的查找规则
    find_package(Qt6 REQUIRED COMPONENTS Core Widgets Network)
    target_link_libraries(你的项目名 PRIVATE Qt6::Core Qt6::Widgets Qt6::Network)
    

基础用法示例 #

最常见的场景是把Qt原生信号转成Rx流做链式处理，比如实现输入框实时搜索的防抖逻辑，直接在窗口构造函数里写即可：

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <rxqt.hpp>
#include <rxcpp/rx.hpp>
#include <QThread>

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)
{
    ui->setupUi(this);

    // 将输入框的textChanged信号转为可观察流
    auto input_stream = rxqt::from_signal(ui->searchEdit, &QLineEdit::textChanged);

    // 持有订阅对象，窗口销毁时主动取消订阅避免野指针
    auto sub = input_stream
        // 防抖：输入停顿300ms才触发后续逻辑，避免每次敲字都发请求
        .debounce(std::chrono::milliseconds(300), rxqt::run_loop(this))
        // 过滤空输入，无效请求直接截断
        .filter([](const QString& kw){ return !kw.trimmed().isEmpty(); })
        // 切到子线程执行耗时操作，不阻塞UI线程
        .observe_on(rxcpp::synchronize_new_thread())
        .map([](const QString& kw){
            // 这里写实际的搜索请求、数据库查询等耗时逻辑
            QThread::msleep(600); // 模拟IO耗时
            return QString("关键词「%1」匹配到12条结果").arg(kw);
        })
        // 切回Qt主线程执行UI更新操作
        .observe_on(rxqt::observe_on_run_loop(this))
        // 订阅最终处理结果
        .subscribe([this](const QString& res){
            ui->resultLabel->setText(res);
        });

    // 窗口销毁时取消订阅，避免后台任务回调已经释放的控件
    connect(this, &QObject::destroyed, [sub](){
        sub.unsubscribe();
    });
}

新手避坑提醒 #

• 所有操作Qt UI控件的逻辑必须切回Qt主线程执行，也就是加observe_on(rxqt::observe_on_run_loop(关联窗口对象))，跨线程直接操作UI会触发崩溃
• 编译报错优先检查头文件路径是否正确、编译器和Qt库的位数/版本是否匹配，这两个库都是纯头文件实现，不需要链接额外二进制文件
• 长生命周期的异步流一定要存好订阅对象，关联的UI对象销毁时主动取消订阅，避免野指针崩溃

方案2：轻量响应式（适配简单属性联动、状态绑定场景） #

如果只是做简单的属性绑定、状态联动，不需要复杂的流组合、线程调度能力，直接用Qt 6自带的QProperty绑定即可，零依赖不需要引入第三方库，示例：

// 输入框内容变化时，标签自动同步显示当前输入长度
ui->lenLabel->bindableText().setBinding([&](){
    return QString("当前输入长度：%1").arg(ui->searchEdit->text().length());
});

简单场景下这个方案性能更好，也没有额外的Rx学习成本。

内容的提问来源于stack exchange，提问作者Sayali