多服务场景化解决方案短视频剪辑(ShortVideoCreator)

Posted 2022-09-07 华为开发者论坛

介绍

通过构建Short Video Creator这款短视频创建应用，您可以更好地了解华为生态系统的Serverless成员，如账号服务、云存储、云数据库、云函数等。该应用接入了强大的华为媒体服务及其它核心功能。得益于此，企业和用户可以在该应用平台上编辑和上传视频，将他们的才能让更多的人看到。

特点：

支持手机号登录

精彩视频，互动不停

免费使用，无限上传

具有视频编辑功能

头像上传

实时更新

在这个Codelab中，我们将使用如下华为移动服务来实现应用的相关功能：

应用功能	华为移动服务
手机号登录	账号服务
编辑、发布视频，上传头像 编辑完成后需借助本地存储和云存储确定如何在个人主页展示视频和头像。	视频编辑服务
上传视频和头像	云数据库
存储和获取用户信息，视频ID，视频标签，和视频评论等数据	云存储和云数据库
编辑个人主页照片	图像服务
个人主页广告展示	广告服务

您将建立什么

在这个Codelab中，您将建立一个名为Short Video Creator的短视频创建应用示例工程，使用视频编辑服务，账号服务，广告服务，图像服务，云存储和云数据库等华为服务的接口，并能学习到MVVM（Model–view–viewmodel）架构模式概念。

下图展示的是登录界面。当输入并确认手机号后，需要配合验证码完成登录。

​

​

下图展示的是应用上播放的视频及其评论。

​

​

下图展示的是视频编辑页面，用户可以在该页面上传视频和添加不同的音频片段。

​

​

​

下图展示如何添加音频片段。

​

​

​

​

下图展示的是个人主页，用户可以在该页面看到已上传的视频，添加或更新个人头像。

​

​

​

为保护用户隐私，本文档中涉及用户个人信息的图片都已做了模糊处理。

您将学到什么

在这个Codelab中，您将学到：

• 如何使用账号服务实现登录功能；
• 如何使用云数据库储存用户和视频信息；
• 如何使用云存储储存图像和视频；
• 如何接入视频编辑服务和图像服务

您需要什么

说明：请提前准备上述硬件环境和相关设备。

硬件要求

• 运行Windows 10操作系统的台式机或笔记本电脑。
• 安装HMS Core (APK) 5.0.0.300或以上版本的华为手机一部。

软件要求

• ​​Android Studio 3.X​​
• JDK 1.8或以上。
• SDK Platform 23或以上。
• Gradle 4.6或以上。

​

说明：请提前准备上述软件环境。

能力接入准备

要集成HMS Core相关服务，需要完成以下准备：

• 登录AppGallery Connect并创建应用。
• 创建android Studio工程。
• 生成签名证书。
• 生成签名证书指纹。
• 配置签名证书指纹。
• 添加应用包名并保存配置文件。
• 在项目级build.gradle文件中，添加AppGallery Connect插件及Maven仓地址。
• 在Android Studio中配置签名证书。

具体操作，请按照​​HMS Core集成准备​​中的详细说明来完成。

前往“项目设置”页面，选择“API”管理并开通下述服务：

• 账号服务
• 云数据库
• 云存储
• 视频编辑服务
• 图像服务
• 广告服务

​

说明：部分API默认是关闭的，您必须手动启用。

集成账号服务

全球约有十亿拥有华为账号的用户。接入华为账号的应用支持用户一键登录华为账号。此外，得益于庞大的华为用户群，您还可以拉新大量用户。

使用账号服务，您需要：

前往​​开发者联盟​​注册华为账号，登录​​AppGallery Connect​​创建应用，配置应用信息，然后开通账号服务。

在Android Studio中创建项目并接入账号服务SDK。

根据开发指南调用和调试账号服务接口。

开通账号服务。

1.添加如下依赖。

说明：根据​​开发文档​​集成​​最新版本的SDK​​，示例集成的是6.1.0.302版本。

implementation "com.huawei.hms:hwid:<latest_version>"

