适用于 Flutter 的腾讯云点播上传 SDK.rar

package com.tencent.ugcupload.demo.videoupload.impl; import android.app.Activity; import android.content.Context; import android.content.SharedPreferences; import android.net.Uri; import android.os.Bundle; import android.os.Handler; import android.text.TextUtils; import android.util.Log; import com.tencent.cos.xml.CosXmlService; import com.tencent.cos.xml.CosXmlServiceConfig; import com.tencent.cos.xml.exception.CosXmlClientException; import com.tencent.cos.xml.exception.CosXmlServiceException; import com.tencent.cos.xml.listener.CosXmlProgressListener; import com.tencent.cos.xml.listener.CosXmlResultListener; import com.tencent.cos.xml.model.CosXmlRequest; import com.tencent.cos.xml.model.CosXmlResult; import com.tencent.cos.xml.model.object.InitMultipartUploadRequest; import com.tencent.cos.xml.model.object.InitMultipartUploadResult; import com.tencent.cos.xml.model.object.PutObjectRequest; import com.tencent.cos.xml.transfer.COSXMLUploadTask; import com.tencent.cos.xml.transfer.TransferConfig; import com.tencent.cos.xml.transfer.TransferManager; import com.tencent.cos.xml.transfer.TransferState; import com.tencent.cos.xml.transfer.TransferStateListener; import com.tencent.ugcupload.demo.videoupload.TXUGCPublishTypeDef; import com.tencent.ugcupload.demo.videoupload.impl.compute.TXHttpTaskMetrics; import com.tencent.ugcupload.demo.videoupload.impl.compute.TXOnGetHttpTaskMetrics; import org.json.JSONException; import org.json.JSONObject; import java.io.File; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.InetAddress; import java.util.List; import java.util.Map; import java.util.Timer; import java.util.TimerTask; import okhttp3.Call; import okhttp3.Callback; import okhttp3.Response; /** * 视频上传客户端 */ public class TVCClient { private final static String TAG = "TVC-Client"; private Context context; private Handler mainHandler; private boolean busyFlag = false; private boolean cancleFlag = false; private TVCUploadInfo uploadInfo; private UGCClient ugcClient; private TVCUploadListener tvcListener; private int cosAppId; //点播上传用到的COS appid private int userAppId; //客户自己的appid，数据上报需要 private String uploadRegion = ""; private String cosBucket; private String cosTmpSecretId = ""; private String cosTmpSecretKey = ""; private String cosToken = ""; private long cosExpiredTime; private long localTimeAdvance = 0; //本地时间相对unix时间戳提前间隔 private String cosVideoPath; private String videoFileId; private String cosCoverPath; private boolean isOpenCosAcc = false; //是否使用cos动态加速 private String cosAccDomain = ""; //动态加速域名 private String cosHost = ""; private String domain; private String cosIP = ""; private String vodSessionKey = null; private long reqTime = 0; //各阶段开始请求时间 private long initReqTime = 0; //上传请求时间，用于拼接reqKey。串联请求 private String customKey = ""; //用于数据上报 private CosXmlService mCosXmlService; private COSXMLUploadTask mCOSXMLUploadTask; private TransferConfig mTransferConfig; private TransferManager mTransferManager; // 断点重传session本地缓存 // 以文件路径作为key值得，存储的内容是<session, uploadId, fileLastModify, expiredTime> private static final String LOCALFILENAME = "TVCSession"; private SharedPreferences mSharedPreferences; private SharedPreferences.Editor mShareEditor; private String uploadId = null; private long fileLastModTime = 0; //视频文件最后修改时间 private long coverFileLastModTime = 0; //封面文件最后修改时间 private boolean enableResume = true; private boolean enableHttps = false; private UGCReport.ReportInfo reportInfo; private static final int VIRTUAL_TOTAL_PERCENT = 10; //前后的虚拟进度占的百分比 private TimerTask virtualProgress = null; //虚拟进度任务 private Timer mTimer; //定时器 private int virtualPercent = 0; //虚拟进度 private boolean realProgressFired = false; private int vodCmdRequestCount = 0; //vod信令重试次数 private String mainVodServerErrMsg; //主域名请求失败的msg，用于备份域名都请求失败后，带回上报。 /** * 初始化上传实例 * * @param signature 签名 * @param iTimeOut 超时时间 */ public TVCClient(Context context, String customKey, String signature, boolean enableResume, boolean enableHttps, int iTimeOut) { this.context = context.getApplicationContext(); ugcClient = UGCClient.getInstance(signature, iTimeOut); mainHandler = new Handler(context.getMainLooper()); mSharedPreferences = context.getSharedPreferences(LOCALFILENAME, Activity.MODE_PRIVATE); mShareEditor = mSharedPreferences.edit(); this.enableResume = enableResume; this.enableHttps = enableHttps; this.customKey = customKey; reportInfo = new UGCReport.ReportInfo(); clearLocalCache(); } /** * 初始化上传实例 * * @param ugcSignature 签名 */ public TVCClient(Context context, String customKey, String ugcSignature, boolean resumeUpload, boolean enableHttps) { this(context, customKey, ugcSignature, resumeUpload, enableHttps, 8); } // 清理一下本地缓存，过期的删掉 private void clearLocalCache() { if (mSharedPreferences != null) { try { Map<String, ?> allContent = mSharedPreferences.getAll(); //注意遍历map的方法 for (Map.Entry<String, ?> entry : allContent.entrySet()) { JSONObject json = new JSONObject((String) entry.getValue()); long expiredTime = json.optLong("expiredTime", 0); // 过期了清空key if (expiredTime < System.currentTimeMillis() / 1000) { mShareEditor.remove(entry.getKey()); mShareEditor.commit(); } } } catc