轻松玩转HarmonyOS分布式应用开发——分布式通讯录

一、背景996的工作压力巨大，大家为了更好地隔离工作和生活，已经不满足于一机两号，而是直接进行两机两号的物理隔离。工作的通讯录不想放在生活手机上，但有时确实需要在生活机上查看，这时候使用云同步不大合适，而本应用恰巧能够满足该使用场景。用户在工作机和生活机上都安装该应用，并在工作机上通过按钮将本地通讯簿读取出来后，存入分布式数据库中，并通过分布式协同操作拉起生活机上的相同应用进行展示。二、代码实现本

kiba_zwei

1772人浏览 · 2021-11-30 22:27:30

kiba_zwei · 2021-11-30 22:27:30 发布

一、背景

996的工作压力巨大，大家为了更好地隔离工作和生活，已经不满足于一机两号，而是直接进行两机两号的物理隔离。

工作的通讯录不想放在生活手机上，但有时确实需要在生活机上查看，这时候使用云同步不大合适，而本应用恰巧能够满足该使用场景。

用户在工作机和生活机上都安装该应用，并在工作机上通过按钮将本地通讯簿读取出来后，存入分布式数据库中，并通过分布式协同操作拉起生活机上的相同应用进行展示。

二、代码实现

本应用主要功能是由本地读取通讯簿，通过分布式数据库传递给远端设备并拉起远端应用展示，从而达到在远端看到数据的效果。

读取联系人

鸿蒙的联系人操作方式要比Android的友好多的多，完全面向对象，屏蔽了那些复杂的表结构，不用时刻想着操作后就要commit，否则不生效。也不用随时随地握这一个_id增删改查，鸿蒙的开发小哥哥们都帮我们把这些事在底层搞定了，所以在鸿蒙系统上使用的十分顺滑。

鸿蒙的联系人操作的核心在于ContactsHelper这个类，通过构造不同的联系人特性来对联系人的不同属性进行查看、插入、修改与删除，具体代码如下。

	private List<Contact> readContacts() {
        ContactsHelper contactsHelper = new ContactsHelper(getContext());
        ContactAttributes contactAttributes = new ContactAttributes();
        contactAttributes.add(ContactAttributes.Attribute.ATTR_NAME);
        contactAttributes.add(ContactAttributes.Attribute.ATTR_PHONE);
        ContactsCollection contactsCollection = contactsHelper.queryContacts(null, contactAttributes);
        Contact contact = contactsCollection.next();
        List<Contact> contacts = new ArrayList<>();
        StringBuilder datas = new StringBuilder();
        String device = KvManagerFactory.getInstance()
                .createKvManager(new KvManagerConfig(getContext()))
                .getLocalDeviceInfo().getName();
        while (contact != null) {
            contacts.add(contact);
            LogUtil.info(TAG, contact.getName().getFullName());
            String name = contact.getName().getFullName();
            String num = contact.getPhoneNumbers() == null ? "" : contact.getPhoneNumbers().get(0).getPhoneNumber();
            StringBuilder sb = new StringBuilder();
            sb.append(name).append(SEPARATOR).append(num).append(SEPARATOR).append(device);
            mContactList.add(new ContactItemViewHolder(name, num, device));
            contact = contactsCollection.next();
            datas.append(sb.toString()).append(SEPARATOR_DATA);
        }
        singleKvStore.putString(CONSTACTS_KEY, datas.toString());
        return contacts;
    }

读取对端联系人

    private void readRemoteContacts() {
        String remoteData = singleKvStore.getString(CONSTACTS_KEY);
        LogUtil.info(TAG, "remote data:" + remoteData);
        String[] datas = remoteData.split(SEPARATOR_DATA);
        for (String data : datas) {
            String[] params = data.split(SEPARATOR);
            mContactList.add(new ContactItemViewHolder(params[0], params[1], params[2]));
        }
    }

分布式操作

本应用主要使用SingleKvStore分布式数据库功能传递联系人信息，由本端存入，再拉起对端，由对端显示。
该部分代码主要参考Codelab的demo，套用了其中分布式的范式代码，具体实现可以见工程代码。

权限管理

权限声明

"reqPermissions": [
      {
        "reason": "多设备协同",
        "name": "ohos.permission.DISTRIBUTED_DATASYNC",
        "usedScene": {
          "ability": [
            "com.xlab.xlabtestapp.slice.MainAbilitySlice"
          ],
          "when": "always"
        }
      },
      {
        "name": "ohos.permission.READ_CONTACTS",
        "reason": "需要联系人权限",
        "usedScene": {
          "ability": [
            "com.xlab.xlabtestapp.slice.MainAbilitySlice"
          ],
          "when": "always"
        }
      },
      {
        "name": "ohos.permission.WRITE_CONTACTS",
        "reason": "需要联系人权限",
        "usedScene": {
          "ability": [
            "com.xlab.xlabtestapp.slice.MainAbilitySlice"
          ],
          "when": "always"
        }
      }
    ]

动态请求

鸿蒙中高危权限需要动态请求，并且第一次新增时，还要求进行重新签名。

    private void requestPermissions() {
        String[] permissions = {
                SystemPermission.READ_CONTACTS, SystemPermission.WRITE_CONTACTS, SystemPermission.DISTRIBUTED_DATASYNC
        };
        List<String> permissionsToProcess = new ArrayList<>();
        for (String permission : permissions) {
            if (verifySelfPermission(permission) != IBundleManager.PERMISSION_GRANTED
                    && canRequestPermission(permission)) {
                permissionsToProcess.add(permission);
            }
        }
        requestPermissionsFromUser(permissionsToProcess.toArray(new String[0]), 0);
    }