2.导入认证服务需要用到的相关类。

import com.huawei.hms.common.ApiException;

import com.huawei.hms.support.account.AccountAuthManager;

import com.huawei.hms.support.account.request.AccountAuthParams;

import com.huawei.hms.support.account.request.AccountAuthParamsHelper;

import com.huawei.hms.support.account.result.AuthAccount;

import com.huawei.hms.support.account.service.AccountAuthService;

3.编辑LoginActivity.java。

btnSignup.setOnClickListener(v -> signup());
        Handler mHandler = new Handler(Looper.getMainLooper());
        if (AGConnectAuth.getInstance().getCurrentUser() == null) 
            mHandler.post(() -> 
                LoginHelper loginHelper = new LoginHelper(LoginActivity.this);
                loginHelper.addLoginCallBack(this);
                loginHelper.login();
            );
        
private void signup()
        try 
            AccountAuthParams mAuthParam = new AccountAuthParamsHelper(AccountAuthParams.DEFAULT_AUTH_REQUEST_PARAM)
                    .setIdToken()
                    .setAccessToken()
                    .createParams();
            AccountAuthService mAuthManager = AccountAuthManager.getService(LoginActivity.this, mAuthParam);
            startActivityForResult(mAuthManager.getSignInIntent(), Constants.REQUEST_SIGN_IN_LOGIN);
        catch (Exception e)
            Log.e(Constants.APP_TAG,e.getMessage());
        
    
@Override
    protected void onActivityResult(int requestCode, int resultCode, Intent data) 
        super.onActivityResult(requestCode, resultCode, data);
if (requestCode == Constants.REQUEST_SIGN_IN_LOGIN) 
            Task<AuthAccount> authAccountTask = AccountAuthManager.parseAuthResultFromIntent(data);
            if (authAccountTask.isSuccessful()) 
                AuthAccount authAccount = authAccountTask.getResult();
                if(null !=authAccount.getEmail()) 
                    if (authAccount.getEmail().equalsIgnoreCase("0") || authAccount.getDisplayName().equalsIgnoreCase("0")) 
                        SharedPreferences.Editor editor = getSharedPreferences(MY_PREFS_NAME, MODE_PRIVATE).edit();
                        editor.putString("email", authAccount.getEmail());
                        editor.putString("mobile", authAccount.getDisplayName());
                        editor.putString("name", authAccount.getUid());
                        editor.putInt("login", 1);
                        editor.putInt("count", 1);
                        editor.apply();
                        getProfileDialog(authAccount.getEmail(), authAccount.getDisplayName(), authAccount.getUid());
 
                    
                
                else
                    SharedPreferences.Editor editor = getSharedPreferences(MY_PREFS_NAME, MODE_PRIVATE).edit();
                    editor.putString("email", authAccount.getEmail());
                    editor.putString("mobile", authAccount.getDisplayName());
                    editor.putString("name", authAccount.getUid());
                    editor.putInt("login", 1);
                    editor.putInt("count", 1);
                    editor.apply();
                    getProfileDialog("", authAccount.getDisplayName(), authAccount.getUid());
 
                
 
             else 
                Log.i(Constants.APP_TAG, "signIn failed: " + ((ApiException) authAccountTask.getException()).getStatusCode());
            
        
    

集成云数据库

本示例项目中需要将所有数据储存至云数据库中。

1.添加依赖。

a.添加如下云数据库依赖：

dependencies 

implementation "com.huawei.agconnect:agconnect-cloud-database:<cloud_DB_zone>"

说明：请根据​​开发文档​​集成​​最新版本的云数据库​​，示例集成的是1.2.3.301版本。

b.接入SDK后，在应用级build.gradle文件头apply plugin: com.android.application下添加如下声明。

apply plugin: com.huawei.agconnect

2.创建一个包含指定字段的User对象。

Java示例

创建一个用来与云数据库交互用户信息的User类。

