在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

基于鴻蒙分布式數據服務開發的聊天室應用

OpenHarmony技術社區 ? 來源:鴻蒙技術社區 ? 作者:梁青松 ? 2021-11-15 09:32 ? 次閱讀

之前給大家介紹過《HarmonyOS 分布式之仿抖音應用》,此次給大家介紹一下基于鴻蒙分布式數據服務開發的聊天室應用,模擬現實中的聊天室對話,可以與小伙伴們互動、分享自己的故事給小伙伴。

主要知識點

分布式數據服務

https://developer.harmonyos.com/cn/docs/documentation/doc-guides/database-mdds-guidelines-0000000000030122

官方介紹:分布式數據服務主要實現用戶設備中應用程序的數據內容的分布式同步。

當設備 1 上的應用 A 在分布式數據庫中增、刪、改數據后,設備 2 上的應用 A 也可以獲取到該數據庫變化,總結一句話:多個設備共用一個數據庫。

主頁代碼

沒有特別復雜的邏輯,主要是分布式數據服務的使用,關鍵地方都有注釋。
importcom.ldd.myapp.bean.ChatDataBean;
importcom.ldd.myapp.provider.ChatProvider;
importcom.ldd.myapp.util.Tools;
importohos.aafwk.ability.AbilitySlice;
importohos.aafwk.content.Intent;
importohos.agp.components.Button;
importohos.agp.components.ListContainer;
importohos.agp.components.TextField;
importohos.app.Context;
importohos.bundle.IBundleManager;
importohos.data.distributed.common.*;
importohos.data.distributed.user.SingleKvStore;
importohos.utils.zson.ZSONArray;
importohos.utils.zson.ZSONObject;

importjava.util.ArrayList;
importjava.util.List;

importstaticohos.security.SystemPermission.DISTRIBUTED_DATASYNC;

