初次提交

DownloadFileInfo.cs

@@ -0,0 +1,16 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using UnityEngine;
+
+namespace TModule.Runtime
+{
+    public class DownloadFileInfo
+    {
+        public string m_url;
+        public string m_savePath;
+        public Action<float, long, long> onProgress;
+        public Action<string> onErroe;
+        public Action onOver;
+    }
+}

DownloadFileInfo.cs.meta

@@ -0,0 +1,11 @@
+fileFormatVersion: 2
+guid: f78430bf86a047d45b47e688eb9a1f20
+MonoImporter:
+  externalObjects: {}
+  serializedVersion: 2
+  defaultReferences: []
+  executionOrder: 0
+  icon: {instanceID: 0}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

DownloadManager.cs

@@ -0,0 +1,159 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using UnityEngine;
+
+namespace TModule.Runtime
+{
+    public class DownloadManager : MonoBehaviour
+    {
+        private List<DownloadRoutine> _downloadRoutines = new List<DownloadRoutine>();
+
+        private Queue<DownloadFileInfo> downloadFiles = new Queue<DownloadFileInfo>();
+
+        /// <summary>
+        /// 最大下载器数量
+        /// </summary>
+        public int m_maxCount = 5;
+
+        private void Awake()
+        {
+            for (int i = 0; i < m_maxCount; i++)
+            {
+                _downloadRoutines.Add(new DownloadRoutine());
+            }
+        }
+
+        /// <summary>
+        /// 暂停下载
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="savePath"></param>
+        public void StopDownload(string url, string savePath)
+        {
+            _downloadRoutines.Find(p => p.DownLoadUrl == url && p.FileSavePath == savePath)?.StopDownload();
+        }
+
+        /// <summary>
+        /// 暂停下载
+        /// </summary>
+        /// <param name="fileInfo"></param>
+        public void StopDownload(DownloadFileInfo fileInfo)
+        {
+            StopDownload(fileInfo.m_url, fileInfo.m_savePath);
+        }
+
+        /// <summary>
+        /// 暂停所有下载
+        /// </summary>
+        public void StopAllDownload()
+        {
+            foreach (var item in _downloadRoutines)
+            {
+                if (!item.IsLeisure)
+                    item.StopDownload();
+            }
+        }
+
+        /// <summary>
+        /// 开始下载
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="savePath"></param>
+        /// <param name="onProgress"></param>
+        /// <param name="onOver"></param>
+        /// <param name="onError"></param>
+        public void StartDownload(string url,string savePath,Action<float,long,long>onProgress=null,Action onOver=null,Action<string> onError=null)
+        {
+            StartDownload(new DownloadFileInfo
+            {
+                m_savePath = savePath,
+                m_url = url,
+                onErroe = onError,
+                onOver = onOver,
+                onProgress = onProgress
+            });
+        }
+
+        /// <summary>
+        /// 开始下载
+        /// </summary>
+        /// <param name="fileInfo"></param>
+        public void StartDownload(DownloadFileInfo fileInfo)
+        {
+            DownloadRoutine routine = GetLeisureDownloadRoutine(); 
+            if (routine == null)
+                downloadFiles.Enqueue(fileInfo);
+            else
+            {
+                routine.onProgress = fileInfo.onProgress;
+                routine.onDownloadOver = ()=> { fileInfo.onOver?.Invoke(); CheckIsOver();};
+                routine.onError = fileInfo.onErroe;
+                routine.StartDownload(fileInfo.m_url, fileInfo.m_savePath);
+            }
+        }
+
+        /// <summary>
+        /// 批量下载
+        /// </summary>
+        /// <param name="fileInfos"></param>
+        public void BatchDownload(IEnumerable<DownloadFileInfo> fileInfos)
+        {
+            foreach (var item in fileInfos)
+            {
+                StartDownload(item);
+            }
+        }
+
+        /// <summary>
+        /// 继续下载
+        /// </summary>
+        /// <param name="url"></param>
+        /// <param name="savePath"></param>
+        public void ContinueDownload(string url,string savePath)
+        {
+            _downloadRoutines.Find(p => p.DownLoadUrl == url && p.FileSavePath == savePath)?.ContinueDownload();
+        }
+
+        /// <summary>
+        /// 继续下载
+        /// </summary>
+        /// <param name="fileInfo"></param>
+        public void ContinueDownload(DownloadFileInfo fileInfo)
+        {
+            ContinueDownload(fileInfo.m_url, fileInfo.m_savePath);
+        }
+
+        /// <summary>
+        /// 全部继续下载
+        /// </summary>
+        public void ContinueAllDownload()
+        {
+            foreach (var item in _downloadRoutines)
+            {
+                if (!item.IsLeisure && item.IsStop)
+                    item.ContinueDownload();
+            }
+        }
+
+        private void CheckIsOver()
+        {
+            lock(downloadFiles)
+            {
+                if (downloadFiles.Count > 0)
+                {
+                    StartDownload(downloadFiles.Dequeue());
+                }
+            }
+        }
+
+        /// <summary>
+        /// 获取空闲下载器
+        /// </summary>
+        /// <returns></returns>
+        private DownloadRoutine GetLeisureDownloadRoutine()
+        {
+            return _downloadRoutines.Find(p => p.IsLeisure);
+        }
+    }
+}

