介紹

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

圖 1 []()

搭建OpenHarmony環(huán)境

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

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

搜狗高速瀏覽器截圖20240326151450.png

代碼結構解讀

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

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

分布式組網(wǎng)

硬件準備：準備兩臺燒錄相同的版本系統(tǒng)的Hi3516DV300開發(fā)板A，B。
兩個開發(fā)板A，B配置在同一個WiFi網(wǎng)絡之下。
打開設置-->WLAN-->點擊右側(cè)WiFi開關-->點擊目標WiFi并輸入密碼。
將設備A，B設置為互相信任的設備。
- 找到系統(tǒng)應用“音樂”。
- 設備A打開音樂，點擊左下角流轉(zhuǎn)按鈕，彈出列表框，在列表中會展示遠端設備的id。
- 選擇遠端設備B的id，另一臺開發(fā)板（設備B）會彈出驗證的選項框。
- 設備B點擊允許，設備B將會彈出隨機PIN碼，將設備B的PIN碼輸入到設備A的PIN碼填入框中。
配網(wǎng)完畢。

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

導入模塊

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

參考分布式數(shù)據(jù)庫[接口]，在kvStoreModel類中定義KvManager和KvStore變量，并通過createKVManager創(chuàng)建分布式數(shù)據(jù)庫管理對象KvManager，通過getKVStore獲取數(shù)據(jù)庫操作實例KvStore。其中config表示創(chuàng)建KVManager實例的配置信息，包括調(diào)用方的包名和用戶信息。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();
      }
    }
}

操作分布式數(shù)據(jù)方法

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

添加鍵值對到數(shù)據(jù)庫：使用put()方法，該方法接收兩個參數(shù)，分別是要添加的數(shù)值Key和要添加的數(shù)值。示例代碼如下：
```
put(key, value) {
  this.kvStore.put(key, value).then((data) = > {
	this.kvStore.get(key).then((data) = > {
	});
  }).catch((err) = > {
  });
}
```
數(shù)據(jù)庫中刪除指定鍵值對的數(shù)據(jù)：使用delete()方法，該方法接收一個參數(shù)，需要刪除數(shù)據(jù)的鍵值key，結果以Promise形式返回。示例代碼如下：
```
delete(key) {
  this.kvStore.delete(key).then((data) = > {
  }).catch((err) = > {
  });
}
```
數(shù)據(jù)庫中獲取指定鍵值對的數(shù)據(jù)：使用get()方法，該方法接收兩個參數(shù)，分別是需要獲取數(shù)據(jù)的鍵值key和返回函數(shù)callback,結果以callback函數(shù)形式返回。示例代碼如下：
```
get(key,callback){
  this.kvStore.get(key).then((data) = > {
       callback(data);
  });
}
```

同步分布式數(shù)據(jù)庫

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

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

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

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;
	  }
	});
  });
}