/**
*主頁
*/
publicclassMainAbilitySliceextendsAbilitySlice{
privateContextmContext;
//聊天列表
privateListContainerlcList;
//聊天數據
privatefinalListlistData=newArrayList<>();
//聊天數據適配器
privateChatProviderchatProvider;
//輸入框
privateTextFieldtfContent;
//發送按鈕
privateButtonbtnSend;

//分布式數據庫管理器
privateKvManagerkvManager;
//分布式數據庫
privateSingleKvStoresingleKvStore;
//數據庫名稱
privatestaticfinalStringSTORE_NAME="ChatStore";
//存入的列表數據key
privatestaticfinalStringKEY_DATA="key_data";
//存入的頭像索引
privatestaticfinalStringKEY_PIC_INDEX="key_pic_index";
privateintpicIndex=0;

@Override
publicvoidonStart(Intentintent){
super.onStart(intent);
super.setUIContent(ResourceTable.Layout_ability_main);
mContext=this;
requestPermission();
initComponent();
initDatabase();
}

/**
*請求分布式權限
*/
privatevoidrequestPermission(){
if(verifySelfPermission(DISTRIBUTED_DATASYNC)!=IBundleManager.PERMISSION_GRANTED){
if(canRequestPermission(DISTRIBUTED_DATASYNC)){
requestPermissionsFromUser(newString[]{DISTRIBUTED_DATASYNC},0);
}
}
}

/**
*初始化組件
*/
privatevoidinitComponent(){
lcList=(ListContainer)findComponentById(ResourceTable.Id_lc_list);
tfContent=(TextField)findComponentById(ResourceTable.Id_tf_content);
tfContent.setAdjustInputPanel(true);
btnSend=(Button)findComponentById(ResourceTable.Id_btn_send);
btnSend.setEnabled(false);

//初始化適配器
chatProvider=newChatProvider(mContext,listData);
lcList.setItemProvider(chatProvider);

//輸入框內容變化監聽
tfContent.addTextObserver((text,start,before,count)->{
btnSend.setEnabled(text.length()!=0);
});
//點擊發送按鈕
btnSend.setClickedListener(component->{
Stringcontent=tfContent.getText().trim();
listData.add(newChatDataBean(Tools.getDeviceId(mContext),picIndex,content));
//存入數據庫中
singleKvStore.putString(KEY_DATA,ZSONObject.toZSONString(listData));

//清空輸入框
tfContent.setText("");
});
}

/**
*初始化分布式數據庫
*/
privatevoidinitDatabase(){
//創建分布式數據庫管理器
kvManager=KvManagerFactory.getInstance().createKvManager(newKvManagerConfig(this));

//數據庫配置
Optionsoptions=newOptions();
options.setCreateIfMissing(true)//設置數據庫不存在時是否創建
.setEncrypt(false)//設置數據庫是否加密
.setKvStoreType(KvStoreType.SINGLE_VERSION);//數據庫類型
//創建分布式數據庫
singleKvStore=kvManager.getKvStore(options,STORE_NAME);
//監聽數據庫數據改變
singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL,newKvStoreObserver(){
@Override
publicvoidonChange(ChangeNotificationchangeNotification){
ListinsertEntries=changeNotification.getInsertEntries();
ListupdateEntries=changeNotification.getUpdateEntries();

//第一次存入數據,獲取insertEntries
if(insertEntries.size()>0){
for(Entryentry:insertEntries){
if(KEY_DATA.equals(entry.getKey())){
//回調為非UI線程,需要在UI線程更新UI
getUITaskDispatcher().syncDispatch(()->{
listData.clear();
listData.addAll(ZSONArray.stringToClassList(entry.getValue().getString(),ChatDataBean.class));
chatProvider.notifyDataChanged();
lcList.scrollTo(listData.size()-1);
});
}
}
}elseif(updateEntries.size()>0){
for(Entryentry:updateEntries){
if(KEY_DATA.equals(entry.getKey())){
//回調為非UI線程,需要在UI線程更新UI
getUITaskDispatcher().syncDispatch(()->{
listData.clear();
listData.addAll(ZSONArray.stringToClassList(entry.getValue().getString(),ChatDataBean.class));
chatProvider.notifyDataChanged();
lcList.scrollTo(listData.size()-1);
});
}
}
}
}
});

try{
picIndex=singleKvStore.getInt(KEY_PIC_INDEX);
singleKvStore.putInt(KEY_PIC_INDEX,picIndex+1);
}catch(KvStoreExceptione){
e.printStackTrace();
//沒有找到,首次進入
if(e.getKvStoreErrorCode()==KvStoreErrorCode.KEY_NOT_FOUND){
picIndex=0;
singleKvStore.putInt(KEY_PIC_INDEX,picIndex+1);
}
}
}

@Override
protectedvoidonStop(){
super.onStop();
kvManager.closeKvStore(singleKvStore);
}
}

簡單案例

config.json 配置:
"reqPermissions":[
{
"reason":"多設備協同",
"name":"ohos.permission.DISTRIBUTED_DATASYNC",
"usedScene":{
"ability":[
"MainAbility"
],
"when":"always"
}
},
{
"name":"ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE"
},
{
"name":"ohos.permission.GET_DISTRIBUTED_DEVICE_INFO"
},
{
"name":"ohos.permission.GET_BUNDLE_INFO"
}
]

布局頁面:

<DirectionalLayout
xmlns:ohos="http://schemas.huawei.com/res/ohos"
ohos:height="match_parent"
ohos:width="match_parent"
ohos:alignment="center"
ohos:orientation="vertical">

<Text
ohos:id="$+id:text"
ohos:height="match_content"
ohos:width="match_content"
ohos:text="數據:0"
ohos:text_size="15fp"/>

<Button
ohos:margin="20vp"
ohos:id="$+id:button"
ohos:height="match_content"
ohos:width="match_parent"
ohos:background_element="$graphic:button_bg"
ohos:padding="10vp"
ohos:text="點擊+1"
ohos:text_color="white"
ohos:text_size="15fp"/>