package com.huawei.tiktoksample.db.clouddb;
 
 
import com.huawei.agconnect.cloud.database.CloudDBZoneObject;
import com.huawei.agconnect.cloud.database.Text;
import com.huawei.agconnect.cloud.database.annotations.DefaultValue;
import com.huawei.agconnect.cloud.database.annotations.NotNull;
import com.huawei.agconnect.cloud.database.annotations.Indexes;
 import com.huawei.agconnect.cloud.database.annotations.PrimaryKeys;
 
@PrimaryKeys("user_email")
@Indexes("user_id_email:user_email,user_id", "user_email:user_email")
public final class User extends CloudDBZoneObject 
     private Integer user_id;

     private String user_email;

     private String user_name;

     private String user_profile_pic;

     @DefaultValue(booleanValue = true)
     private Boolean user_shadow_flag;

     private String user_phone;

     public User() 
         super(User.class);
         this.user_shadow_flag = true;
     

     public void setUserId(Integer user_id) 
         this.user_id = user_id;
     

     public Integer getUserId() 
         return user_id;
     

     public void setUserEmail(String user_email) 
         this.user_email = user_email;
     

     public String getUserEmail() 
         return user_email;
     

     public void setUserName(String user_name) 
         this.user_name = user_name;
     

     public String getUserName() 
         return user_name;
     

     public void setUserProfilePic(String user_profile_pic) 
         this.user_profile_pic = user_profile_pic;
     

     public String getUserProfilePic() 
         return user_profile_pic;
     

     public void setUserShadowFlag(Boolean user_shadow_flag) 
         this.user_shadow_flag = user_shadow_flag;
     

     public Boolean getUserShadowFlag() 
         return user_shadow_flag;
     

     public void setUserPhone(String user_phone) 
         this.user_phone = user_phone;
     

     public String getUserPhone() 
         return user_phone;
     

 

3.在CloudDBHelper类中导入启动、关闭和初始化云数据库的单例类。

Java示例

CloudDBHelper.java

import com.huawei.agconnect.cloud.database.AGConnectCloudDB;
import com.huawei.agconnect.cloud.database.CloudDBZone;
import com.huawei.agconnect.cloud.database.CloudDBZoneConfig;
import com.huawei.agconnect.cloud.database.exceptions.AGConnectCloudDBException;
import com.huawei.hmf.tasks.Task;
import com.huawei.tiktoksample.db.clouddb.ObjectTypeInfoHelper;
import com.huawei.tiktoksample.util.Constants;
import com.huawei.tiktoksample.util.OnDBZoneOpen;

4.添加如下代码段。

public class CloudDBHelper 

    private AGConnectCloudDB agConnectCloudDB;
    private CloudDBZone;
    private static final String TAG = CloudDBHelper.class.getSimpleName();

    private static CloudDBHelper;

    public static CloudDBHelper getInstance() 
        if (cloudDBHelper == null) 
            cloudDBHelper = new CloudDBHelper();
        
        return cloudDBHelper;
    

    public void init(Context context) 
        AGConnectCloudDB.initialize(context);
        try 
            agConnectCloudDB = AGConnectCloudDB.getInstance();
            agConnectCloudDB.createObjectType(ObjectTypeInfoHelper.getObjectTypeInfo());
         catch (AGConnectCloudDBException e) 
            e.printStackTrace();
        
    

    public void openDb(OnDBZoneOpen onDBZoneOpen) 
        CloudDBZoneConfig mConfig = new CloudDBZoneConfig(Constants.DB_ZONE_NAME,
                CloudDBZoneConfig.CloudDBZoneSyncProperty.CLOUDDBZONE_CLOUD_CACHE,
                CloudDBZoneConfig.CloudDBZoneAccessProperty.CLOUDDBZONE_PUBLIC);
        mConfig.setPersistenceEnabled(true);
        Task<CloudDBZone> openDBZoneTask = agConnectCloudDB.openCloudDBZone2(mConfig, true);
        openDBZoneTask.addOnSuccessListener(cloudDBZone -> 
            Log.i(TAG, "open cloudDBZone success");
            this.cloudDBZone = cloudDBZone;
            onDBZoneOpen.isDBZoneOpen(true, this.cloudDBZone);
        ).addOnFailureListener(e -> 
            Log.w(TAG, "open cloudDBZone failed for " + e.getMessage());
            onDBZoneOpen.isDBZoneOpen(false, null);
        );
    

    public void closeDb(Context context) 
        try 
            agConnectCloudDB.closeCloudDBZone(cloudDBZone);
         catch (AGConnectCloudDBException e) 
            e.printStackTrace();
        
    

