首页 > 其他分享 >鸿蒙原生应用开发——分布式数据对象

鸿蒙原生应用开发——分布式数据对象

时间：2023-12-08 10:02:51浏览次数：31  
标签：原生 鸿蒙 对象 sessionId 组网 权限 数据 分布式

 

01、什么是分布式数据对象

在可信组网环境下，多个相互组网认证的设备将各自创建的对象加入同一个sessionId，使得加入的多个数据对象之间可以同步数据，也就是说，当某一数据对象属性发生变更时，其他数据对象会检测到这一变更，同时将自身属性更新。此时，该sessionId下的所有数据对象属性相同，这样的数据对象称之为分布式数据对象。此外，分布式数据对象可以被动退出sessionId，当分布式数据对象退出sessionId后，该对象将检测不到其他对象的变更。

02、分布式数据对象能力

1、  分布式数据对象创建

2、  分布式数据对象查询

3、  分布式数据对象修改

4、  分布式数据对象删除

5、  分布式数据对象保存

6、  分布式数据对象订阅（数据变更，上下线）

7、分布式数据对象加入、退出分布式组网

03、前提准备

 

1、  开发工具：DevEco Studio 3.1.0.501

2、API：9

3、  SDK版本：3.2.12.5

 

04、创建一个新的项目

新建项目，选择API9版本，stage模型。

 

05、权限申请

 

1、  使用到的权限

○ ohos.permission.DISTRIBUTED_DATASYNC

○ 允许不同设备间的数据交换

○ 权限级别：normal

○ 授权方式：user_grant

○ ACL使能：TRUE

2、配置文件申明

首先，在项目的模块级目录下找到并打开module.json5文件，如下图：

 

在module下的对象里添加如下申明：

 

此时，配置文件中的权限申明就完成了，但是，此时我们还不能获得这些权限。由于ohos.permission.DISTRIBUTED_DATASYNC权限是ACL使能为TRUE的权限，需要在签名工具文件中说明一下。

如何找到对应的签名工具文件呢？我们在安装DevEco Studio的时候是下载好了OpenHarmony的SDK的，此时在OpenHarmony文件夹中，打开 “Sdk\OpenHarmony SDK版本\toolchains\lib” 该路径，此时在lib文件夹中，咱们可以找到两个json文件，分别为UnsgnedDebugProfileTemplate.json和UnsgnedReleasedProfileTemplate.json，点击并打开这两个文件，添加如下权限：

 

3、权限申请编码

在申请ohos.permission.DISTRIBUTED_DATASYNC权限时，其文档中将其标注为用户手动授权的权限，此时需要我们动态申请权限，在项目中，我们新建一个ets文件，我这里取名为RequestPermission.ets。

首先，导入以下包：

 

import abilityAccessCtrl, { Permissions } from '@ohos.abilityAccessCtrl';
import bundleManager from '@ohos.bundle.bundleManager';
import common from '@ohos.app.ability.common';

　　

获取访问控制模块对象实例：

 

let atManager = abilityAccessCtrl.createAtManager();

　　

编写如下方法（这里使用的是异步函数）：

 

export async function checkAccessTokenID(permission: Array<Permissions>) {
  // 获取应用程序的accessTokenID
  let tokenId: number;
  let grantStatus: Array<abilityAccessCtrl.GrantStatus> = []
  try {
    let bundleInfo: bundleManager.BundleInfo = await bundleManager.getBundleInfoForSelf(bundleManager.BundleFlag.GET_BUNDLE_INFO_WITH_APPLICATION);
    let appInfo: bundleManager.ApplicationInfo = bundleInfo.appInfo;
    tokenId = appInfo.accessTokenId;
  } catch (err) {
    console.error(`getBundleInfoForSelf failed, code is ${err.code}, message is ${err.message}`);
  }
  // 校验应用是否被授予权限，若申请多个权限，建议循环检查多个权限
  for (let index = 0;index < permission.length; index++) {
    try {
      grantStatus.push(await atManager.checkAccessToken(tokenId, permission[index]))
    } catch (err) {
      console.error(`checkAccessToken failed, code is ${err.code}, message is ${err.message}`);
    }
  }
  return grantStatus;
}