DirectionalLayout>
MainAbilitySlice 代碼:
importohos.aafwk.ability.AbilitySlice;
importohos.aafwk.content.Intent;
importohos.agp.components.Button;
importohos.agp.components.ListContainer;
importohos.agp.components.Text;
importohos.agp.components.TextField;
importohos.bundle.IBundleManager;
importohos.data.distributed.common.*;
importohos.data.distributed.user.SingleKvStore;
importohos.utils.zson.ZSONArray;

importjava.util.List;

importstaticohos.security.SystemPermission.DISTRIBUTED_DATASYNC;

publicclassMainAbilitySliceextendsAbilitySlice{
//顯示數據
privateTexttext;
//分布式數據庫管理器
privateKvManagerkvManager;
//分布式數據庫
privateSingleKvStoresingleKvStore;
//數據庫名稱
privatestaticfinalStringSTORE_NAME="MyStore";
//存入的數據key
privatestaticfinalStringKEY_COUNT="key_count";

@Override
publicvoidonStart(Intentintent){
super.onStart(intent);
super.setUIContent(ResourceTable.Layout_ability_main);
requestPermission();
initDatabase();
initComponent();
}

/**
*請求分布式權限
*/
privatevoidrequestPermission(){
if(verifySelfPermission(DISTRIBUTED_DATASYNC)!=IBundleManager.PERMISSION_GRANTED){
if(canRequestPermission(DISTRIBUTED_DATASYNC)){
requestPermissionsFromUser(newString[]{DISTRIBUTED_DATASYNC},0);
}
}
}

/**
*初始化分布式數據庫
*/
privatevoidinitDatabase(){
//創建分布式數據庫管理器
kvManager=KvManagerFactory.getInstance().createKvManager(newKvManagerConfig(this));

//數據庫配置
Optionsoptions=newOptions();
options.setCreateIfMissing(true)//設置數據庫不存在時是否創建
.setEncrypt(false)//設置數據庫是否加密
.setKvStoreType(KvStoreType.SINGLE_VERSION);//數據庫類型
//創建分布式數據庫
singleKvStore=kvManager.getKvStore(options,STORE_NAME);
//監聽數據庫數據改變
singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL,newKvStoreObserver(){
@Override
publicvoidonChange(ChangeNotificationchangeNotification){
ListinsertEntries=changeNotification.getInsertEntries();
ListupdateEntries=changeNotification.getUpdateEntries();

//第一次存入數據,獲取insertEntries
if(insertEntries.size()>0){
for(Entryentry:insertEntries){
if(KEY_COUNT.equals(entry.getKey())){
//回調為非UI線程,需要在UI線程更新UI
getUITaskDispatcher().syncDispatch(()->{
intcount=entry.getValue().getInt();
text.setText("數據:"+count);
});
}
}
}elseif(updateEntries.size()>0){
for(Entryentry:updateEntries){
if(KEY_COUNT.equals(entry.getKey())){
//回調為非UI線程,需要在UI線程更新UI
getUITaskDispatcher().syncDispatch(()->{
intcount=entry.getValue().getInt();
text.setText("數據:"+count);
});
}
}
}
}
});

}

/**
*初始化組件
*/
privatevoidinitComponent(){
text=(Text)findComponentById(ResourceTable.Id_text);
Buttonbutton=(Button)findComponentById(ResourceTable.Id_button);

//點擊事件
button.setClickedListener(component->{
try{
intcount=singleKvStore.getInt(KEY_COUNT);
singleKvStore.putInt(KEY_COUNT,count+1);
}catch(KvStoreExceptione){
e.printStackTrace();
//沒有找到,首次進入
if(e.getKvStoreErrorCode()==KvStoreErrorCode.KEY_NOT_FOUND){
intcount=0;
singleKvStore.putInt(KEY_COUNT,count+1);
}
}
});
}
}
注釋比較詳細,主要注意 2 個點:
  • 獲取數據時加入 try catch 塊,處理 key 未找到的情況。

  • 數據庫數據改變監聽回調是非 UI 線程,如果更新 UI 必須切換到 UI 線程。