DownloadManager.cs.meta

@@ -0,0 +1,11 @@
+fileFormatVersion: 2
+guid: d526844b7ba8798409d04a2e12a1a7ec
+MonoImporter:
+  externalObjects: {}
+  serializedVersion: 2
+  defaultReferences: []
+  executionOrder: 0
+  icon: {instanceID: 0}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

DownloadRoutine.cs

@@ -0,0 +1,155 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.IO;
+using System.Threading.Tasks;
+using UnityEngine;
+using UnityEngine.Networking;
+
+namespace TModule.Runtime
+{
+    public class DownloadRoutine
+    {
+        /// <summary>
+        /// 下载路径
+        /// </summary>
+        public string DownLoadUrl { get; set; }
+
+        /// <summary>
+        /// 文件保存路径
+        /// </summary>
+        public string FileSavePath { get; set; }
+
+        /// <summary>
+        /// 是否空闲
+        /// </summary>
+        public bool IsLeisure { get; set; } = true;
+
+        /// <summary>
+        /// 下载总大小
+        /// </summary>
+        private long _totalSzie;
+
+        public long TotalSize => _totalSzie;
+
+        /// <summary>
+        /// 已下载大小
+        /// </summary>
+        private long _currentDownloadSize;
+
+        public long CurrentDownloadSize => _currentDownloadSize;
+
+        //停止下载
+        private bool _isStop;
+
+        public bool IsStop
+        {
+            get => _isStop ||
+#if UNITY_EDITOR 
+                !UnityEditor.EditorApplication.isPlaying
+
+#else
+            !Application.isPlaying
+#endif
+                ;
+            set => _isStop = value;
+        }
+
+        public Action onDownloadOver;
+
+        /// <summary>
+        /// 下载中事件 下载进度 总大小 已下载大小
+        /// </summary>
+        public Action<float,long,long> onProgress;
+
+        public Action<string> onError;
+
+        /// <summary>
+        /// 开始下载
+        /// </summary>
+        /// <param name="url"></param>
+        /// <returns></returns>
+        public async Task StartDownload(string url,string fileSavePath)
+        {
+            DownLoadUrl = url;
+            FileSavePath = fileSavePath;
+            IsStop = false;
+            _currentDownloadSize = 0;
+            IsLeisure = false;
+            UnityWebRequest webRequest = UnityWebRequest.Head(DownLoadUrl);
+            await webRequest.SendWebRequest();
+            if (webRequest.result == UnityWebRequest.Result.ConnectionError || webRequest.result == UnityWebRequest.Result.ProtocolError)
+            {
+                onError?.Invoke(webRequest.error);
+                Debug.Log(webRequest.error); //出现错误 输出错误信息
+            }
+            else
+            {
+                string info = webRequest.GetResponseHeader("Content-Length");
+                _totalSzie = long.Parse(info);
+                await DownloadFile();
+            }
+        }
+
+        public void StopDownload()
+        {
+            IsStop = true;
+        }
+
+        public async Task ContinueDownload()
+        {
+            if (IsLeisure) return;
+            IsStop = false;
+            await DownloadFile();
+        }
+
+        async Task DownloadFile()
+        {
+            string dirPath = Path.GetDirectoryName(FileSavePath);
+            if (!Directory.Exists(dirPath))
+                Directory.CreateDirectory(dirPath);
+            using (FileStream fs = new FileStream(FileSavePath, FileMode.OpenOrCreate, FileAccess.Write,FileShare.ReadWrite))
+            {
+                _currentDownloadSize = fs.Length;
+
+                if (_currentDownloadSize < _totalSzie)
+                {
+                    fs.Seek(_currentDownloadSize, SeekOrigin.Begin);
+                    UnityWebRequest request = UnityWebRequest.Get(DownLoadUrl);
+                    request.SetRequestHeader("Range", $"bytes={_currentDownloadSize}-");
+                    request.SendWebRequest();
+                    if (request.result == UnityWebRequest.Result.ConnectionError || request.result == UnityWebRequest.Result.ProtocolError)
+                    {
+                        onError?.Invoke(request.error);
+                        Debug.Log(request.error); //出现错误 输出错误信息
+                    }
+                    else
+                    {
+                        long index = 0;
+                        while (_currentDownloadSize < _totalSzie)
+                        {
+                            if (IsStop) break;
+                            byte[] data = request.downloadHandler.data;
+                            if (data != null)
+                            {
+                                long length = data.Length - index;
+                                fs.Write(data, (int)index, (int)length);
+                                index += length;
+                                _currentDownloadSize += length;
+                                onProgress?.Invoke((float)Math.Round((double)_currentDownloadSize / _totalSzie,2), _totalSzie, _currentDownloadSize);
+                                if (_currentDownloadSize >= _totalSzie)
+                                {
+                                    //下载完成
+                                    IsLeisure = true;
+                                    onDownloadOver?.Invoke();
+                                    break;
+                                }
+                            }
+                            await Task.Yield();
+                        }
+                    }
+                }
+            }
+        }
+    }
+}