export async function checkPermission(context: common.UIAbilityContext, permissions: Array<Permissions>) {
  let grantStatus: Array<abilityAccessCtrl.GrantStatus> = await checkAccessTokenID(permissions)
  for (let i = 0; i < grantStatus.length; i++) {
    if (grantStatus[i] === abilityAccessCtrl.GrantStatus.PERMISSION_GRANTED) {
      console.info(`${permissions[i].toString()} 已授权`)
    } else {
      //申请权限
      console.info('开始向用户申请权限')
      requestPermissionFromUser(context, permissions)
    }
  }
}
export async function requestPermissionFromUser(context: common.UIAbilityContext, permissions: Array<Permissions>) {
  // requestPermissionsFromUser会判断权限的授权状态来决定是否唤起弹窗
  atManager.requestPermissionsFromUser(context, permissions).then((data) => {
    let grantStatus: Array<number> = data.authResults
    let length: number = grantStatus.length
    for (let i = 0;i < length; i++) {
      if (grantStatus[i] === 0) {
        // 用户授权，可以继续访问目标操作
        console.info(`${permissions[i].toString()} 权限申请成功`)
      } else {
        // 用户拒绝授权，提示用户必须授权才能访问当前页面的功能，并引导用户到系统设置中打开相应的权限
        console.info(`${permissions[i].toString()} 权限申请被用户拒绝`)
      }
    }
    // 授权成功
  })
}

　　

此时，我们申请权限的方法就算编写完成了，在应用入口，即EntryAbility.ts文件中的

onCreate（want: Want, launchParam: AbilityConstant.LaunchParam）

方法中回调权限申请函数：

requestPermissionFromUser(this.context, PERMISSIONS)

其中，PERMISSIONS定义如下：

const PERMISSIONS:Array<Permissions>=['ohos.permission.DISTRIBUTED_DATASYNC']

到此，我们的权限申请就算完完全全完成啦，当用户第一次安装并打开应用的时候，应用会向用户通过弹窗形式申请权限，用户点击授权即可赋予应用相应的权限啦~

 

06、上手分布式数据对象代码开发

登录了同一华为帐号的HarmonyOS设备已经默认了进行了组网认证，所以在进行分布式数据对象开发之前无需再进行多设备组网认证这一阶段的开发，开发变得相对简单了起来。首先，咱们制作一个简易UI界面（UI界面仅供参考），如下图所示：

 

相信对于有HarmonyOS开发经验的小伙伴们来说这样的UI界面制作并不困难，其中红色圆点、绿色圆点为设备状态，当设备状态发生改变如下线时，颜色变为红色,UI界面代码如下：

import router from '@ohos.router'
import { DistributedDeviceManageFunc } from '../modules/DistributedDeviceManager/DistributedDeviceManagerFunctions'
import DistributedObjectFunc from '../modules/DistributedObject/DistributedObjectFunctions'
import { ContinuationDeviceManagerDialog } from '../view/ContinuationDeviceManagerDialog'
import { DistributedDeviceManagerDialog } from '../view/DistributedDeviceManagerDialog'


AppStorage.SetOrCreate('distributedDeviceList', [])
AppStorage.SetOrCreate('message', '分布式数据对象Demo测试')
AppStorage.SetOrCreate('statusColor', '#ff4fc100')
AppStorage.SetOrCreate('distributedColor', '#ffff0000')


@Entry
@Component
struct DistributedObjectDemo {
  @StorageLink('message') message: string = ''
  @StorageLink('statusColor') statusColor: string = ''
  @StorageLink('distributedColor') distributedColor: string = ''
  @StorageLink('distributedObj') distributedObj: DistributedObjectFunc = new DistributedObjectFunc()


  @Builder
  navigationTitle() {
    Row({ space: '10vp' }) {
      Button({ type: ButtonType.Normal }) {
        Image($rawfile('ic_public_back.svg'))
          .size({
            width: '24vp',
            height: '24vp'
          })
      }
      .width('36vp')
      .height('36vp')
      .backgroundColor(Color.White)
      .borderRadius('10vp')
      .onClick(() => {
        DistributedDeviceManageFunc.release()
        router.back()
      })


      Text('分布式数据对象测试')
        .fontWeight(FontWeight.Bold)
        .fontSize('20vp')
      Blank()
      Button({ type: ButtonType.Normal }) {
        Image($rawfile('ic_public_connection_filled.svg'))
          .size({
            width: '24vp',
            height: '24vp'
          })
      }
      .width('36vp')
      .height('36vp')
      .backgroundColor(Color.White)
      .borderRadius('10vp')
      .onClick(() => {
        this.distributedDeviceManagerDialogController.open()
      })
    }
    .padding('5vp')
    .width('90%')
  }


