HarmonyOS 分布式之聊天室應用

作者：開鴻HOS小鴻 2021-11-16 09:38:10

開發分布式 OpenHarmony

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

[[434771]]

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

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

https://harmonyos.51cto.com

介紹

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

效果演示

#星光計劃1.0# HarmonyOS 分布式之聊天室應用-鴻蒙HarmonyOS技術社區

項目類說明

主要知識點

分布式數據服務

官方介紹：分布式數據服務主要實現用戶設備中應用程序的數據內容的分布式同步。當設備1上的應用A在分布式數據庫中增、刪、改數據后，設備2上的應用A也可以獲取到該數據庫變化，總結一句話：多個設備共用一個數據庫。

主頁代碼

沒有特別復雜的邏輯，主要是分布式數據服務的使用，關鍵地方都有注釋。

import com.ldd.myapp.bean.ChatDataBean; 
import com.ldd.myapp.provider.ChatProvider; 
import com.ldd.myapp.util.Tools; 
import ohos.aafwk.ability.AbilitySlice; 
import ohos.aafwk.content.Intent; 
import ohos.agp.components.Button; 
import ohos.agp.components.ListContainer; 
import ohos.agp.components.TextField; 
import ohos.app.Context; 
import ohos.bundle.IBundleManager; 
import ohos.data.distributed.common.*; 
import ohos.data.distributed.user.SingleKvStore; 
import ohos.utils.zson.ZSONArray; 
import ohos.utils.zson.ZSONObject; 
 
import java.util.ArrayList; 
import java.util.List; 
 
import static ohos.security.SystemPermission.DISTRIBUTED_DATASYNC; 
 
/** 
 * 主頁 
 */ 
public class MainAbilitySlice extends AbilitySlice { 
    private Context mContext; 
    // 聊天列表 
    private ListContainer lcList; 
    // 聊天數據 
    private final List<ChatDataBean> listData = new ArrayList<>(); 
    // 聊天數據適配器 
    private ChatProvider chatProvider; 
    // 輸入框 
    private TextField tfContent; 
    // 發送按鈕 
    private Button btnSend; 
 
    // 分布式數據庫管理器 
    private KvManager kvManager; 
    // 分布式數據庫 
    private SingleKvStore singleKvStore; 
    // 數據庫名稱 
    private static final String STORE_NAME = "ChatStore"; 
    // 存入的列表數據key 
    private static final String KEY_DATA = "key_data"; 
    // 存入的頭像索引 
    private static final String KEY_PIC_INDEX = "key_pic_index"; 
    private int picIndex = 0; 
 
    @Override 
    public void onStart(Intent intent) { 
        super.onStart(intent); 
        super.setUIContent(ResourceTable.Layout_ability_main); 
        mContext = this; 
        requestPermission(); 
        initComponent(); 
        initDatabase(); 
    } 
 
    /** 
     * 請求分布式權限 
     */ 
    private void requestPermission() { 
        if (verifySelfPermission(DISTRIBUTED_DATASYNC) != IBundleManager.PERMISSION_GRANTED) { 
            if (canRequestPermission(DISTRIBUTED_DATASYNC)) { 
                requestPermissionsFromUser(new String[]{DISTRIBUTED_DATASYNC}, 0); 
            } 
        } 
    } 
 
    /** 
     * 初始化組件 
     */ 
    private void initComponent() { 
        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 = new ChatProvider(mContext, listData); 
        lcList.setItemProvider(chatProvider); 
 
        // 輸入框內容變化監聽 
        tfContent.addTextObserver((text, start, before, count) -> { 
            btnSend.setEnabled(text.length() != 0); 
        }); 
        // 點擊發送按鈕 
        btnSend.setClickedListener(component -> { 
            String content = tfContent.getText().trim(); 
            listData.add(new ChatDataBean(Tools.getDeviceId(mContext),picIndex,content)); 
            // 存入數據庫中 
            singleKvStore.putString(KEY_DATA, ZSONObject.toZSONString(listData)); 
 
            // 清空輸入框 
            tfContent.setText(""); 
        }); 
    } 
 
    /** 
     * 初始化分布式數據庫 
     */ 
    private void initDatabase() { 
        // 創建分布式數據庫管理器 
        kvManager = KvManagerFactory.getInstance().createKvManager(new KvManagerConfig(this)); 
 
        // 數據庫配置 
        Options options = new Options(); 
        options.setCreateIfMissing(true) // 設置數據庫不存在時是否創建 
                .setEncrypt(false) // 設置數據庫是否加密 
                .setKvStoreType(KvStoreType.SINGLE_VERSION); //數據庫類型 
        // 創建分布式數據庫 
        singleKvStore = kvManager.getKvStore(options, STORE_NAME); 
        // 監聽數據庫數據改變 
        singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, new KvStoreObserver() { 
            @Override 
            public void onChange(ChangeNotification changeNotification) { 
                List<Entry> insertEntries = changeNotification.getInsertEntries(); 
                List<Entry> updateEntries = changeNotification.getUpdateEntries(); 
 
                // 第一次存入數據，獲取insertEntries 
                if(insertEntries.size()>0){ 
                    for (Entry entry : 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); 
                            }); 
                        } 
                    } 
                }else if(updateEntries.size()>0){ 
                    for (Entry entry : 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 (KvStoreException e) { 
            e.printStackTrace(); 
            // 沒有找到，首次進入 
            if (e.getKvStoreErrorCode() == KvStoreErrorCode.KEY_NOT_FOUND) { 
                picIndex = 0; 
                singleKvStore.putInt(KEY_PIC_INDEX, picIndex + 1); 
            } 
        } 
    } 
 
    @Override 
    protected void onStop() { 
        super.onStop(); 
        kvManager.closeKvStore(singleKvStore); 
    } 
}

