当前位置：首页 > java >正文

HarmonyOS 实战：6 种实现实时数据更新的方案全解析（含完整 Demo）

java 2025/8/22 9:51:34

在这里插入图片描述

摘要

在当下的应用开发中，用户体验越来越依赖“实时性”。消息要第一时间送达、订单状态要立刻刷新、数据变化不能延迟……这些需求推动了“实时数据更新”成为应用的必备功能。在鸿蒙系统（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 已关闭");};
}