5.初始化云数据库SDK，在Application类中调用如下方法。

public void init(Context context) 
    AGConnectCloudDB.initialize(context);
    try 
      agConnectCloudDB = AGConnectCloudDB.getInstance();
      agConnectCloudDB.createObjectType(ObjectTypeInfoHelper.getObjectTypeInfo());
     catch (AGConnectCloudDBException e) 
        e.printStackTrace();
    

6.建立与云数据库的连接。

    CloudDBZoneConfig mConfig = new CloudDBZoneConfig(Constants.DB_ZONE_NAME,
            CloudDBZoneConfig.CloudDBZoneSyncProperty.CLOUDDBZONE_CLOUD_CACHE,
            CloudDBZoneConfig.CloudDBZoneAccessProperty.CLOUDDBZONE_PUBLIC);
    mConfig.setPersistenceEnabled(true);
    Task<CloudDBZone> openDBZoneTask = agConnectCloudDB.openCloudDBZone2(mConfig, true);
    openDBZoneTask.addOnSuccessListener(cloudDBZone -> 
        AppLog.logI(TAG, "cloudDBZOne Open");
        this.cloudDBZone = cloudDBZone;
        onDBZoneOpen.isDBZoneOpen(true, this.cloudDBZone);
    ).addOnFailureListener(e -> 
        AppLog.logW(TAG, "open cloudDBZone failed for " + e.getMessage());
        onDBZoneOpen.isDBZoneOpen(false, null);
    );

7.设置数据库连接关闭函数。

public void closeDb(Context context) 
    try 
        agConnectCloudDB.closeCloudDBZone(cloudDBZone);
     catch (AGConnectCloudDBException e) 
        AppLog.logW(TAG,"close the DBZone "+e.getMessage());
    

8.输入用户信息。

User user= new User();
user.setUserEmail(etEmail.getText().toString());
user.setUserName(etEmail.getText().toString());
user.setUserPhone(etMobile.getText().toString());
user.setUserId((int) System.currentTimeMillis());
user.setUserProfilePic(uri.toString());
user.setUserShadowFlag(true);
updateProfileData(user);
userProfile = new ViewModelProvider(LoginActivity.this).get(UserProfile.class);
 
public void updateProfileData(User user)
 
     userProfile.saveUser(user, this);
 

9.保存用户信息，检查是否成功保存。

public void saveUser(User user, Context context) 

    CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
        if (isConnected && cloudDBZone != null) 
            if (cloudDBZone == null) 
                return;
             else 
                Task<Integer> insertTask = cloudDBZone.executeUpsert(user);
                insertTask.addOnSuccessListener(integer -> 
                    userMutableLiveData.setValue(true);
                    CloudDBHelper.getInstance().closeDb(context);
                ).addOnFailureListener(e -> 
                    userMutableLiveData.setValue(false);
                    CloudDBHelper.getInstance().closeDb(context);
                );
            
        
    );

10.用户信息保存结果。

​

集成云存储

1.添加依赖。

dependencies

implementation "com.huawei.agconnect:agconnect-storage:<storage_version>"

说明：请根据​​开发文档​​集成​​最新版本的云存储​​，示例集成的是1.3.1.100版本。

2.初始化云存储。

StorageReference storageReference = TikTokSampleApplication.getStorageManagement().getStorageReference("tiktoksample/user_video/"+file.getName());

3.设置云存储的ViewModel。