DownloadRoutine.cs.meta

@@ -0,0 +1,11 @@
+fileFormatVersion: 2
+guid: ef3321e1cf28b294ea746927f92a0489
+MonoImporter:
+  externalObjects: {}
+  serializedVersion: 2
+  defaultReferences: []
+  executionOrder: 0
+  icon: {instanceID: 0}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: 

ExtensionAsyncOperation.cs

@@ -0,0 +1,18 @@
+using System.Collections;
+using System.Collections.Generic;
+using System.Runtime.CompilerServices;
+using System.Threading.Tasks;
+using UnityEngine;
+
+namespace TModule.Runtime
+{
+    public static class ExtensionAsyncOperation
+    {
+        public static TaskAwaiter GetAwaiter(this AsyncOperation asyncOp)
+        {
+            var tcs = new TaskCompletionSource<object>();
+            asyncOp.completed += obj => { tcs.SetResult(null); };
+            return ((Task)tcs.Task).GetAwaiter();
+        }
+    }
+}

ExtensionAsyncOperation.cs.meta

@@ -0,0 +1,11 @@
+fileFormatVersion: 2
+guid: 9af226bf479be4e4892cbd92f0d26854
+MonoImporter:
+  externalObjects: {}
+  serializedVersion: 2
+  defaultReferences: []
+  executionOrder: 0
+  icon: {instanceID: 0}
+  userData: 
+  assetBundleName: 
+  assetBundleVariant: