自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

HarmonyOS基礎技術賦能之分布式數(shù)據(jù)服務功能

作者：軟通張二龍
開發(fā) 前端 分布式 OpenHarmony
分布式數(shù)據(jù)服務(Distributed Data Service，DDS) 為應用程序提供不同設備間數(shù)據(jù)庫數(shù)據(jù)分布式的能力。通過調用分布式數(shù)據(jù)接口，應用程序將數(shù)據(jù)保存到分布式數(shù)據(jù)庫中。

[[419727]]

想了解更多內容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術社區(qū)

https://harmonyos.51cto.com

引言

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

功能介紹

此次通過HarmonyOS的分布式數(shù)據(jù)服務能力，一方面可以實現(xiàn)自身應用界面的數(shù)據(jù)實時更新;另一方面也可以實現(xiàn)不同設備之間的數(shù)據(jù)實時更新。前提是在不同設備之間，要實現(xiàn)分布式數(shù)據(jù)服務的同步能力，需要同一個華為賬號登錄、并一個應用包名、同一個網(wǎng)絡之間進行，也可以兩個設備同時開啟藍牙。

開發(fā)指南

1. 在config.json中添加permisssion權限。

  1. // 添加在abilities同一目錄層級 
  2. "reqPermissions": [ 
  3.     { 
  4.         "name": "ohos.permission.DISTRIBUTED_DATASYNC" 
  5.     } 
  6. ] 

2. 在MainAbility中添加權限

  1. @Override 
  2. public void onStart(Intent intent) { 
  3.   super.onStart(intent); 
  4.   super.setMainRoute(MainAbilitySlice.class.getName()); 
  5.   //實現(xiàn)Ability的代碼中顯式聲明需要使用多設備協(xié)同訪問的權限 
  6.   requestPermissionsFromUser(new String[]{ 
  7.       "ohos.permission.DISTRIBUTED_DATASYNC"}, 0); 
  8.  
  9. } 

3. 根據(jù)配置構造分布式數(shù)據(jù)庫管理類實例KvManager以及創(chuàng)建分布式數(shù)據(jù)庫對象SingleKvStore。

  1. //實現(xiàn)數(shù)據(jù)庫的初始化 
  2. // 初入的參數(shù)context: Context context = getApplicationContext()獲得；storeId為分布式數(shù)據(jù)庫id,String類型，可自行定義，例如“testApp”。 
  3. public static SingleKvStore initOrGetDB(Context context, String storeId) { 
  4.   KvManagerConfig kvManagerConfig = new KvManagerConfig(context); 
  5.   kvManager = KvManagerFactory.getInstance().createKvManager(kvManagerConfig); 
  6.   Options options = new Options(); 
  7.   options.setCreateIfMissing(true) 
  8.     .setEncrypt(false) 
  9.     .setKvStoreType(KvStoreType.SINGLE_VERSION) //數(shù)據(jù)庫類型：單版本分布式數(shù)據(jù)庫 
  10.     .setAutoSync(true);//設置數(shù)據(jù)為自動同步 
  11.   singleKvStore = kvManager.getKvStore(options, storeId); 
  12.   return singleKvStore; 
  13. } 

4. 將數(shù)據(jù)寫入單版本分布式數(shù)據(jù)庫。

  1. //以key-value形式存儲到分布式數(shù)據(jù)庫 
  2. try { 
  3.   long id = System.currentTimeMillis(); 
  4.   singleKvStore.putString("key", 
  5.       "{\"id\":" + id + 
  6.           ",\"temp\":" + temperature + 
  7.           ",\"humidity\":" + humidity + 
  8.           ",\"NH4\":" + 0.0 + 
  9.           ",\"H2S\":" + 0.0 + 
  10.           ",\"other\":" + gas + "}"); 
  11. } catch (KvStoreException e) { 
  12.   e.printStackTrace(); 
  13. } 

5.訂閱分布式數(shù)據(jù)變化?？蛻舳诵枰獙崿F(xiàn)KvStoreObserver接口，監(jiān)聽數(shù)據(jù)變化。

  1. try { 
  2. //訂閱類型SubscribeType.SUBSCRIBE_TYPE_ALL意思可以同步到本機和其他外圍設備 
  3.   innerKvStoreObserver = new InnerKvStoreObserver(); 
  4.   singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, innerKvStoreObserver); 
  5. } catch (KvStoreException e) { 
  6.   e.printStackTrace(); 
  7. } 
  8.  
  9. public class InnerKvStoreObserver implements KvStoreObserver { 
  10.  
  11.   @Override 
  12.   public void onChange(ChangeNotification changeNotification) { 
  13.     //刷新頁面上的數(shù)據(jù)，同樣有一個坑，onChange方法實質上，在一個子線程里執(zhí)行 
  14.     MainAbilitySlice.taskDispatcher.asyncDispatch(() -> { 
  15.       //在這里執(zhí)行頁面ui組件的顯示刷新 
  16.       flushUIData(); 
  17.     }); 
  18.   } 
  19. } 