public class TikTokSampleViewModel extends ViewModel 

    private static final String TAG = "TikTokSampleViewModel";
    private MutableLiveData<List<VideoUpload>> userUploadedVideoList;
    private MutableLiveData<List<VideoComments>> userVideoComentsList;
    private MutableLiveData<Uri> uploadFileLiveData;
    private MutableLiveData<Boolean> insertVideoData;

    private MutableLiveData<Integer> insertVideoComment;
    private MutableLiveData<Integer> updateVideoLike;

    private OnApiError onApiError;

    public LiveData<Integer> insertCommentForVideo() 
        if (insertVideoData == null) 
            insertVideoComment = new MutableLiveData<>();
        
        return insertVideoComment;
    

    public LiveData<Integer> updateLikeForVideo() 
        if (updateVideoLike == null) 
            updateVideoLike = new MutableLiveData<>();
        
        return updateVideoLike;
    


    public LiveData<Uri> uploadFileLiveData() 
        if (uploadFileLiveData == null) 
            uploadFileLiveData = new MutableLiveData<>();
        
        return uploadFileLiveData;
    

    public LiveData<Boolean> insertUserVideoData() 
        if (insertVideoData == null) 
            insertVideoData = new MutableLiveData<>();
        
        return insertVideoData;
    

    public void uploadFile(StorageReference reference, String fileName, File filePath, OnApiError onApiError) 
        this.onApiError = onApiError;
        UploadTask task = reference.putFile(filePath);
        task.addOnSuccessListener(uploadSuccessListener)
                .addOnFailureListener(uploadFailureListener);
    

    OnSuccessListener<UploadTask.UploadResult> uploadSuccessListener = new OnSuccessListener<UploadTask.UploadResult>() 
        @Override
        public void onSuccess(UploadTask.UploadResult uploadResult) 
            uploadResult.getStorage().getDownloadUrl().addOnSuccessListener(downloadLink)
                    .addOnFailureListener(downloadUriFailureListener);
        
    ;

    OnSuccessListener<Uri> downloadLink = new OnSuccessListener<Uri>() 
        @Override
        public void onSuccess(Uri uri) 
            uploadFileLiveData.postValue(uri);
        
    ;

    OnFailureListener uploadFailureListener = new OnFailureListener() 
        @Override
        public void onFailure(Exception e) 
            if (onApiError != null) 
                onApiError.onError("Error in uploading file to server", e);
            
        
    ;

    OnFailureListener downloadUriFailureListener = new OnFailureListener() 
        @Override
        public void onFailure(Exception e) 
            if (onApiError != null) 
                onApiError.onError("Failed in getting uri", e);
            
        
    ;


    public void insertUserVideoData(Context context, VideoUpload videoupload, OnApiError onApiError) 
        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (isConnected && cloudDBZone != null) 
                if (cloudDBZone == null) 
                    return;
                 else 
                    Task<Integer> insertTask = cloudDBZone.executeUpsert(videoupload);
                    insertTask.addOnSuccessListener(integer -> 
                        insertVideoData.setValue(true);
                        CloudDBHelper.getInstance().closeDb(context);
                    ).addOnFailureListener(e -> 
                        onApiError.onError(e.getLocalizedMessage(), e);
                        CloudDBHelper.getInstance().closeDb(context);
                    );
                
            
        );
    

    public void insertUserData(Context context, User userData, OnApiError onApiError) 
        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (isConnected && cloudDBZone != null) 
                if (cloudDBZone == null) 
                    return;
                 else 
                    Task<Integer> insertTask = cloudDBZone.executeUpsert(userData);
                    insertTask.addOnSuccessListener(integer -> 
                        insertVideoData.setValue(true);
                        CloudDBHelper.getInstance().closeDb(context);
                    ).addOnFailureListener(e -> 
                        onApiError.onError(e.getLocalizedMessage(), e);
                        CloudDBHelper.getInstance().closeDb(context);
                    );
                
            
        );
    

    public void getUserList(Context context, OnApiError onApiError) 
        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (cloudDBZone == null) 
                AppLog.logE(TAG, "CloudDBZone is null, try re-open it");
                return;
            
            Task<CloudDBZoneSnapshot<User>> queryTask = cloudDBZone.executeQuery(
                    CloudDBZoneQuery.where(User.class),
                    CloudDBZoneQuery.CloudDBZoneQueryPolicy.POLICY_QUERY_FROM_CLOUD_ONLY);
            queryTask.addOnSuccessListener((OnSuccessListener<CloudDBZoneSnapshot<User>>) snapshot -> processQueryResult(snapshot)).addOnFailureListener(new OnFailureListener() 
                @Override
                public void onFailure(Exception e) 
                    AppLog.logE(getClass().getName(), "Error in getting data from user table");
                
            );

        );
    

    private void processQueryResult(CloudDBZoneSnapshot<User> snapshot) 
        CloudDBZoneObjectList<User> bookInfoCursor = snapshot.getSnapshotObjects();
        List<User> bookInfoList = new ArrayList<>();
        try 
            while (bookInfoCursor.hasNext()) 
                User userInfo = bookInfoCursor.next();
                bookInfoList.add(userInfo);
            
         catch (AGConnectCloudDBException e) 
            AppLog.logE(TAG, "processQueryResult: " + e.getMessage());
        

        AppLog.logE(getClass().getName(), "We got user data " + bookInfoList.toString());
        snapshot.release();
    


    public void updateLikeCount(VideoUpload videoUpload) 
        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (cloudDBZone == null) 
                AppLog.logE(TAG, "CloudDBZone is null, try re-open it");
                return;
            
            Task<Integer> queryTask = cloudDBZone.executeUpsert(videoUpload);
            queryTask
                    .addOnSuccessListener(integer ->
                            updateVideoLike.postValue(integer)
                    )
                    .addOnFailureListener(e -> 
                        onApiError.onError(e.getLocalizedMessage(), e);
            );

        );
    

    public void enterCommentForVideo(VideoComments videoComments, OnApiError onApiError) 

        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 

            if (cloudDBZone == null) 
                AppLog.logE(TAG, TikTokSampleApplication.getInstance().getString(R.string.err_cloud_db_zone));
                onApiError.onError(TikTokSampleApplication.getInstance().getString(R.string.err_cloud_db_zone), new Throwable(TikTokSampleApplication.getInstance().getString(R.string.err_cloud_db_zone)));
                return;
            

            Task<Integer> enterComment = cloudDBZone.executeUpsert(videoComments);
            enterComment.addOnSuccessListener(integer -> 
                insertVideoComment.postValue(integer);
            ).addOnFailureListener(e -> 
                onApiError.onError(e.getMessage(), e);
            );

        );

    
    public LiveData<List<VideoUpload>> getUsersListOfVideo()
        if(userUploadedVideoList==null)
            userUploadedVideoList = new MutableLiveData<>();
        
        return userUploadedVideoList;
    
    public LiveData<List<VideoComments>> getUsersListOfComments()
        if(userVideoComentsList==null)
            userVideoComentsList = new MutableLiveData<>();
        
        return userVideoComentsList;
    
    public void getAllUserUploadedVideoList(String userEmail, OnApiError onApiError)

        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (cloudDBZone == null) 
                AppLog.logE(TAG, "CloudDBZone is null, try re-open it");
                return;
            
            Task<CloudDBZoneSnapshot<VideoUpload>> queryTask = cloudDBZone.executeQuery(
                    CloudDBZoneQuery.where(VideoUpload.class).equalTo("user_email", userEmail),
                    CloudDBZoneQuery.CloudDBZoneQueryPolicy.POLICY_QUERY_FROM_CLOUD_ONLY);
            queryTask.addOnSuccessListener(this::processVideoUploadResult).addOnFailureListener(new OnFailureListener() 
                @Override
                public void onFailure(Exception e) 
                    AppLog.logE(getClass().getName(), "Error in getting data from user table");
                
            );

        );

    

    private void processVideoUploadResult(CloudDBZoneSnapshot<VideoUpload> snapshot) 
        CloudDBZoneObjectList<VideoUpload> bookInfoCursor = snapshot.getSnapshotObjects();
        List<VideoUpload> videoUploads = new ArrayList<>();
        try 
            while (bookInfoCursor.hasNext()) 
                VideoUpload userInfo = bookInfoCursor.next();
                videoUploads.add(userInfo);
            
            userUploadedVideoList.postValue(videoUploads);
         catch (AGConnectCloudDBException e) 
            AppLog.logE(TAG, "processQueryResult: " + e.getMessage());
        

        AppLog.logE(getClass().getName(), "We got user data " + videoUploads.toString());
        snapshot.release();
    
    public void getComments(Long videoId)
    
        CloudDBHelper.getInstance().openDb((isConnected, cloudDBZone) -> 
            if (cloudDBZone == null) 
                AppLog.logE("TAG", "CloudDBZone is null, try re-open it");
                return;
            
            Task<CloudDBZoneSnapshot<VideoComments>> queryTask = cloudDBZone.executeQuery(
                    CloudDBZoneQuery.where(VideoComments.class).equalTo("video_id",videoId),
                    CloudDBZoneQuery.CloudDBZoneQueryPolicy.POLICY_QUERY_FROM_CLOUD_ONLY);
            queryTask.addOnSuccessListener(snapshot -> processQueryCommentsResult(snapshot))
                    .addOnFailureListener(new OnFailureListener() 
                        @Override
                        public void onFailure(Exception e) 
                            AppLog.logE(getClass().getName(), "Error in getting data from user table");
                        
                    );

        );
    
    private void processQueryCommentsResult(CloudDBZoneSnapshot<VideoComments> snapshot) 
        CloudDBZoneObjectList<VideoComments> videoInfoCursor = snapshot.getSnapshotObjects();
        List<VideoComments> commentList = new ArrayList<>();
        try 
            while (videoInfoCursor.hasNext()) 
                VideoComments videoComments = videoInfoCursor.next();
                commentList.add(videoComments);
            

            userVideoComentsList.postValue(commentList);
         catch (AGConnectCloudDBException e) 
            AppLog.logE("TAG", "processQueryResult: " + e.getMessage());
        
        snapshot.release();
        Log.e("new test", "new test");
    

