鸿蒙超级终端多设备协同开发涉及分布式架构、数据管理与通信。文章介绍了超级终端的定义与架构，通过实战演示了商品搜索与购物车在多设备间的协同流程。重点讲解了分布式数据管理工具类 DistributedDataManager 和分布式通信工具类 DistributedCommunicationManager 的实现方法，包括单例模式、初始化、设备发现、连接及消息收发。同时涵盖了 module.json5 权限配置与项目部署测试步骤，旨在帮助开发者实现手机、平板、智慧屏等设备间的数据同步与无缝体验。
本文承接原子化服务与元服务卡片开发内容，复用项目架构，重点讲解超级终端多设备协同的核心技术。
学习目标：
学习重点：
超级终端多设备协同是 HarmonyOS Next 推出的一种全新的应用形态，具有以下特点：
超级终端多设备协同采用分布式架构，由以下部分组成：
基于 MyFirstHarmonyApp 项目架构，实现以下功能：
在 entry/src/main/ets 目录下创建以下文件夹：
distributed：存放分布式能力相关代码；ui：存放分布式 UI 组件相关代码。// entry/src/main/ets/utils/DistributedDataManager.ets
import dataShare from '@ohos.data.dataShare';
import { UIAbilityContext } from '@ohos.abilityAccessCtrl';
// 分布式数据管理工具类
export class DistributedDataManager {
private static instance: DistributedDataManager | null = null;
private dataShareHelper: dataShare.DataShareHelper | null = null;
// 单例模式
static getInstance(): DistributedDataManager {
if (!DistributedDataManager.instance) {
DistributedDataManager.instance = new DistributedDataManager();
}
return DistributedDataManager.instance;
}
// 初始化分布式数据管理
async init(context: UIAbilityContext): Promise<void> {
if (!this.dataShareHelper) {
const uri = 'dataability://com.example.myapp';
this.dataShareHelper = await dataShare.createDataShareHelper(context, uri);
}
}
// 保存数据
async saveData(key: string, value: any): Promise<void> {
if (!this.dataShareHelper) {
return;
}
await this.dataShareHelper.insert('data', { key, value });
}
// 获取数据
async getData(key: string): Promise<any> {
if (!this.dataShareHelper) {
return null;
}
const result = await this.dataShareHelper.query('data', { key });
if (result && result.length > 0) {
return result[0].value;
}
return null;
}
// 删除数据
async deleteData(key: string): Promise<void> {
if (!this.dataShareHelper) {
return;
}
await this.dataShareHelper.delete('data', { key });
}
// 监听数据变化
onDataChange(key: string, callback: (value: any) => void): void {
if (!this.dataShareHelper) {
return;
}
this.dataShareHelper.on('dataChange', (data: any) => {
if (data.key === key) {
callback(data.value);
}
});
}
// 取消监听数据变化
offDataChange(key: string, callback: (value: any) => void): void {
if (!this.dataShareHelper) {
return;
}
this.dataShareHelper.off('dataChange', callback);
}
}
// entry/src/main/ets/services/SearchService.ets（修改）
import { DistributedDataManager } from '../utils/DistributedDataManager';
// 搜索服务
export class SearchService {
// ...
// 保存搜索记录
async saveSearchHistory(keyword: string): Promise<void> {
const history = await this.getSearchHistory();
const index = history.findIndex(item => item === keyword);
if (index !== -1) {
history.splice(index, 1);
}
history.unshift(keyword);
if (history.length > 10) {
history.splice(10);
}
await DistributedDataManager.getInstance().saveData('searchHistory', history);
}
// 获取搜索记录
async getSearchHistory(): Promise<Array<string>> {
const history = await DistributedDataManager.getInstance().getData('searchHistory');
history || [];
}
(: ): <> {
history = .();
index = history.( item === keyword);
(index !== -) {
history.(index, );
.().(, history);
}
}
(): <> {
.().();
}
}
// entry/src/main/ets/services/CartService.ets（修改）
import { DistributedDataManager } from '../utils/DistributedDataManager';
// 购物车服务
export class CartService {
// ...
// 添加商品到购物车
async addToCart(productId: number, count: number): Promise<void> {
const cartItems = await this.getCartItems();
const index = cartItems.findIndex(item => item.productId === productId);
if (index !== -1) {
cartItems[index].count += count;
} else {
const product = goodsData.find(item => item.id === productId);
if (product) {
cartItems.push({ id: productId, productId, name: product.name, imageUrl: product.imageUrl, price: product.price, count, isChecked: false });
}
}
await this.saveCartItems(cartItems);
// 同步到分布式数据管理
.().(, cartItems);
}
(): <<>> {
remoteData = .().();
(remoteData) {
remoteData;
}
localData = .();
localData;
}
(: ): <> {
cartItems = .();
index = cartItems.( item. === id);
(index !== -) {
cartItems.(index, );
.(cartItems);
.().(, cartItems);
}
}
(): <> {
.([]);
.().(, []);
}
}
// entry/src/main/ets/utils/DistributedCommunicationManager.ets
import communication from '@ohos.comm';
import { UIAbilityContext } from '@ohos.abilityAccessCtrl';
// 分布式通信工具类
export class DistributedCommunicationManager {
private static instance: DistributedCommunicationManager | null = null;
private communicationHelper: communication.CommunicationHelper | null = null;
// 单例模式
static getInstance(): DistributedCommunicationManager {
if (!DistributedCommunicationManager.instance) {
DistributedCommunicationManager.instance = new DistributedCommunicationManager();
}
return DistributedCommunicationManager.instance;
}
// 初始化分布式通信
async init(context: UIAbilityContext): Promise<void> {
if (!this.communicationHelper) {
this.communicationHelper = communication.createCommunicationHelper(context);
}
}
(: ): {
(!.) {
;
}
..(, {
(device);
});
}
(: ): {
(!.) {
;
}
..(, callback);
}
(: ): <> {
(!.) {
;
}
result = ..(deviceId);
result === communication..;
}
(: ): <> {
(!.) {
;
}
result = ..(deviceId);
result === communication..;
}
(: , : ): <> {
(!.) {
;
}
result = ..(deviceId, message);
result === communication..;
}
(: ): {
(!.) {
;
}
..(, {
(deviceId, message);
});
}
(: ): {
(!.) {
;
}
..(, callback);
}
}
// entry/src/main/ets/components/DeviceListComponent.ets
import { DistributedCommunicationManager } from '../utils/DistributedCommunicationManager';
import { communication } from '@ohos.comm';
@Component
export struct DeviceListComponent {
@State deviceList: Array<communication.DeviceInfo> = [];
@State connectedDeviceId: string = '';
build() {
Column({ space: 16 }) {
Text('已连接设备').fontSize(18).fontWeight(FontWeight.Bold).textColor('#000000');
List({ space: 16 }) {
ForEach(this.deviceList, (device: communication.DeviceInfo) => {
ListItem() {
Row({ space: 16 }) {
Image(device.icon).width(40).height(40).objectFit(.);
({ : }) {
(device.).().(.).();
(device.).().();
}.();
(device. === .) {
().().();
} {
().().().().( () => {
result = .().(device.);
(result) {
. = device.;
}
});
}
}.().().().().();
}.().();
}, device.);
}.().().();
().().(.).();
({ : }) {
}.().().();
}.().().();
}
() {
.().( {
..(device);
});
}
}
在 entry/src/main/module.json5 中添加分布式能力配置：
{
"module": {
"requestPermissions": [
{ "name": "ohos.permission.DISTRIBUTED_DATASYNC" },
{ "name": "ohos.permission.DISTRIBUTED_COMMUNICATION" },
{ "name": "ohos.permission.GET_NETWORK_INFO" },
{ "name": "ohos.permission.READ_EXTERNAL_STORAGE" },
{ "name": "ohos.permission.WRITE_EXTERNAL_STORAGE" }
],
"abilities": [],
"widgets": [],
"pages": []
}
}
在 DevEco Studio 中点击 Build → Build HAP，编译项目。
将编译后的 HAP 文件部署到鸿蒙设备上。
本文完成了：
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online
将 Markdown（GFM）转为 HTML 片段，浏览器内 marked 解析；与 HTML转Markdown 互为补充。 在线工具，Markdown转HTML在线工具，online
将 HTML 片段转为 GitHub Flavored Markdown，支持标题、列表、链接、代码块与表格等；浏览器内处理，可链接预填。 在线工具，HTML转Markdown在线工具，online
通过删除不必要的空白来缩小和压缩JSON。 在线工具，JSON 压缩在线工具，online
将JSON字符串修饰为友好的可读格式。 在线工具，JSON美化和格式化在线工具，online