6.獲取分布式數(shù)據(jù)庫數(shù)據(jù)

  1. private void flushUIData() { 
  2.   //查詢分布式數(shù)據(jù)的數(shù)據(jù)，獲取數(shù)據(jù)可以通過get（String key）/ getEntries(String key)方法獲取數(shù)據(jù) 
  3.   List<Entry> entries = singleKvStore.getEntries(“key”); 
  4.   if (entries.size() > 0) { 
  5.     ZSONObject zsonObject = ZSONObject.stringToZSON(entries.get(0).getValue().getString()); 
  6.     int temp = zsonObject.getIntValue("temp"); 
  7.     int humidity = zsonObject.getIntValue("humidity"); 
  8.     int other = zsonObject.getIntValue("other"); 
  9.     tvTemp.setText(temp+"℃"); 
  10.     tvHumi.setText(humidity+"% RH"); 
  11.     tvGas.setText(other+"% LEL"); 
  12.   } 

7. 解除訂閱。一般在頁面銷毀時調用，也就是MainAbilitySlice的onStop()中調用

  1. if (singleKvStore != null) { 
  2.   singleKvStore.unSubscribe(innerKvStoreObserver); 
  3. } 

8. 同步數(shù)據(jù)到其他設備。獲取已連接的設備列表，選擇同步方式進行數(shù)據(jù)同步

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

項目中采用在后臺service中開啟定時任務，實時保存數(shù)據(jù)到分布式數(shù)據(jù)庫，然后在主界面，監(jiān)聽數(shù)據(jù)變化，實時更新數(shù)據(jù)。

結果演示

1.剛開始安裝完成后效果：

HarmonyOS基礎技術賦能之分布式數(shù)據(jù)服務功能-鴻蒙HarmonyOS技術社區(qū)

2.每隔3秒，界面數(shù)據(jù)都會發(fā)生變化：

HarmonyOS基礎技術賦能之分布式數(shù)據(jù)服務功能-鴻蒙HarmonyOS技術社區(qū)
HarmonyOS基礎技術賦能之分布式數(shù)據(jù)服務功能-鴻蒙HarmonyOS技術社區(qū)

附上源碼：

1.MainAbilitySlice

  1. public class MainAbilitySlice extends AbilitySlice { 
  2.   private SingleKvStore singleKvStore; 
  3.   private Text tvTemp; 
  4.   private Text tvHumi; 
  5.   private Text tvGas; 
  6.   private Intent serviceIntent; 
  7.   private InnerKvStoreObserver innerKvStoreObserver; 
  8.  
  9.   @Override 
  10.   public void onStart(Intent intent) { 
  11.     super.onStart(intent); 
  12.     super.setUIContent(ResourceTable.Layout_ability_main); 
  13.     tvTemp=(Text)findComponentById(ResourceTable.Id_tvTemp); 
  14.     tvHumi=(Text)findComponentById(ResourceTable.Id_tvHumi); 
  15.     tvGas=(Text)findComponentById(ResourceTable.Id_tvGas); 
  16.     initService(); 
  17.  
  18.     try { 
  19.       //獲取數(shù)據(jù)庫 
  20.       singleKvStore = DBUtils.initOrGetDB(this, DBUtils.STORE_ID); 
  21.       innerKvStoreObserver = new InnerKvStoreObserver(); 
  22.       singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, innerKvStoreObserver); 
  23.     } catch (KvStoreException e) { 
  24.       e.printStackTrace(); 
  25.     } 
  26.   } 
  27.  
  28.   public class InnerKvStoreObserver implements KvStoreObserver { 
  29.  
  30.     @Override 
  31.     public void onChange(ChangeNotification changeNotification) { 
  32.       //刷新頁面上的數(shù)據(jù)，同樣有一個坑，onChange方法實質上，在一個子線程里執(zhí)行 
  33.       getUITaskDispatcher().asyncDispatch(() -> { 
  34.         //在這里執(zhí)行頁面ui組件的顯示刷新 
  35.         flushUIData(); 
  36.       }); 
  37.     } 
  38.   } 
  39.  
  40.   private void flushUIData() { 
  41.     //查詢分布式數(shù)據(jù)的數(shù)據(jù) 
  42.     List<Entry> entries = singleKvStore.getEntries("key"); 
  43.     if (entries.size() > 0) { 
  44.       ZSONObject zsonObject = ZSONObject.stringToZSON(entries.get(0).getValue().getString()); 
  45.       int temp = zsonObject.getIntValue("temp"); 
  46.       int humidity = zsonObject.getIntValue("humidity"); 
  47.       int other = zsonObject.getIntValue("other"); 
  48.       tvTemp.setText(temp+"℃"); 
  49.       tvHumi.setText(humidity+"% RH"); 
  50.       tvGas.setText(other+"% LEL"); 
  51.     } 
  52.  
  53.  
  54.  
  55.   } 
  56.  
  57.   private void initService() { 
  58.     //啟動ServiceAbility 
  59.      serviceIntent = new Intent(); 
  60.     Operation operation = new Intent.OperationBuilder() 
  61.         .withDeviceId("") 
  62.         .withBundleName("com.isoftstone.kvstoreapp") 
  63.         .withAbilityName("com.isoftstone.kvstoreapp.ServiceAbility") 
  64.         .build(); 
  65.     serviceIntent.setOperation(operation); 
  66.     startAbility(serviceIntent); 
  67.   } 
  68.  
  69.   @Override 
  70.   public void onActive() { 
  71.     super.onActive(); 
  72.   } 
  73.  
  74.   @Override 
  75.   public void onForeground(Intent intent) { 
  76.     super.onForeground(intent); 
  77.   } 
  78.  
  79.   @Override 
  80.   protected void onStop() { 
  81.     super.onStop(); 
  82.     //銷毀service 
  83.    stopAbility(serviceIntent); 
  84.    //刪除數(shù)據(jù)庫 
  85.    DBUtils.clearDB(); 
  86.     //解除訂閱 
  87.     if (singleKvStore != null) { 
  88.       singleKvStore.unSubscribe(innerKvStoreObserver); 
  89.     } 
  90.   } 
  91. } 