4.上传文件。

private void uploadVideoToStorage(String filePath)
    File file = new File(filePath);
    StorageReference storageReference = TikTokSampleApplication.getStorageManagement().getStorageReference("tiktoksample/user_video/"+file.getName());
    tiktokStorageViewModel.uploadFile(storageReference,
            file.getName(), file, onApiError);

5.查存储结果。

​

​

集成视频编辑服务

集成视频编辑服务能够简易您的视频编辑功能的开发。该服务提供下述SDK：

UI SDK：提供产品级UI界面，集成简单。

原子能力SDK：提供数百个原子能力接口，包含多个AI算法能力接口，可根据业务场景灵活选择。

这两种方式均提供导入、编辑、渲染、导出、媒体资源管理等一站式视频编辑能力，为您提供性能优异、简单易用、高兼容性的接口，帮助您轻松地构建应用。您可根据使用场景选择不同的集成方式获取视频编辑能力。

1.前往AppGallery Connect开通视频编辑服务。

​

2.添加如下依赖。

dependencies 

implementation com.huawei.hms:video-editor-ui:<Latest_videoEditor_kit_version>

说明：根据​​开发文档​​集成​​最新版本的视频编辑服务​​，示例集成的是1.1.0.301版本。

3.在Manifest文件中添加权限。

