介紹

分布式數據服務(Distributed Data Service，DDS)為應用程序提供不同設備間數據分布式的能力。通過調用分布式數據接口，應用程序將數據保存到分布式數據庫中。通過結合帳號、應用和分布式數據服務對屬于不同的應用的數據進行隔離，保證不同應用之間的數據不能通過分布式數據服務互相訪問。在通過可信認證的設備間，分布式數據服務支持應用數據相互同步，為用戶提供在多種終端設備上一致的數據訪問體驗。效果圖如下：

圖 1 []()

搭建OpenHarmony環(huán)境

完成本篇Codelab我們首先要完成開發(fā)環(huán)境的搭建，本示例以Hi3516DV300開發(fā)板為例，參照以下步驟進行：

1. [獲取OpenHarmony系統(tǒng)版本]：標準系統(tǒng)解決方案（二進制）
   以3.0版本為例：
   
2. 搭建燒錄環(huán)境
   1. [完成DevEco Device Tool的安裝]
   2. [完成Hi3516開發(fā)板的燒錄]
   3. 鴻蒙開發(fā)指導參考：[gitee.com/li-shizhen-skin/harmony-os/blob/master/README.md](
3. 搭建開發(fā)環(huán)境
   1. 開始前請參考[工具準備]，完成DevEco Studio的安裝和開發(fā)環(huán)境配置。
   2. 開發(fā)環(huán)境配置完成后，請參考[使用工程向導]創(chuàng)建工程（模板選擇“Empty Ability”），選擇JS或者eTS語言開發(fā)。
   3. 工程創(chuàng)建完成后，選擇使用[真機進行調測]。

代碼結構解讀

本篇Codelab只對核心代碼進行講解，對于完整代碼，我們會在最后的參考中提供下載方式，接下來我們來講解整個工程的代碼結構：

• pages：用于存放所有頁面的目錄。
  • index：構成關系型數據庫操作界面，包括index.hml布局文件，index.css樣式文件，index.js邏輯處理文件。
  • KvStoreModel.js：創(chuàng)建分布式數據庫，以及提供表格數據的增、刪、改、查API接口。
• config.json：配置文件。

分布式組網

1. 硬件準備：準備兩臺燒錄相同的版本系統(tǒng)的Hi3516DV300開發(fā)板A，B。

2. 兩個開發(fā)板A，B配置在同一個WiFi網絡之下。
   打開設置-->WLAN-->點擊右側WiFi開關-->點擊目標WiFi并輸入密碼。
   

3. 將設備A，B設置為互相信任的設備。

   • 找到系統(tǒng)應用“音樂”。

   

   • 設備A打開音樂，點擊左下角流轉按鈕，彈出列表框，在列表中會展示遠端設備的id。
     
   • 選擇遠端設備B的id，另一臺開發(fā)板（設備B）會彈出驗證的選項框。
     
   • 設備B點擊允許，設備B將會彈出隨機PIN碼，將設備B的PIN碼輸入到設備A的PIN碼填入框中。

   
   配網完畢。

創(chuàng)建分布式數據庫

1. 導入模塊

   import distributedData from '@ohos.data.distributeddata';
   

2. 參考分布式數據庫[接口]，在kvStoreModel類中定義KvManager和KvStore變量，并通過createKVManager創(chuàng)建分布式數據庫管理對象KvManager，通過getKVStore獲取數據庫操作實例KvStore。其中config表示創(chuàng)建KVManager實例的配置信息，包括調用方的包名和用戶信息。options表示創(chuàng)建 KvStore實例的配置信息。表示示例代碼如下：

export default class KvStoreModel {
    kvManager;
    kvStore;
    constructor() {
    }
    createKvStore(callback) {
      if (typeof (this.kvStore) === 'undefined') {
        //創(chuàng)建KVManager實例的配置信息
        var config = {
          bundleName: 'com.ohos.distributedmusicplayer',
          userInfo: {
            userId: '0',
            userType: 0
          }
        };
        let self = this;
        distributedData.createKVManager(config).then((manager) = > {
          self.kvManager = manager;
          //創(chuàng)建 KvStore實例的配置信息
          var options = {
            createIfMissing: true,
            encrypt: false,
            backup: false,
            autoSync: true,
            kvStoreType: 1,
            schema: '',
            securityLevel: 3,
          };
          self.kvManager.getKVStore(STORE_ID, options).then((store) = > {
            self.kvStore = store;
            callback();
          });
        });
      } else {
        callback();
      }
    }
}

操作分布式數據方法

創(chuàng)建分布式數據庫后，獲得一個KvStore，通過KvStore調用相關接口執(zhí)行相關的數據操作，結果以Promise形式返回。

• 添加鍵值對到數據庫：使用put()方法，該方法接收兩個參數，分別是要添加的數值Key和要添加的數值。示例代碼如下：

  put(key, value) {
    this.kvStore.put(key, value).then((data) = > {
  	this.kvStore.get(key).then((data) = > {
  	});
    }).catch((err) = > {
    });
  }
  

• 數據庫中刪除指定鍵值對的數據：使用delete()方法，該方法接收一個參數，需要刪除數據的鍵值key，結果以Promise形式返回。示例代碼如下：

  delete(key) {
    this.kvStore.delete(key).then((data) = > {
    }).catch((err) = > {
    });
  }
  

• 數據庫中獲取指定鍵值對的數據：使用get()方法，該方法接收兩個參數，分別是需要獲取數據的鍵值key和返回函數callback,結果以callback函數形式返回。示例代碼如下：

  get(key,callback){
    this.kvStore.get(key).then((data) = > {
         callback(data);
    });
  }
  

同步分布式數據庫

通常情況下，當數據庫的數據產生變化時，需要主動通知與該數據相關聯(lián)的進程或者應用，從而使得相關進程或者應用接收到數據變化后完成相應的處理。對于數據提供方，當數據庫數據變化，可以通過如下方法通知數據訂閱者：

broadcastMessage(key, value) {
  let self = this;
  this.createKvStore(() = > {
	self.put(key, value);//self.delete(key)新增或者刪除數據都可導致數據變化
  });
}

對于數據接收方，可以通過KvStore提供的[on]方法注冊一個數據訂閱者。示例代碼如下：

setOnMessageReceivedListener(callback) {
  let self = this;
  this.createKvStore(() = > {
	self.kvStore.on('dataChange', 1, (data) = > {
	  for (var i = 0; i < data.insertEntries.length; i++) {
		callback(data.insertEntries[0].key, data.insertEntries[0].value.value, 0);
		return;
	  }
	  for (i = 0; i < data.updateEntries.length; i++) {
		callback(data.updateEntries[0].key, data.updateEntries[0].value.value, 1);
		return;
	  }
	  for (i = 0; i < data.deleteEntries.length; i++) {
		callback(data.deleteEntries[0].key, '', 2);
		return;
	  }
	});
  });
}

審核編輯 黃宇