  build() {
    Navigation() {
      Column({ space: '20vp' }) {
        Row({ space: '20vp' }) {
          Text(`设备状态`)
            .fontSize('20vp')
            .fontWeight(FontWeight.Bold)
          Circle()
            .width('25vp')
            .height('25vp')
            .fill(this.statusColor)
        }


        Row({ space: '20vp' }) {
          Text(`对端设备状态`)
            .fontSize('20vp')
            .fontWeight(FontWeight.Bold)
          Circle()
            .width('25vp')
            .height('25vp')
            .fill(this.distributedColor)
        }


        Text(`SessionID：${this.distributedObj.getSessionId()}`)
          .fontSize('20vp')
          .fontWeight(FontWeight.Bold)
        Text(this.message)
          .fontSize('20vp')
          .fontWeight(FontWeight.Bold)
          .maxLines(2)
        Button('保存分布式数据对象')
          .buttonStyles()
          .onClick(() => {
            this.distributedObj.saveDistributedObject()
          })
        Button('修改分布式数据对象')
          .buttonStyles()
          .onClick(() => {
            this.distributedObj.updateDistributedObject()
          })
        Button('退出组网')
          .buttonStyles()
          .onClick(() => {
            this.distributedObj.exit()
            router.back()
          })
      }
      .width('100%')
    }
    .width('100%')
    .height('100%')
    .mode(NavigationMode.Auto)
    .titleMode(NavigationTitleMode.Mini)
    .hideBackButton(true)
    .title(this.navigationTitle())
  }
}


@Extend(Button) function buttonStyles() {
  .fontSize('20vp')
  .width('60%')
  .height('50vp')
}

　　

现在，我们的页面制作就完成啦，下面开始重头戏——分布式数据对象开发流程

1、导入模块

 

import distributedObject from '@ohos.data.distributedDataObject'

　　

2、初始化distributedObject. DataObject对象

定义一个distributedObject. DataObject类型的变量。

mDistributedObject: distributedObject.DataObject

　　

调用distributedObject. Create()函数创建一个distributedObject. DataObject对象，并将其返回给定义的变量mDistributedObject。

 

this.mDistributedObject = distributedObject.create(globalThis.context, {
  name: 'jack',
  age: 18,
  isVis: false
})

　　

在create()方法中存在两个参数，context和resource，context的类型为Context，resource类型为object，在这里我是在entryAbility.ts文件下的onWindowStageCreate()方法里面定义了一个全局变量globalThis.context。

globalThis.context = this.context

　　

3、设置组网sessionId

 

this.mDistributedObject.setSessionId(this.mSessionId)

　　

在setSessionId()函数中，参数sessionId为string类型，表示分布式对象组网唯一标识符，设置同步的sessionId，当可信组网中有多个设备时，多个设备间的对象如果设置为同一个sessionId，就能自动同步。

4、开启设备状态监听

 

globalThis.statusCallback = (sessionId: string, networkId: string, status: string) => {
  AppStorage.Set('message', `组网设备状况变更，id：${sessionId} status:${status} networkId:${networkId}`)
  if (status == 'online') {
    AppStorage.Set('distributedColor', '#ff4fc100')
  } else if (status == 'offline') {
    AppStorage.Set('distributedColor', '#ffff0000')
  }
}
this.mDistributedObject.on("status", globalThis.statusCallback)

　　

（sessionId: string, networkId: string, status: string）为callback回调函数返回的值，我们可以使用这些返回值判断设备上下线状态，其中status参数返回值为online或者offline，表示设备对端设备上下线。

5、开启分布式数据对象同步监听

 

globalThis.changeCallback = (sessionId: string, fields: Array<string>) => {
  console.info('分布式数据对象发生变化')
  if (fields != null && fields != undefined) {
    AppStorage.Set('message', `data change:${fields} sessionId:${sessionId}`)
  }
}
this.mDistributedObject.on("change", globalThis.changeCallback)

　　

当同一组网内分布式数据对象发生改变时，同一组网中的所有分布式数据对象同步发生变化，变化后的值为某一分布式数据对象改变后的值(sessionId: string, fields: Array<string>)为callback回调函数返回值，其中，sessionId为组网唯一标识符，field为分布式数据对象的数据变更列表。

此时此刻，分布式数据对象就基本上开发完成啦。

如果有小伙伴想要修改分布式数据对象的属性，可以直接修改

 

// @ts-ignore
this.mDistributedObject.name = 'lucy'
// @ts-ignore
this.mDistributedObject.age = 25

　　

注意：根据当前版本IDE的编码插件情况，不能直接写this.mDistributedObject.age = 25，此时咱们需要加上// @ts-ignore就可以啦。

最后，使用完分布式数据对象后大家要记得释放资源哦（注销所有监听，退出组网sessionId，将分布式数据对象设置为空值）

 