<!-- Vibrate -->
<uses-permission android:name="android.permission.VIBRATE" />
<!-- Microphone -->
<uses-permission android:name="android.permission.RECORD_AUDIO" />
<!-- Write into storage -->
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
<!-- Read from storage -->
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
<!-- Connect to the Internet -->
<uses-permission android:name="android.permission.INTERNET" />
<!-- Listen for the network status -->
<uses-permission android:name="android.permission.CHANGE_NETWORK_STATE" />
<!-- Obtain the network status -->
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />

4.应用初始化时调用setApiKey方法设置api_key（仅需设置一次）。

    UUID uuid = UUID.randomUUID();
    MediaApplication.getInstance().setLicenseId(uuid.toString());
    AGConnectServicesConfig config = AGConnectServicesConfig.fromContext(this);
    MediaApplication.getInstance().setApiKey(config.getString("client/api_key"));
    MediaApplication.getInstance().setOnMediaExportCallBack(CALL_BACK);

5.调用START_MODE_IMPORT_FROM_DRAFT，通过草稿模式进入Video Editor Kit UI界面。

private void initEvent() 
    draftAdapter.setSelectedListener(new DraftAdapter.OnStyleSelectedListener() 
        @Override
        public void onStyleSelected(int position) 
            String draftId = draftInfos.get(position).getDraftId();
            Log.d("Video_path", draftInfos.get(position).getDraftId()+" "+draftInfos.get(position).getDraftCoverPath());
            MediaApplication.getInstance()
                    .launchEditorActivity(VideoEditActivity.this,
                            new VideoEditorLaunchOption.Builder()
                                    .setStartMode(MediaApplication.START_MODE_IMPORT_FROM_DRAFT)
                                    .setDraftId(draftId)
                                    .build());
        
    );

    draftAdapter.setLongSelectedListener(new DraftAdapter.OnStyleLongSelectedListener() 
        @Override
        public void onStyleLongSelected(View v, int position) 
            VideoEditActivity.this.position = position;
            PopupMenu popup = new PopupMenu(VideoEditActivity.this, v);
            MenuInflater inflater = popup.getMenuInflater();
            inflater.inflate(R.menu.menu, popup.getMenu());
            popup.setOnMenuItemClickListener(VideoEditActivity.this);
            popup.show();
        
    );
    mSetting.setOnClickListener(v -> this.startActivity(new Intent(VideoEditActivity.this, SettingActivity.class)));