簡單案例

1、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" 
      } 
    ]

2、布局頁面

<?xml version="1.0" encoding="utf-8"?> 
<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>

3、MainAbilitySlice代碼

import ohos.aafwk.ability.AbilitySlice; 
import ohos.aafwk.content.Intent; 
import ohos.agp.components.Button; 
import ohos.agp.components.ListContainer; 
import ohos.agp.components.Text; 
import ohos.agp.components.TextField; 
import ohos.bundle.IBundleManager; 
import ohos.data.distributed.common.*; 
import ohos.data.distributed.user.SingleKvStore; 
import ohos.utils.zson.ZSONArray; 
 
import java.util.List; 
 
import static ohos.security.SystemPermission.DISTRIBUTED_DATASYNC; 
 
public class MainAbilitySlice extends AbilitySlice { 
    // 顯示數據 
    private Text text; 
    // 分布式數據庫管理器 
    private KvManager kvManager; 
    // 分布式數據庫 
    private SingleKvStore singleKvStore; 
    // 數據庫名稱 
    private static final String STORE_NAME = "MyStore"; 
    // 存入的數據key 
    private static final String KEY_COUNT = "key_count"; 
 
    @Override 
    public void onStart(Intent intent) { 
        super.onStart(intent); 
        super.setUIContent(ResourceTable.Layout_ability_main); 
        requestPermission(); 
        initDatabase(); 
        initComponent(); 
    } 
 
    /** 
     * 請求分布式權限 
     */ 
    private void requestPermission() { 
        if (verifySelfPermission(DISTRIBUTED_DATASYNC) != IBundleManager.PERMISSION_GRANTED) { 
            if (canRequestPermission(DISTRIBUTED_DATASYNC)) { 
                requestPermissionsFromUser(new String[]{DISTRIBUTED_DATASYNC}, 0); 
            } 
        } 
    } 
 
    /** 
     * 初始化分布式數據庫 
     */ 
    private void initDatabase() { 
        // 創建分布式數據庫管理器 
        kvManager = KvManagerFactory.getInstance().createKvManager(new KvManagerConfig(this)); 
 
        // 數據庫配置 
        Options options = new Options(); 
        options.setCreateIfMissing(true) // 設置數據庫不存在時是否創建 
                .setEncrypt(false) // 設置數據庫是否加密 
                .setKvStoreType(KvStoreType.SINGLE_VERSION); //數據庫類型 
        // 創建分布式數據庫 
        singleKvStore = kvManager.getKvStore(options, STORE_NAME); 
        // 監聽數據庫數據改變 
        singleKvStore.subscribe(SubscribeType.SUBSCRIBE_TYPE_ALL, new KvStoreObserver() { 
            @Override 
            public void onChange(ChangeNotification changeNotification) { 
                List<Entry> insertEntries = changeNotification.getInsertEntries(); 
                List<Entry> updateEntries = changeNotification.getUpdateEntries(); 
 
                // 第一次存入數據，獲取insertEntries 
                if (insertEntries.size() > 0) { 
                    for (Entry entry : insertEntries) { 
                        if (KEY_COUNT.equals(entry.getKey())) { 
                            // 回調為非UI線程，需要在UI線程更新UI 
                            getUITaskDispatcher().syncDispatch(() -> { 
                                int count = entry.getValue().getInt(); 
                                text.setText("數據："+count); 
                            }); 
                        } 
                    } 
                } else if (updateEntries.size() > 0) { 
                    for (Entry entry : updateEntries) { 
                        if (KEY_COUNT.equals(entry.getKey())) { 
                            // 回調為非UI線程，需要在UI線程更新UI 
                            getUITaskDispatcher().syncDispatch(() -> { 
                                int count = entry.getValue().getInt(); 
                                text.setText("數據："+count); 
                            }); 
                        } 
                    } 
                } 
            } 
        }); 
 
    } 
 
    /** 
     * 初始化組件 
     */ 
    private void initComponent() { 
        text = (Text) findComponentById(ResourceTable.Id_text); 
        Button button = (Button) findComponentById(ResourceTable.Id_button); 
 
        // 點擊事件 
        button.setClickedListener(component -> { 
            try { 
                int count = singleKvStore.getInt(KEY_COUNT); 
                singleKvStore.putInt(KEY_COUNT, count + 1); 
            } catch (KvStoreException e) { 
                e.printStackTrace(); 
                // 沒有找到，首次進入 
                if (e.getKvStoreErrorCode() == KvStoreErrorCode.KEY_NOT_FOUND) { 
                    int count = 0; 
                    singleKvStore.putInt(KEY_COUNT, count + 1); 
                } 
            } 
        }); 
    } 
}