this.mDistributedObject.off("change")
this.mDistributedObject.off("status")
this.mDistributedObject.setSessionId()
this.mDistributedObject = null
this.mSessionId = null

　　

如果有小伙伴有两部或两部以上的华为设备，可以将程序烧录到设备中，体验一下分布式数据对象能力的快乐~

标签：原生,鸿蒙,对象,sessionId,组网,权限,数据,分布式
From： https://www.cnblogs.com/HarmonyOSDev/p/17884544.html

相关文章

  • 分布式系统-负载均衡
    分布式系统中，业务系统都是集群部署，而且一般会做微服务化。那么，从一个系统rpc请求到另一个系统，应该路由到哪一台节点呢？这，就涉及到负载均衡。负载均衡的核心，便是负载均衡算法，算法有很多，主要介绍其中六种，并说一说各自算法的优缺点。1.加权随机加权随机，顾名思义，就是路由到哪一台节......
  • 『江鸟中原』深入探索鸿蒙ArkTS：高效安全的跨语言开发体验
    随着鸿蒙操作系统的快速发展，跨语言开发成为了开发者们关注的焦点之一。鸿蒙ArkTS作为鸿蒙操作系统的重要组成部分，为开发者提供了一种高效、安全的跨语言开发体验。本文将深入探索鸿蒙ArkTS的语法，并通过实例代码演示其强大的功能和灵活性。ArkTS简介鸿蒙ArkTS是一种基于TypeScript......
  • 分布式资源调度框架YARN
    1、YARN=YetAnotherResourceNegotiator2、主从架构，一主多从3、主=ResourceManager,从=NodeManager4、ResourceManager由ApplicationManager和ResourceScheduler组成5、NodeManager的核心组件包括ApplicationMaster和Container6、工作流程分为五个阶段：（1）作业提交阶段（2）作业初始化......
  • redis分布式锁实现原理
    在.netcore中，可以使用StackExchange.Redis实现redis分布式锁，///<summary>///分布式锁///</summary>///<paramname="Redis">RedisDB</param>///<paramname="Key">锁标识</param>///<paramname="Seconds">过......
  • 实战最新鸿蒙系统的短视频App：教你一步步掌握HarmonyOS的几个要点
    鸿蒙（HarmonyOS）是华为公司推出的全场景分布式操作系统，具备高效、安全和灵活的特性。本文将分享如何实战鸿蒙系统的智能家居控制App，并教你一步步掌握HarmonyOS的关键要点，并提供相关示例代码。一、了解HarmonyOS的核心概念在实战HarmonyOS智能家居控制App之前，首先需要了解HarmonyOS的......
  • 分布式事务-Seata解决方案
    一、定义   Seata解决方案是分布式事务解决方案之一。常用的分布式事务解决方案有：2PC,3PC,TCC,SAGA(seata)、本地消息表、MQ消息事务、最大努力通知。   Seata是一款分布式解决方案，致力于提供高性能和简单易用的分布式事务服务。提供事务模式有：AT,TCC,SAGA,XA。其中......
  • 分布式主键
     核心概念::ShardingSpherehttps://shardingsphere.apache.org/document/current/cn/features/sharding/concept/ 分布式主键传统数据库软件开发中，主键自动生成技术是基本需求。而各个数据库对于该需求也提供了相应的支持，比如MySQL的自增键，Oracle的自增序列等。数据......
  • 技术分享丨 Prisma Cloud 增强云原生代码保护能力！
    现如今，企业业务向云计算转变已是主流，组织收到威胁、运营中断、威胁形势也持续升级，网络安全转型已变成当今企业的当务之急。Palo Alto PrismaCloud具有业界最广泛的安全性和合规性覆盖范围，它保护跨平台的云原生应用程序、数据、网络、计算、存储、用户和更高级别的PaaS+SaaS服务......
  • Zookeeper——分布式一致性协议及Leader选举原理
    一、引言随着业务的增长，单体架构发展为分布式架构，大大提升了业务的处理能力，但同时也带来了很多单体架构不存在的问题，如：各节点之间网络通信的异常以及因其引起的脑裂问题（网络分区）。引出“三态”。在单体架构中只会存在“成功”或“失败”两种结果，但是在分布式架构中由于网络异......
  • 鸿蒙开发丨设备内UIAbility的几种交互方式
    本文分享自华为云社区《设备内UIAbility交互：无缝体验与高级技巧》，作者：柠檬味拥抱。UIAbility组件间交互（设备内）在设备内，UIAbility（用户界面能力）是系统调度的最小单元，它们负责展示用户界面和执行相关的业务逻辑。设备内的不同功能模块之间的交互是应用程序开发中的重要部分。本文......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99