2.ServiceAbility

  1. public class ServiceAbility extends Ability { 
  2.  
  3.   private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD001100, "Demo"); 
  4.   private SingleKvStore singleKvStore; 
  5.   private Timer timer; 
  6.   private MyTimerTask myTimerTask; 
  7.   private int temperature; 
  8.   private int humidity; 
  9.   private int gas; 
  10.  
  11.   @Override 
  12.   public void onStart(Intent intent) { 
  13.     super.onStart(intent); 
  14.     singleKvStore = DBUtils.initOrGetDB(this, DBUtils.STORE_ID); 
  15.     timer=new Timer(); 
  16.     myTimerTask=new MyTimerTask(); 
  17.     timer.schedule(myTimerTask,0,3000); 
  18.  
  19.   } 
  20.  
  21.   @Override 
  22.   public void onBackground() { 
  23.     super.onBackground(); 
  24.     HiLog.info(LABEL_LOG, "ServiceAbility::onBackground"); 
  25.   } 
  26.  
  27.   @Override 
  28.   public void onStop() { 
  29.     super.onStop(); 
  30.     if(myTimerTask!=null){ 
  31.       myTimerTask.cancel(); 
  32.     } 
  33.     if(timer!=null){ 
  34.       timer.cancel(); 
  35.     } 
  36.   } 
  37.  
  38.   @Override 
  39.   public void onCommand(Intent intent, boolean restart, int startId) { 
  40.   } 
  41.  
  42.   @Override 
  43.   public IRemoteObject onConnect(Intent intent) { 
  44.     return null; 
  45.   } 
  46.  
  47.   @Override 
  48.   public void onDisconnect(Intent intent) { 
  49.   } 
  50.  
  51.   private class MyTimerTask extends TimerTask{ 
  52.  
  53.     @Override 
  54.     public void run() { 
  55.       temperature++; 
  56.       humidity++; 
  57.       gas++; 
  58.       try { 
  59.         long id = System.currentTimeMillis(); 
  60.         singleKvStore.putString("key", 
  61.             "{\"id\":" + id + 
  62.                 ",\"temp\":" + temperature + 
  63.                 ",\"humidity\":" + humidity + 
  64.                 ",\"NH4\":" + 0.0 + 
  65.                 ",\"H2S\":" + 0.0 + 
  66.                 ",\"other\":" + gas + "}"); 
  67.       } catch (KvStoreException e) { 
  68.         e.printStackTrace(); 
  69.       } 
  70.  
  71.     } 
  72.   } 
  73. } 

