# Robius 应用架构技能基于 Robrix 和 Moly 代码库构建 Makepad 应用程序的最佳实践 - 使用 Makepad 和 Robius 框架构建的生产应用程序。 **源代码库：** * **Robrix** ：Matrix 聊天客户端 - 与后台订阅的复杂同步/异步 * **Moly** ：人工智能聊天应用程序 - 具有流 API 的跨平台（本机 + WASM） ## 触发器在以下情况下使用此技能： * 构建具有异步后端集成的 Makepad 应用程序 * 在 Makepad 中设计同步/异步通信模式 * 构建 Robius 风格的应用程序 * 关键词：robrix、robius、makepad 应用程序结构、异步 makepad、tokio makepad ## 生产模式对于生产就绪的异步模式，请参阅“_base/”目录：图案|描述 ---|--- [08-async-loading]() |具有加载状态的异步数据加载 [09-streaming-results]() |使用 SignalToUI 获得增量结果 [13-tokio-integration]() |完整的 tokio 运行时集成 ## 核心架构模式 ┌──────────────────────────────────────────────────────────────┐ │ UI 线程 (Makepad) │ │ ┌──────────┐ ┐──────────┐ ┌────────────────────┐ │ │ │ 应用程序 │────▶│ WidgetRef │────▶│ Widget 树（视图） │ │ │ │ 状态 │ │ ui │ │ 范围::with_data() │ │ │ └────┬────┘ └──────────┘ └────────────────────┘ │ │ │ │ │ │ 提交异步请求() │ │ ▼ │ │ ┌────────────────┐ ┌──────────────────────────┐ │ │ │ REQUEST_SENDER │──────────▶│ Crossbeam SegQueue │ │ │ │ (MPSC 通道) │ │ (无锁更新) │ │ │ └────────────────┘ └──────────────────────────┘ │ └────────────────────────────────────┬──────────────────────────┘ │ SignalToUI::set_ui_signal() │ ┌────────────────────────────────────┴──────────────────────────┐ │ Tokio 运行时（异步） │ │ ┌────────────────────────────────────────────────────┐ │ │ │worker_task（请求处理程序）│ │ │ │ - 接收来自 UI 的请求 │ │ │ │ - 根据请求生成异步任务 │ │ │ │ - 通过 Cx::post_action() 回发操作 │ │ │ └────────────────────────────────────────────────────┘ │ │ ┌────────────────────────────────────────────────────┐ │ │ │ 每项订阅者任务 │ │ │ │ - 监听外部数据流 │ │ │ │ - 通过 crossbeam 通道发送更新 │ │ │ │ - 调用 SignalToUI::set_ui_signal() 唤醒 UI │ │ │ └────────────────────────────────────────────────────┘ │ └──────────────────────────────────────────────────────────────┘ ## 应用程序结构 ### 顶级应用程序定义使用 makepad_widgets::*; 现场设计！ { 使用链接::主题::*; 使用链接::小部件::*；应用程序 = {{应用程序}} { 用户界面：<根>{ main_window = <窗口> { 窗口: {inner_size: vec2(1280, 800), 标题: "MyApp"}, 身体={ // 主要内容在这里 } } } } } app_main！（应用程序）； #[推导（实时）] 酒吧结构应用程序{ #[live] ui: WidgetRef, #[rust] app_state：应用程序状态， } impl LiveRegister for App { fn live_register(cx: &mut Cx) { // 顺序很重要：首先注册基础小部件 makepad_widgets::live_design(cx); // 然后是共享/通用小部件板条箱::共享::live_design(cx); // 然后是功能模块板条箱::家::live_design(cx); } } 为应用程序实现 LiveHook { fn after_new_from_doc(&mut self, cx: &mut Cx) { // widget树创建后一次性初始化 } } ### AppMain 实现为应用程序实现 AppMain { fn handle_event(&mut self, cx: &mut Cx, 事件: &Event) { // 转发到 MatchEvent 特征 self.match_event(cx, 事件); // 通过 Scope 通过 widget 树传递 AppState 让范围 = &mut Scope::with_data(&mut self.app_state); self.ui.handle_event(cx, 事件, 范围); } } ## Tokio 运行时集成 ### 静态运行时初始化使用 std::sync::Mutex；使用 tokio::sync::mpsc::{UnboundedReceiver，UnboundedSender}；静态 TOKIO_RUNTIME: Mutex> = Mutex::new(None); 静态 REQUEST_SENDER: Mutex>> = Mutex::new(None); pub fn start_async_runtime() -> 结果 { let (request_sender, request_receiver) = tokio::sync::mpsc::unbounded_channel(); 让 rt_handle = TOKIO_RUNTIME.lock().unwrap() .get_or_insert_with(|| { 东京::运行时::运行时::新() .expect("创建 Tokio 运行时失败") }) .handle() .clone(); // 存储发送者以供 UI 线程使用 *REQUEST_SENDER.lock().unwrap() = Some(request_sender); // 生成主工作任务 rt_handle.spawn(worker_task(request_receiver)); 好的（rt_handle） } ### 请求提交模式 pub 枚举 AppRequest { FetchData { id: 字符串 }, SendMessage { 内容：字符串 }, // ...其他请求类型 } /// 将请求从 UI 线程提交到异步运行时 pub fn Submit_async_request（请求：AppRequest）{ if let Some(sender) = REQUEST_SENDER.lock().unwrap().as_ref() { 发送者.send(req) .expect("BUG：工作任务接收者已死亡！"); } } ### 工作任务模式 async fn worker_task(mut request_receiver: UnboundedReceiver) -> Result<()> { while let Some(request) = request_receiver.recv().await { 匹配请求{ AppRequest::FetchData { id } => { // 为每个请求生成一个新任务让 _task = tokio::spawn(异步移动 { 让结果 = fetch_data(&id).await; // 将结果发送回 UI 线程 Cx::post_action(DataFetchedAction { id, 结果 }); }); } AppRequest::SendMessage { 内容 } => { 让 _task = tokio::spawn(异步移动 { 匹配 send_message(&content).await { 好的(()) => Cx::post_action(MessageSentAction::成功), Err(e) => Cx::post_action(MessageSentAction::Failed(e)), } }); } } } 好的(()) } ## 无锁更新队列模式对于后台任务的高频更新：使用 crossbeam_queue::SegQueue；使用 makepad_widgets::SignalToUI； pub 枚举数据更新 { NewItem { 项目：项目 }, ItemChanged { id：字符串，更改：更改 }，状态{消息：字符串}， } 静态 PENDING_UPDATES：SegQueue = SegQueue::new(); /// 从后台异步任务调用 pub fn enqueue_update(更新: DataUpdate) { PENDING_UPDATES.push(更新); SignalToUI::set_ui_signal(); // 唤醒UI线程 } // 在小部件的handle_event中：为 MyWidget 实现 Widget { fn handle_event(&mut self, cx: &mut Cx, 事件: &Event, 范围: &mut 范围) { // 轮询信号事件的更新如果让 Event::Signal = 事件 { 而让一些（更新）= PENDING_UPDATES.pop（）{ 比赛更新{ DataUpdate::NewItem { 项目 } => { self.items.push(item); self.redraw(cx); } // ... 处理其他更新 } } } } } ## 启动顺序为应用程序实现 MatchEvent { fn handle_startup(&mut self, cx: &mut Cx) { // 1. 初始化日志记录让_=tracing_subscriber::fmt::try_init(); // 2.初始化应用程序数据目录让 _app_data_dir = crate::app_data_dir(); // 3. 加载持久状态 if let Err(e) = persistence::load_window_state( self.ui.window(ids!(main_window)), cx ）{ error!("加载窗口状态失败：{}", e); } // 4. 根据加载状态更新 UI self.update_ui_visibility(cx); // 5. 启动异步运行时让 _rt_handle = crate::start_async_runtime().unwrap(); } } ## 关闭顺序为应用程序实现 AppMain { fn handle_event(&mut self, cx: &mut Cx, 事件: &Event) { 如果让 Event::Shutdown = 事件 { // 保存窗口几何形状让 window_ref = self.ui.window(ids!(main_window)); if let Err(e) = persistence::save_window_state(window_ref, cx) { error!("保存窗口状态失败：{e}"); } // 保存应用程序状态 if let Some(user_id) = current_user_id() { if let Err(e) = persistence::save_app_state( self.app_state.clone(), user_id ）{ error!("无法保存应用状态：{e}"); } } } // ... 其余的事件处理 } } ## 最佳实践 1. **关注点分离** ：将 UI 逻辑保留在主线程上，将异步操作保留在 Tokio 运行时中 2. **请求/响应模式**：使用类型化枚举来表示请求和操作 3. **无锁更新** ：使用 `crossbeam::SegQueue` 进行高频后台更新 4. **SignalToUI** ：在排队更新后始终调用 `SignalToUI::set_ui_signal()` 5. **Cx::post_action()** ：用于需要操作处理的异步任务结果 6. **Scope::with_data()** ：通过 widget 树传递共享状态 7. **模块注册顺序** ：在`live_register()`中的依赖模块之前注册基本小部件 ## 参考文件 * `references/tokio-integration.md` \- 详细的 Tokio 运行时模式 (Robrix) * `references/channel-patterns.md` \- 通道通信模式 (Robrix) * `references/moly-async-patterns.md` \- 跨平台异步模式 (Moly) * 用于本机/WASM 兼容性的“PlatformSend”特征 * 用于异步延迟操作的“UiRunner” * `AbortOnDropHandle` 用于取消任务 * WASM 上的非发送类型的“ThreadToken” * `spawn()` 与平台无关的函数

Robius 应用架构

包含技能