场景介绍

分布式数据服务主要实现对用户设备中应用程序的数据内容的分布式同步。当设备 1 上的应用 A 在分布式数据库中增、删、改数据后，设备2上的应用 A 也可以获取到该数据库变化。可在分布式图库、信息、通讯录、文件管理器等场景中使用。

接口说明

HarmonyOS 系统中的分布式数据服务模块为开发者提供下面几种功能：

开发步骤

以单版本分布式数据库为例，说明开发步骤。

1. 根据配置构造分布式数据库管理类实例。

1. 根据应用上下文创建 KvManagerConfig 对象。
2. 创建分布式数据库管理器实例。

以下为创建分布式数据库管理器的代码示例：

   Context context;
   ...
   KvManagerConfig config = new KvManagerConfig(context);
   KvManager kvManager = KvManagerFactory.getInstance().createKvManager(config);

1. 获取/创建单版本分布式数据库。

1. 声明需要创建的单版本分布式数据库 ID 描述。
2. 创建单版本分布式数据库。

以下为创建单版本分布式数据库的代码示例：

   Options CREATE = new Options();

    
   CREATE.setCreateIfMissing(true).setEncrypt(false).setKvStoreType(KvStoreType.SINGLE_VERSION);
   String storeID = "testApp";
   SingleKvStore singleKvStore = kvManager.getKvStore(CREATE, storeID);

1. 订阅分布式数据变化。

\1. 客户端需要实现KvStoreObserver接口。

\2. 构造并注册KvStoreObserver实例。

以下为订阅单版本分布式数据库所有（本地及远端）数据变化通知的代码示例：

   class KvStoreObserverClient implements KvStoreObserver() {
       @Override
       public void onChange(ChangeNotification notification) {
           List<Entry> insertEntries = notification.getInsertEntries();
           List<Entry> updateEntries = notification.getUpdateEntries();
           List<Entry> deleteEntries = notification.getDeleteEntries();
       }
   }

    
   KvStoreObserver kvStoreObserverClient = new KvStoreObserverClient();
   singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, kvStoreObserverClient);

1. 将数据写入单版本分布式数据库。

1. 构造需要写入单版本分布式数据库的 Key (键)和 Value (值)。
2. 将键值数据写入单版本分布式数据库。

以下为将字符串类型键值数据写入单版本分布式数据库的代码示例：

   String key = "todayWeather";
   String value = "Sunny";
   singleKvStore.putString(key, value);

1. 查询单版本分布式数据库数据。

1. 构造需要从单版本分布式数据库快照中查询的 Key(键)。
2. 从单版本分布式数据库快照中获取数据。

以下为从单版本分布式数据库中查询字符串类型数据的代码示例：

   String key = "todayWeather";String value = singleKvStore.getString(key);

1. 同步数据到其他设备。

\1. 获取已连接的设备列表。

\2. 选择同步方式进行数据同步。

以下为单版本分布式数据库进行数据同步的代码示例，其中同步方式为 PUSH_ONLY：

   List<DeviceInfo> deviceInfoList = kvManager.getConnectedDevicesInfo(DeviceFilterStrategy.NO_FILTER);
   List<String> deviceIdList = new ArrayList<>();
   for (DeviceInfo deviceInfo : deviceInfoList) {
       deviceIdList.add(deviceInfo.getId());
   }
   singleKvStore.sync(deviceIdList, SyncMode.PUSH_ONLY);

1. 关闭单版本分布式数据库。以下为关闭单版本分布式数据库的代码示例：

   kvManager.closeKvStore(singleKvStore);

1. 删除单版本分布式数据库。以下为删除单版本分布式数据库的代码示例：

   kvManager.deleteKvStore(storeID);