3.DBUtils

  1. public class DBUtils { 
  2.   //分布式數(shù)據(jù)庫storeId 
  3.   public static final String STORE_ID="kvStoreDB"; 
  4.   private static KvManager kvManager; 
  5.   private static SingleKvStore singleKvStore; 
  6.  
  7.  
  8.   //具體的實現(xiàn)數(shù)據(jù)庫的初始化 
  9.   public static SingleKvStore initOrGetDB(Context context, String storeId) { 
  10.  
  11.     KvManagerConfig kvManagerConfig = new KvManagerConfig(context); 
  12.     kvManager = KvManagerFactory.getInstance().createKvManager(kvManagerConfig); 
  13.     Options options = new Options(); 
  14.     options.setCreateIfMissing(true) 
  15.         .setEncrypt(false) 
  16.         .setKvStoreType(KvStoreType.SINGLE_VERSION) 
  17.         .setAutoSync(true);//設置數(shù)據(jù)為自動同步 
  18.     singleKvStore = kvManager.getKvStore(options, storeId); 
  19.     return singleKvStore; 
  20.   } 
  21.  
  22.   // 如果數(shù)據(jù)庫中的字段有修改，只能先關閉，后刪除，然后重新創(chuàng)建才生效 
  23.   public static void clearDB() { 
  24.     kvManager.closeKvStore(singleKvStore); 
  25.     kvManager.deleteKvStore(STORE_ID); 
  26.   } 
  27.  
  28.  
  29. } 

4. MainAbility

  1. public class MainAbility extends Ability { 
  2.  
  3.   @Override 
  4.   public void onStart(Intent intent) { 
  5.     super.onStart(intent); 
  6.     super.setMainRoute(MainAbilitySlice.class.getName()); 
  7.     //實現(xiàn)Ability的代碼中顯式聲明需要使用多設備協(xié)同訪問的權限 
  8.     requestPermissionsFromUser(new String[]{ 
  9.         "ohos.permission.DISTRIBUTED_DATASYNC"}, 0); 
  10.   } 
  11. } 

5. MyApplication

  1. public class MyApplication extends AbilityPackage { 
  2.  
  3.   @Override 
  4.   public void onInitialize() { 
  5.     super.onInitialize(); 
  6.   } 
  7. } 

6. config.json 文件

  1. { 
  2.   "app": { 
  3.     "bundleName": "com.isoftstone.healthdata", 
  4.     "vendor": "isoftstone", 
  5.     "version": { 
  6.       "code": 1000000, 
  7.       "name": "1.0" 
  8.     }, 
  9.     "apiVersion": { 
  10.       "compatible": 4, 
  11.       "target": 5, 
  12.       "releaseType": "Release" 
  13.     } 
  14.   }, 
  15.   "deviceConfig": {}, 
  16.   "module": { 
  17.     "package": "com.isoftstone.kvstoreapp", 
  18.     "name": ".MyApplication", 
  19.     "deviceType": [ 
  20.       "phone" 
  21.     ], 
  22.     "distro": { 
  23.       "deliveryWithInstall": true, 
  24.       "moduleName": "entry", 
  25.       "moduleType": "entry" 
  26.     }, 
  27.     "reqPermissions": [ 
  28.       { 
  29.         "name": "ohos.permission.DISTRIBUTED_DATASYNC" 
  30.       } 
  31.     ], 
  32.     "abilities": [ 
  33.       { 
  34.         "skills": [ 
  35.           { 
  36.             "entities": [ 
  37.               "entity.system.home" 
  38.             ], 
  39.             "actions": [ 
  40.               "action.system.home" 
  41.             ] 
  42.           } 
  43.         ], 
  44.         "orientation": "unspecified", 
  45.         "name": "com.isoftstone.kvstoreapp.MainAbility", 
  46.         "icon": "$media:icon", 
  47.         "description": "$string:mainability_description", 
  48.         "label": "$string:app_name", 
  49.         "type": "page", 
  50.         "launchType": "standard" 
  51.       }, 
  52.       { 
  53.         "name": "com.isoftstone.kvstoreapp.ServiceAbility", 
  54.         "icon": "$media:icon", 
  55.         "description": "$string:serviceability_description", 
  56.         "type": "service" 
  57.       } 
  58.     ] 
  59.   } 
  60. } 