6.调用setOnMediaExportCallBack设置导出的回调。

private final MediaExportCallBack CALL_BACK = new MediaExportCallBack() 
    @Override
    public void onMediaExportSuccess(MediaInfo mediaInfo) 
        AppLog.logE(getClass().getSimpleName(),"length of media info "+mediaInfo.getMediaPath().length());
        mediaPath = mediaInfo.getMediaPath();
        Log.i(TAG, "The current video export path is" + mediaPath);
        uploadVideoToStorage(mediaPath);
    
    @Override
    public void onMediaExportFailed(int errorCode) 
        Log.d(TAG, "errorCode" + errorCode);
    
;

集成图像服务

图像服务通过华为场景智能设计服务SDK和华为场景动效服务SDK为您提供图像智能编辑与设计、场景动效制作能力。通过集成该服务提供的SDK，您可以快速集成24种滤镜、9大智能动效、图像主题标签、贴纸花字、图片裁剪、动画等能力。

1.添加如下依赖。

dependencies 

implementation "com.huawei.hms:image-vision:<latest_version_image_vision>"

说明：根据​​开发文档​​集成​​最新版本的图像服务​​，示例集成的是1.0.3.301版本。

2.在Manifest文件中声明如下权限。

<uses-permission android:name="android.permission.INTERNET"/>

<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE"/>

<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

<uses-permission android:name="android.permission.ACCESS_WIFI_
以上是关于多服务场景化解决方案短视频剪辑(ShortVideoCreator)的主要内容，如果未能解决你的问题，请参考以下文章
 
 短视频运营短视频剪辑 ③ ( 添加字幕 | 智能识别字幕 | 修改字幕 | 字幕预设 | 字幕换行 | 使用字幕作为封面主题 )
 短视频运营短视频剪辑 ⑤ ( 视频素材使用 | 设置插入后的视频素材属性 | 设置画面 | 设置音频 | 设置变速 | 设置动画 | 设置调节 )
 短视频运营短视频剪辑 ④ ( 将文字转音频添加到视频中 | 编辑 TTS 音频信息 | 组合重叠人声音频添加 | 音频爆音处理 )
 AI智能剪辑，仅需2秒一键提取精彩片段
 论文阅读笔记XLINK：淘宝短视频传输的多径QUIC协议
 阿里云短视频服务快速使用