以上簡單案例就是讓你快速掌握分布式數據服務:多個設備相同的應用之間使用同一個數據庫。 項目地址(需要登錄才能看到演示圖):
https://gitee.com/liangdidi/DistributedChatDemo.git

責任編輯:haq


聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • 數據
    +關注

    關注

    8

    文章

    7241

    瀏覽量

    91023
  • 鴻蒙系統
    +關注

    關注

    183

    文章

    2639

    瀏覽量

    67712
  • HarmonyOS
    +關注

    關注

    79

    文章

    2053

    瀏覽量

    32150

原文標題:一款鴻蒙分布式聊天室應用!

文章出處:【微信號:gh_834c4b3d87fe,微信公眾號:OpenHarmony技術社區】歡迎添加關注!文章轉載請注明出處。

收藏 人收藏

    評論

    相關推薦
    熱點推薦

    鴻蒙5開發寶藏案例分享---應用接續提升內容發布體驗

    : [distributedAsset] // 關鍵!這里放的是分布式文件引用 }); // 激活數據同步(相當于啟動數據快遞服務) this.distributedObject.s
    發表于 06-03 18:25

    鴻蒙5開發寶藏案例分享---一多開發實例(游戲)

    十年前藏的現金一樣驚喜!)這些藏在文檔深處的\"武功秘籍\",能幫我們輕松實現分布式游戲、跨端協同這些聽起來很酷的功能。快上車,帶你解鎖鴻蒙開發的正確姿勢! 一、分布式游戲手柄
    發表于 06-03 18:22

    分布式存儲數據恢復—虛擬機上hbase和hive數據數據恢復案例

    分布式存儲數據恢復環境: 16臺某品牌R730xd服務器節點,每臺服務器節點上有數臺虛擬機。 虛擬機上部署Hbase和Hive數據庫。
    的頭像 發表于 04-17 11:05 ?165次閱讀

    分布式云化數據庫有哪些類型

    分布式云化數據庫有哪些類型?分布式云化數據庫主要類型包括:關系型分布式數據庫、非關系型分布式數據
    的頭像 發表于 01-15 09:43 ?400次閱讀

    AIGC入門及鴻蒙入門

    JDK、配置SDK等。 3. 開發實踐: 學習鴻蒙系統的架構和API,了解其組件化、分布式等特性。 通過官方文檔和社區資源,學習和掌握鴻蒙應用的開發
    發表于 01-13 10:32

    基于ptp的分布式系統設計

    在現代分布式系統中,精確的時間同步對于確保數據一致性、系統穩定性和性能至關重要。PTP(Precision Time Protocol)是一種網絡協議,用于在分布式系統中實現高精度的時間同步
    的頭像 發表于 12-29 10:09 ?463次閱讀

    HarmonyOS Next 應用元服務開發-分布式數據對象遷移數據文件資產遷移

    設備文件訪問實現文件的遷移,難以獲取文件同步完成的時間。為了保證更高的成功率,文件的遷移不建議繼續通過該方式實現,推薦使用分布式數據對象攜帶資產的方式。開發者此前通過跨設備文件訪問實現的文件遷移依然生效
    發表于 12-24 10:11

    HarmonyOS Next 應用元服務開發-分布式數據對象遷移數據權限與基礎數據

    設備文件訪問實現文件的遷移,難以獲取文件同步完成的時間。為了保證更高的成功率,文件的遷移不建議繼續通過該方式實現,推薦使用分布式數據對象攜帶資產的方式。開發者此前通過跨設備文件訪問實現的文件遷移依然生效
    發表于 12-24 09:40

    京準電鐘:NTP網絡授時服務器在分布式網絡內的應用

    京準電鐘:NTP網絡授時服務器在分布式網絡內的應用
    的頭像 發表于 11-27 16:09 ?447次閱讀
    京準電鐘:NTP網絡授時<b class='flag-5'>服務</b>器在<b class='flag-5'>分布式</b>網絡內的應用

    分布式光纖測溫是什么?應用領域是?

    時,該處的散射光特性會受到影響。通過高速信號采集與數據處理技術,可以準確地定位發生溫度變化的位置,并給出實時的溫度信息。簡而言之,分布式光纖測溫技術將整條傳輸光纖作為傳感器,光纖上的每一點都兼具“傳”和“感”
    的頭像 發表于 10-24 15:30 ?1096次閱讀
    <b class='flag-5'>分布式</b>光纖測溫是什么?應用領域是?

    分布式存儲費用高嗎?大概需要多少錢

    分布式存儲的費用是否高,取決于多個因素,包括存儲容量、性能要求、服務提供商、計費模式等。因此,無法簡單地給出一個“高”或“不高”的答案。通常分布式存儲費用通常包含存儲費用、網絡費用、增值服務
    的頭像 發表于 09-24 10:41 ?536次閱讀

    鴻蒙開發管理:ohos.account.distributedAccount 分布式帳號管理

    獲取分布式帳號單實例對象。
    的頭像 發表于 07-08 10:03 ?439次閱讀
    <b class='flag-5'>鴻蒙</b><b class='flag-5'>開發</b>管理:ohos.account.distributedAccount <b class='flag-5'>分布式</b>帳號管理

    鴻蒙ArkTS聲明開發:跨平臺支持列表【分布式遷移標識】 通用屬性

    組件的分布式遷移標識,指明了該組件在分布式遷移場景下可以將特定狀態恢復到對端設備。
    的頭像 發表于 06-07 21:15 ?587次閱讀

    鴻蒙開發接口數據管理:【@ohos.data.distributedDataObject (分布式數據對象)】

    本模塊提供管理基本數據對象的相關能力,包括創建、查詢、刪除、修改、訂閱等;同時支持相同應用多設備間的分布式數據對象協同能力。
    的頭像 發表于 06-07 17:51 ?1741次閱讀
    <b class='flag-5'>鴻蒙</b><b class='flag-5'>開發</b>接口<b class='flag-5'>數據</b>管理:【@ohos.data.distributedDataObject (<b class='flag-5'>分布式</b><b class='flag-5'>數據</b>對象)】

    鴻蒙開發接口數據管理:【@ohos.data.distributedData (分布式數據管理)】

    分布式數據管理為應用程序提供不同設備間數據庫的分布式協同能力。通過調用分布式數據各個接口,應用程
    的頭像 發表于 06-07 09:30 ?1434次閱讀
    <b class='flag-5'>鴻蒙</b><b class='flag-5'>開發</b>接口<b class='flag-5'>數據</b>管理:【@ohos.data.distributedData (<b class='flag-5'>分布式</b><b class='flag-5'>數據</b>管理)】
    主站蜘蛛池模板: 完全免费在线视频 | 色五月视频 | 国产农村妇女毛片精品久久 | 欧美videosex性欧美成人 | 亚洲午夜一区二区三区 | videsgratis欧美另类 | 孩交精品xxxx视频视频 | 在线观看日本亚洲一区 | 九九热在线精品 | 女人扒开腿让男人桶到爽 | 欧美日韩一日韩一线不卡 | 视频一区二区不卡 | 22eee在线播放成人免费视频 | 免费看黄的视频软件 | 国产美女视频黄a视频全免费网站 | 手机看片福利1024 | 亚色网站 | www.久艹| 色综合狠狠操 | 天天舔天天爽 | 天天操夜夜爱 | 你懂的网站在线播放 | 玖玖在线 | 日本免费观看网站 | 亚洲网站免费看 | 日韩在线视频免费观看 | 久久精品亚洲精品国产欧美 | 四虎精品永久在线 | 亚洲人成电影院在线观看 | 国产亚洲美女精品久久久久狼 | 97一区二区三区 | 亚洲综合久久久 | 毛片2016免费视频 | 国产色视频网站免费观看 | 狠狠激情五月综合婷婷俺 | 亚洲国产婷婷香蕉久久久久久 | 狠狠色噜噜狠狠狠狠97影音先锋 | 天天看片夜夜爽 | 久久国产精品免费网站 | 精品四虎免费观看国产高清午夜 | 97影院理论在线观看 |