7.xml布局文件

  1. <?xml version="1.0" encoding="utf-8"?> 
  2. <DirectionalLayout 
  3.   xmlns:ohos="http://schemas.huawei.com/res/ohos" 
  4.   ohos:height="match_parent" 
  5.   ohos:orientation="vertical" 
  6.   ohos:width="match_parent"> 
  7.  
  8. <DirectionalLayout 
  9.   ohos:padding="20vp" 
  10.   ohos:height="match_content" 
  11.   ohos:width="match_parent" 
  12.   ohos:orientation="horizontal"> 
  13.   <Text 
  14.     ohos:width="match_content" 
  15.     ohos:height="match_content" 
  16.     ohos:text_size="20vp" 
  17.     ohos:text="溫度："/> 
  18.   <Text 
  19.     ohos:id="$+id:tvTemp" 
  20.     ohos:width="0" 
  21.     ohos:height="match_content" 
  22.     ohos:text_size="22vp" 
  23.     ohos:text_color="#00ff00" 
  24.     ohos:text="待采集..." 
  25.     ohos:weight="1"/> 
  26. </DirectionalLayout> 
  27.   <DirectionalLayout 
  28.     ohos:height="1vp" 
  29.     ohos:width="match_parent" 
  30.     ohos:background_element="#cccccc"/> 
  31.  
  32.   <DirectionalLayout 
  33.     ohos:padding="20vp" 
  34.     ohos:height="match_content" 
  35.     ohos:width="match_parent" 
  36.     ohos:orientation="horizontal"> 
  37.     <Text 
  38.       ohos:width="match_content" 
  39.       ohos:height="match_content" 
  40.       ohos:text_size="20vp" 
  41.       ohos:text="濕度："/> 
  42.     <Text 
  43.       ohos:id="$+id:tvHumi" 
  44.       ohos:width="0" 
  45.       ohos:height="match_content" 
  46.       ohos:text_size="22vp" 
  47.       ohos:text_color="#00ff00" 
  48.       ohos:text="待采集..." 
  49.       ohos:weight="1"/> 
  50.   </DirectionalLayout> 
  51.   <DirectionalLayout 
  52.     ohos:height="1vp" 
  53.     ohos:width="match_parent" 
  54.     ohos:background_element="#cccccc"/> 
  55.  
  56.  
  57.   <DirectionalLayout 
  58.     ohos:padding="20vp" 
  59.     ohos:height="match_content" 
  60.     ohos:width="match_parent" 
  61.     ohos:orientation="horizontal"> 
  62.     <Text 
  63.       ohos:width="match_content" 
  64.       ohos:height="match_content" 
  65.       ohos:text_size="20vp" 
  66.       ohos:text="可燃氣體："/> 
  67.     <Text 
  68.       ohos:id="$+id:tvGas" 
  69.       ohos:width="0" 
  70.       ohos:height="match_content" 
  71.       ohos:text_size="22vp" 
  72.       ohos:text_color="#00ff00" 
  73.       ohos:text="待采集..." 
  74.       ohos:weight="1"/> 
  75.   </DirectionalLayout> 
  76.   <DirectionalLayout 
  77.     ohos:height="1vp" 
  78.     ohos:width="match_parent" 
  79.     ohos:background_element="#cccccc"/> 
  80.  
  81. </DirectionalLayout> 

想了解更多內容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術社區(qū)

https://harmonyos.51cto.com

 

責任編輯：jianghua 來源： 鴻蒙社區(qū)
鴻蒙HarmonyOS應用
相關推薦

2015-05-20 15:54:04

Openstack分布式存儲

2020-11-06 12:12:35

HarmonyOS

2020-09-29 19:20:05

鴻蒙

2022-06-28 08:16:35

MySQL數(shù)據(jù)容災

2022-06-15 16:16:21

分布式數(shù)據(jù)庫鴻蒙

2024-01-08 08:05:08

分開部署數(shù)據(jù)體系系統(tǒng)拆分

2024-01-09 08:00:58

2018-05-31 08:57:59

分布式塊存儲元數(shù)據(jù)

2023-02-11 00:04:17

分布式系統(tǒng)安全

2021-08-26 08:03:30

大數(shù)據(jù)Zookeeper選舉

2021-09-07 10:43:25

EverDB分布式執(zhí)行

2019-10-10 09:16:34

Zookeeper架構分布式

2021-12-14 10:16:00

鴻蒙HarmonyOS應用

2022-04-08 07:22:15

分布式計數(shù)器系統(tǒng)設計

2021-01-19 05:43:33

分布式2PC3PC

2022-09-25 22:19:24

Dapr分布式追蹤

2023-02-23 07:55:41

2023-05-29 14:07:00

Zuul網(wǎng)關系統(tǒng)

2023-12-08 07:31:19

服務網(wǎng)格協(xié)同分布式

2019-08-07 10:44:28

MySQLGoogle
點贊
收藏

51CTO技術棧公眾號