摘要

在当下的应用开发中，用户体验越来越依赖“实时性”。消息要第一时间送达、订单状态要立刻刷新、数据变化不能延迟……这些需求推动了“实时数据更新”成为应用的必备功能。在鸿蒙系统（HarmonyOS）中，我们既可以用系统内置的数据能力（DataAbility、DataBus），也可以用事件驱动（发布订阅）、后台服务，甚至和远程服务器保持 WebSocket 长连接。不同的方案适合不同的场景，本文会带大家从原理到实战，结合代码一步步拆解。

引言

假设你正在做一个电商应用：用户提交订单后希望能立刻看到订单状态更新；商家端改价后，用户端价格立刻刷新；再比如做一个股票类 App，行情数据需要秒级同步。这类场景在鸿蒙中都可以实现。
那怎么做呢？常见的方式包括：

• DataAbility：适合模块内、应用间的数据共享和通知。
• 发布-订阅（Publish-Subscribe）：轻量、解耦，常用在组件交互。
• 后台服务（ServiceAbility）：适合长期任务，比如轮询服务器。
• WebSocket：和后端保持实时通信。
• DataBus：模块间的消息和数据同步。

接下来，我们用几个实际场景来展开。

用发布-订阅实现应用内实时更新

发布-订阅是应用内实时通知最常见的方式，模块之间不用直接耦合，只要关心“订阅什么事件”和“发布什么事件”即可。

场景：聊天应用消息刷新

用户在 A 页面发了一条消息，B 页面需要立刻刷新列表。
这时可以用事件分发，避免两个页面硬编码依赖。

Demo 代码

// 定义一个事件 key
const EVENT_MESSAGE_UPDATE = "chat_message_update";// 发布者（比如在发送消息后触发）
import eventEmitter from '@ohos.events.emitter';function sendMessage(content: string) {// 假装这里调用了服务端 API 成功console.info("发送消息成功: " + content);// 发布事件，通知其他模块刷新let eventData = {data: {message: content}};eventEmitter.emit({ eventId: 1, eventName: EVENT_MESSAGE_UPDATE }, eventData);
}

// 订阅者（比如消息列表页面）
import eventEmitter from '@ohos.events.emitter';function registerMessageObserver() {eventEmitter.on({ eventId: 1, eventName: "chat_message_update" }, (data) => {console.info("收到消息更新: " + JSON.stringify(data));// 在这里更新 UI，比如追加到聊天列表});
}

说明

• eventEmitter.emit 是发布事件。
• eventEmitter.on 是订阅事件。
• 事件 ID 和事件名需要保持一致，不然收不到。

这样就能做到：一个页面发消息，另一个页面自动更新。

用后台服务定期获取数据

有些场景下我们不依赖消息推送，而是主动去服务器拉取，比如天气数据、股票行情。这里就要用到 ServiceAbility。

场景：股票行情定时刷新

后台服务定时请求行情接口，前台 UI 通过事件接收并刷新。

Demo 代码

// MyStockServiceAbility.ets
import UIAbility from '@ohos.app.ability.ServiceExtensionAbility';
import eventEmitter from '@ohos.events.emitter';export default class MyStockServiceAbility extends UIAbility {onCreate() {console.info("Stock Service started");this.startPolling();}startPolling() {setInterval(async () => {// 模拟请求股票接口let price = (Math.random() * 100).toFixed(2);console.info("拉取到最新股价: " + price);// 推送事件给 UIeventEmitter.emit({ eventId: 2, eventName: "stock_price_update" }, {data: { price }});}, 5000); // 每 5 秒刷新一次}
}

// 前台页面订阅股价更新
import eventEmitter from '@ohos.events.emitter';function registerStockListener() {eventEmitter.on({ eventId: 2, eventName: "stock_price_update" }, (data) => {console.info("UI 收到最新股价: " + data.data.price);// 在这里刷新界面});
}

说明

• ServiceAbility 适合后台运行，不会被 UI 销毁影响。
• 用 setInterval 定时拉取数据，实际项目中可换成真正的 HTTP 请求。
• UI 层和后台服务解耦，只靠事件通信。

用 WebSocket 做实时推送

如果是消息、通知、行情这类高实时性场景，WebSocket 是更合适的。客户端和服务端保持长连接，一旦有数据，立刻推送。

场景：股票行情实时推送

相比上面的轮询方式，WebSocket 更节省资源，延迟更低。

Demo 代码

import WebSocket from '@ohos.net.webSocket';function connectWebSocket() {const ws = new WebSocket("ws://echo.websocket.org"); // 测试用 echo 服务ws.onopen = () => {console.info("WebSocket 已连接");ws.send("订阅股票行情");};ws.onmessage = (msg) => {console.info("收到行情推送: " + msg.data);// 在这里更新 UI};ws.onerror = (err) => {console.error("WebSocket 错误: " + JSON.stringify(err));};ws.onclose = () => {console.info("WebSocket 已关闭");};
}

说明

• onopen：连接成功回调。
• onmessage：收到消息立刻更新 UI。
• onerror / onclose：处理异常和断开。
• 服务端可以随时推送数据，不需要客户端轮询。

QA 阶段

Q1：发布订阅和 DataAbility 有什么区别？
发布订阅更轻量，适合应用内事件；DataAbility 更像数据库，适合做数据共享和存储。

Q2：后台服务会不会被系统杀掉？
在 HarmonyOS 中，ServiceAbility 默认是后台长驻的，但如果内存紧张，系统也可能回收。可以通过合理的调度策略来增强存活率。

Q3：WebSocket 和轮询哪个好？
实时性要求高 → WebSocket；数据变化频率低且服务端不支持推送 → 定时轮询。

总结

鸿蒙应用实现实时数据更新，有多种方案可选：

• 发布订阅：模块间解耦、事件驱动。
• 后台服务：适合定时拉取或长时间运行的逻辑。
• WebSocket：最适合实时推送场景。
• DataAbility / DataBus：适合模块间或跨应用的数据共享。

开发中往往不是单一选择，而是组合使用。比如：消息系统用 WebSocket，配合事件分发到 UI；行情类数据用后台服务定时补偿，避免丢消息。
这样才能既保证实时性，又保证应用稳定。