Compare commits

...

4 Commits

Author SHA1 Message Date
何冠峰 07086b68c8 update extension sample
优化了抖音小游戏文件系统缓存机制
2025-02-11 18:44:51 +08:00
何冠峰 0a85f3126f update extension sample
优化了微信小游戏文件系统缓存机制。
2025-02-11 18:18:29 +08:00
何冠峰 efa4180340 update resource manager
UnloadUnusedAssetsOperation逻辑里移除了Resources.UnloadUnusedAssets调用
2025-02-11 18:15:45 +08:00
何冠峰 fb06f2aa11 update resource manager
UnloadAllAssetsAsync新增UnloadAllAssetsOptions参数
2025-02-11 17:32:31 +08:00
17 changed files with 217 additions and 400 deletions

View File

@ -3,38 +3,88 @@ using UnityEngine;
namespace YooAsset namespace YooAsset
{ {
public sealed class UnloadAllAssetsOptions
{
/// <summary>
/// 释放所有资源句柄,防止卸载过程中触发完成回调!
/// </summary>
public bool ReleaseAllHandles = true;
/// <summary>
/// 卸载过程中锁定加载操作,防止新的任务请求!
/// </summary>
public bool LockLoadOperation = true;
}
public sealed class UnloadAllAssetsOperation : AsyncOperationBase public sealed class UnloadAllAssetsOperation : AsyncOperationBase
{ {
private enum ESteps private enum ESteps
{ {
None, None,
CheckOptions,
ReleaseAll,
AbortDownload, AbortDownload,
CheckLoading, CheckLoading,
UnloadAll, DestroyAll,
Done, Done,
} }
private readonly ResourceManager _resManager; private readonly ResourceManager _resManager;
private readonly UnloadAllAssetsOptions _options;
private ESteps _steps = ESteps.None; private ESteps _steps = ESteps.None;
internal UnloadAllAssetsOperation(ResourceManager resourceManager) internal UnloadAllAssetsOperation(ResourceManager resourceManager, UnloadAllAssetsOptions options)
{ {
_resManager = resourceManager; _resManager = resourceManager;
_options = options;
} }
internal override void InternalOnStart() internal override void InternalOnStart()
{ {
_steps = ESteps.AbortDownload; _steps = ESteps.CheckOptions;
} }
internal override void InternalOnUpdate() internal override void InternalOnUpdate()
{ {
if (_steps == ESteps.None || _steps == ESteps.Done) if (_steps == ESteps.None || _steps == ESteps.Done)
return; return;
if (_steps == ESteps.CheckOptions)
{
if (_options == null)
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = $"{nameof(UnloadAllAssetsOptions)} is null.";
return;
}
// 设置锁定状态
if (_options.LockLoadOperation)
_resManager.LockLoadOperation = true;
_steps = ESteps.ReleaseAll;
}
if (_steps == ESteps.ReleaseAll)
{
// 清空所有场景句柄
_resManager.SceneHandles.Clear();
// 释放所有资源句柄
if (_options.ReleaseAllHandles)
{
foreach (var provider in _resManager.ProviderDic.Values)
{
provider.ReleaseAllHandles();
}
}
_steps = ESteps.AbortDownload;
}
if (_steps == ESteps.AbortDownload) if (_steps == ESteps.AbortDownload)
{ {
// 注意:终止所有下载任务 // 注意:终止所有下载任务
var loaderDic = _resManager._loaderDic; foreach (var loader in _resManager.LoaderDic.Values)
foreach (var loader in loaderDic.Values)
{ {
loader.AbortDownloadOperation(); loader.AbortDownloadOperation();
} }
@ -44,44 +94,32 @@ namespace YooAsset
if (_steps == ESteps.CheckLoading) if (_steps == ESteps.CheckLoading)
{ {
// 注意:等待所有任务完成 // 注意:等待所有任务完成
var providerDic = _resManager._providerDic; foreach (var provider in _resManager.ProviderDic.Values)
foreach (var provider in providerDic.Values)
{ {
if (provider.IsDone == false) if (provider.IsDone == false)
return; return;
} }
_steps = ESteps.UnloadAll; _steps = ESteps.DestroyAll;
} }
if (_steps == ESteps.UnloadAll) if (_steps == ESteps.DestroyAll)
{ {
var loaderDic = _resManager._loaderDic;
var providerDic = _resManager._providerDic;
// 清空所有场景句柄
_resManager._sceneHandles.Clear();
// 释放所有资源句柄
foreach (var provider in providerDic.Values)
{
provider.ReleaseAllHandles();
}
// 强制销毁资源提供者 // 强制销毁资源提供者
foreach (var provider in providerDic.Values) foreach (var provider in _resManager.ProviderDic.Values)
{ {
provider.DestroyProvider(); provider.DestroyProvider();
} }
// 强制销毁文件加载器 // 强制销毁文件加载器
foreach (var loader in loaderDic.Values) foreach (var loader in _resManager.LoaderDic.Values)
{ {
loader.DestroyLoader(); loader.DestroyLoader();
} }
// 清空数据 // 清空数据
providerDic.Clear(); _resManager.ProviderDic.Clear();
loaderDic.Clear(); _resManager.LoaderDic.Clear();
_resManager.LockLoadOperation = false;
// 注意:调用底层接口释放所有资源 // 注意:调用底层接口释放所有资源
Resources.UnloadUnusedAssets(); Resources.UnloadUnusedAssets();

View File

@ -31,17 +31,16 @@ namespace YooAsset
if (_steps == ESteps.UnloadUnused) if (_steps == ESteps.UnloadUnused)
{ {
var loaderDic = _resManager._loaderDic; var removeList = new List<LoadBundleFileOperation>(_resManager.LoaderDic.Count);
var removeList = new List<LoadBundleFileOperation>(loaderDic.Count);
// 注意:优先销毁资源提供者 // 注意:优先销毁资源提供者
foreach (var loader in loaderDic.Values) foreach (var loader in _resManager.LoaderDic.Values)
{ {
loader.TryDestroyProviders(); loader.TryDestroyProviders();
} }
// 获取销毁列表 // 获取销毁列表
foreach (var loader in loaderDic.Values) foreach (var loader in _resManager.LoaderDic.Values)
{ {
if (loader.CanDestroyLoader()) if (loader.CanDestroyLoader())
{ {
@ -54,13 +53,9 @@ namespace YooAsset
{ {
string bundleName = loader.LoadBundleInfo.Bundle.BundleName; string bundleName = loader.LoadBundleInfo.Bundle.BundleName;
loader.DestroyLoader(); loader.DestroyLoader();
_resManager._loaderDic.Remove(bundleName); _resManager.LoaderDic.Remove(bundleName);
} }
// 注意:调用底层接口释放所有资源
if (removeList.Count > 0)
Resources.UnloadUnusedAssets();
_steps = ESteps.Done; _steps = ESteps.Done;
Status = EOperationStatus.Succeed; Status = EOperationStatus.Succeed;
} }

View File

@ -9,9 +9,9 @@ namespace YooAsset
{ {
internal class ResourceManager internal class ResourceManager
{ {
internal readonly Dictionary<string, ProviderOperation> _providerDic = new Dictionary<string, ProviderOperation>(5000); internal readonly Dictionary<string, ProviderOperation> ProviderDic = new Dictionary<string, ProviderOperation>(5000);
internal readonly Dictionary<string, LoadBundleFileOperation> _loaderDic = new Dictionary<string, LoadBundleFileOperation>(5000); internal readonly Dictionary<string, LoadBundleFileOperation> LoaderDic = new Dictionary<string, LoadBundleFileOperation>(5000);
internal readonly List<SceneHandle> _sceneHandles = new List<SceneHandle>(100); internal readonly List<SceneHandle> SceneHandles = new List<SceneHandle>(100);
private long _sceneCreateIndex = 0; private long _sceneCreateIndex = 0;
private IBundleQuery _bundleQuery; private IBundleQuery _bundleQuery;
@ -20,6 +20,11 @@ namespace YooAsset
/// </summary> /// </summary>
public readonly string PackageName; public readonly string PackageName;
/// <summary>
/// 锁定加载操作
/// </summary>
public bool LockLoadOperation = false;
public ResourceManager(string packageName) public ResourceManager(string packageName)
{ {
@ -64,7 +69,7 @@ namespace YooAsset
{ {
string bundleName = mainLoader.LoadBundleInfo.Bundle.BundleName; string bundleName = mainLoader.LoadBundleInfo.Bundle.BundleName;
mainLoader.DestroyLoader(); mainLoader.DestroyLoader();
_loaderDic.Remove(bundleName); LoaderDic.Remove(bundleName);
} }
} }
@ -79,7 +84,7 @@ namespace YooAsset
{ {
string bundleName = dependLoader.LoadBundleInfo.Bundle.BundleName; string bundleName = dependLoader.LoadBundleInfo.Bundle.BundleName;
dependLoader.DestroyLoader(); dependLoader.DestroyLoader();
_loaderDic.Remove(bundleName); LoaderDic.Remove(bundleName);
} }
} }
} }
@ -92,6 +97,15 @@ namespace YooAsset
/// </summary> /// </summary>
public SceneHandle LoadSceneAsync(AssetInfo assetInfo, LoadSceneParameters loadSceneParams, bool suspendLoad, uint priority) public SceneHandle LoadSceneAsync(AssetInfo assetInfo, LoadSceneParameters loadSceneParams, bool suspendLoad, uint priority)
{ {
if (LockLoadOperation)
{
string error = $"The load operation locked !";
YooLogger.Error(error);
CompletedProvider completedProvider = new CompletedProvider(this, assetInfo);
completedProvider.SetCompletedWithError(error);
return completedProvider.CreateHandle<SceneHandle>();
}
if (assetInfo.IsInvalid) if (assetInfo.IsInvalid)
{ {
YooLogger.Error($"Failed to load scene ! {assetInfo.Error}"); YooLogger.Error($"Failed to load scene ! {assetInfo.Error}");
@ -106,14 +120,14 @@ namespace YooAsset
{ {
provider = new SceneProvider(this, providerGUID, assetInfo, loadSceneParams, suspendLoad); provider = new SceneProvider(this, providerGUID, assetInfo, loadSceneParams, suspendLoad);
provider.InitSpawnDebugInfo(); provider.InitSpawnDebugInfo();
_providerDic.Add(providerGUID, provider); ProviderDic.Add(providerGUID, provider);
OperationSystem.StartOperation(PackageName, provider); OperationSystem.StartOperation(PackageName, provider);
} }
provider.Priority = priority; provider.Priority = priority;
var handle = provider.CreateHandle<SceneHandle>(); var handle = provider.CreateHandle<SceneHandle>();
handle.PackageName = PackageName; handle.PackageName = PackageName;
_sceneHandles.Add(handle); SceneHandles.Add(handle);
return handle; return handle;
} }
@ -122,6 +136,15 @@ namespace YooAsset
/// </summary> /// </summary>
public AssetHandle LoadAssetAsync(AssetInfo assetInfo, uint priority) public AssetHandle LoadAssetAsync(AssetInfo assetInfo, uint priority)
{ {
if (LockLoadOperation)
{
string error = $"The load operation locked !";
YooLogger.Error(error);
CompletedProvider completedProvider = new CompletedProvider(this, assetInfo);
completedProvider.SetCompletedWithError(error);
return completedProvider.CreateHandle<AssetHandle>();
}
if (assetInfo.IsInvalid) if (assetInfo.IsInvalid)
{ {
YooLogger.Error($"Failed to load asset ! {assetInfo.Error}"); YooLogger.Error($"Failed to load asset ! {assetInfo.Error}");
@ -136,7 +159,7 @@ namespace YooAsset
{ {
provider = new AssetProvider(this, providerGUID, assetInfo); provider = new AssetProvider(this, providerGUID, assetInfo);
provider.InitSpawnDebugInfo(); provider.InitSpawnDebugInfo();
_providerDic.Add(providerGUID, provider); ProviderDic.Add(providerGUID, provider);
OperationSystem.StartOperation(PackageName, provider); OperationSystem.StartOperation(PackageName, provider);
} }
@ -149,6 +172,15 @@ namespace YooAsset
/// </summary> /// </summary>
public SubAssetsHandle LoadSubAssetsAsync(AssetInfo assetInfo, uint priority) public SubAssetsHandle LoadSubAssetsAsync(AssetInfo assetInfo, uint priority)
{ {
if (LockLoadOperation)
{
string error = $"The load operation locked !";
YooLogger.Error(error);
CompletedProvider completedProvider = new CompletedProvider(this, assetInfo);
completedProvider.SetCompletedWithError(error);
return completedProvider.CreateHandle<SubAssetsHandle>();
}
if (assetInfo.IsInvalid) if (assetInfo.IsInvalid)
{ {
YooLogger.Error($"Failed to load sub assets ! {assetInfo.Error}"); YooLogger.Error($"Failed to load sub assets ! {assetInfo.Error}");
@ -163,7 +195,7 @@ namespace YooAsset
{ {
provider = new SubAssetsProvider(this, providerGUID, assetInfo); provider = new SubAssetsProvider(this, providerGUID, assetInfo);
provider.InitSpawnDebugInfo(); provider.InitSpawnDebugInfo();
_providerDic.Add(providerGUID, provider); ProviderDic.Add(providerGUID, provider);
OperationSystem.StartOperation(PackageName, provider); OperationSystem.StartOperation(PackageName, provider);
} }
@ -176,6 +208,15 @@ namespace YooAsset
/// </summary> /// </summary>
public AllAssetsHandle LoadAllAssetsAsync(AssetInfo assetInfo, uint priority) public AllAssetsHandle LoadAllAssetsAsync(AssetInfo assetInfo, uint priority)
{ {
if (LockLoadOperation)
{
string error = $"The load operation locked !";
YooLogger.Error(error);
CompletedProvider completedProvider = new CompletedProvider(this, assetInfo);
completedProvider.SetCompletedWithError(error);
return completedProvider.CreateHandle<AllAssetsHandle>();
}
if (assetInfo.IsInvalid) if (assetInfo.IsInvalid)
{ {
YooLogger.Error($"Failed to load all assets ! {assetInfo.Error}"); YooLogger.Error($"Failed to load all assets ! {assetInfo.Error}");
@ -190,7 +231,7 @@ namespace YooAsset
{ {
provider = new AllAssetsProvider(this, providerGUID, assetInfo); provider = new AllAssetsProvider(this, providerGUID, assetInfo);
provider.InitSpawnDebugInfo(); provider.InitSpawnDebugInfo();
_providerDic.Add(providerGUID, provider); ProviderDic.Add(providerGUID, provider);
OperationSystem.StartOperation(PackageName, provider); OperationSystem.StartOperation(PackageName, provider);
} }
@ -203,6 +244,15 @@ namespace YooAsset
/// </summary> /// </summary>
public RawFileHandle LoadRawFileAsync(AssetInfo assetInfo, uint priority) public RawFileHandle LoadRawFileAsync(AssetInfo assetInfo, uint priority)
{ {
if (LockLoadOperation)
{
string error = $"The load operation locked !";
YooLogger.Error(error);
CompletedProvider completedProvider = new CompletedProvider(this, assetInfo);
completedProvider.SetCompletedWithError(error);
return completedProvider.CreateHandle<RawFileHandle>();
}
if (assetInfo.IsInvalid) if (assetInfo.IsInvalid)
{ {
YooLogger.Error($"Failed to load raw file ! {assetInfo.Error}"); YooLogger.Error($"Failed to load raw file ! {assetInfo.Error}");
@ -217,7 +267,7 @@ namespace YooAsset
{ {
provider = new RawFileProvider(this, providerGUID, assetInfo); provider = new RawFileProvider(this, providerGUID, assetInfo);
provider.InitSpawnDebugInfo(); provider.InitSpawnDebugInfo();
_providerDic.Add(providerGUID, provider); ProviderDic.Add(providerGUID, provider);
OperationSystem.StartOperation(PackageName, provider); OperationSystem.StartOperation(PackageName, provider);
} }
@ -245,12 +295,12 @@ namespace YooAsset
{ {
foreach (var provider in removeList) foreach (var provider in removeList)
{ {
_providerDic.Remove(provider.ProviderGUID); ProviderDic.Remove(provider.ProviderGUID);
} }
} }
internal bool HasAnyLoader() internal bool HasAnyLoader()
{ {
return _loaderDic.Count > 0; return LoaderDic.Count > 0;
} }
private LoadBundleFileOperation CreateBundleFileLoaderInternal(BundleInfo bundleInfo) private LoadBundleFileOperation CreateBundleFileLoaderInternal(BundleInfo bundleInfo)
@ -264,19 +314,19 @@ namespace YooAsset
// 新增下载需求 // 新增下载需求
loaderOperation = new LoadBundleFileOperation(this, bundleInfo); loaderOperation = new LoadBundleFileOperation(this, bundleInfo);
OperationSystem.StartOperation(PackageName, loaderOperation); OperationSystem.StartOperation(PackageName, loaderOperation);
_loaderDic.Add(bundleName, loaderOperation); LoaderDic.Add(bundleName, loaderOperation);
return loaderOperation; return loaderOperation;
} }
private LoadBundleFileOperation TryGetBundleFileLoader(string bundleName) private LoadBundleFileOperation TryGetBundleFileLoader(string bundleName)
{ {
if (_loaderDic.TryGetValue(bundleName, out LoadBundleFileOperation value)) if (LoaderDic.TryGetValue(bundleName, out LoadBundleFileOperation value))
return value; return value;
else else
return null; return null;
} }
private ProviderOperation TryGetAssetProvider(string providerGUID) private ProviderOperation TryGetAssetProvider(string providerGUID)
{ {
if (_providerDic.TryGetValue(providerGUID, out ProviderOperation value)) if (ProviderDic.TryGetValue(providerGUID, out ProviderOperation value))
return value; return value;
else else
return null; return null;
@ -284,7 +334,7 @@ namespace YooAsset
private void OnSceneUnloaded(Scene scene) private void OnSceneUnloaded(Scene scene)
{ {
List<SceneHandle> removeList = new List<SceneHandle>(); List<SceneHandle> removeList = new List<SceneHandle>();
foreach (var sceneHandle in _sceneHandles) foreach (var sceneHandle in SceneHandles)
{ {
if (sceneHandle.IsValid) if (sceneHandle.IsValid)
{ {
@ -297,15 +347,15 @@ namespace YooAsset
} }
foreach (var sceneHandle in removeList) foreach (var sceneHandle in removeList)
{ {
_sceneHandles.Remove(sceneHandle); SceneHandles.Remove(sceneHandle);
} }
} }
#region 调试信息 #region 调试信息
internal List<DebugProviderInfo> GetDebugReportInfos() internal List<DebugProviderInfo> GetDebugReportInfos()
{ {
List<DebugProviderInfo> result = new List<DebugProviderInfo>(_providerDic.Count); List<DebugProviderInfo> result = new List<DebugProviderInfo>(ProviderDic.Count);
foreach (var provider in _providerDic.Values) foreach (var provider in ProviderDic.Values)
{ {
DebugProviderInfo providerInfo = new DebugProviderInfo(); DebugProviderInfo providerInfo = new DebugProviderInfo();
providerInfo.AssetPath = provider.MainAssetInfo.AssetPath; providerInfo.AssetPath = provider.MainAssetInfo.AssetPath;

View File

@ -318,9 +318,19 @@ namespace YooAsset
/// 强制回收所有资源 /// 强制回收所有资源
/// </summary> /// </summary>
public UnloadAllAssetsOperation UnloadAllAssetsAsync() public UnloadAllAssetsOperation UnloadAllAssetsAsync()
{
var options = new UnloadAllAssetsOptions();
return UnloadAllAssetsAsync(options);
}
/// <summary>
/// 强制回收所有资源
/// </summary>
/// <param name="options">卸载选项</param>
public UnloadAllAssetsOperation UnloadAllAssetsAsync(UnloadAllAssetsOptions options)
{ {
DebugCheckInitialize(); DebugCheckInitialize();
var operation = new UnloadAllAssetsOperation(_resourceManager); var operation = new UnloadAllAssetsOperation(_resourceManager, options);
OperationSystem.StartOperation(PackageName, operation); OperationSystem.StartOperation(PackageName, operation);
return operation; return operation;
} }

View File

@ -3,16 +3,7 @@ using YooAsset;
internal partial class TTFSInitializeOperation : FSInitializeFileSystemOperation internal partial class TTFSInitializeOperation : FSInitializeFileSystemOperation
{ {
private enum ESteps
{
None,
RecordCacheFiles,
Done,
}
private readonly TiktokFileSystem _fileSystem; private readonly TiktokFileSystem _fileSystem;
private RecordTiktokCacheFilesOperation _recordTiktokCacheFilesOp;
private ESteps _steps = ESteps.None;
public TTFSInitializeOperation(TiktokFileSystem fileSystem) public TTFSInitializeOperation(TiktokFileSystem fileSystem)
{ {
@ -20,36 +11,10 @@ internal partial class TTFSInitializeOperation : FSInitializeFileSystemOperation
} }
internal override void InternalOnStart() internal override void InternalOnStart()
{ {
_steps = ESteps.RecordCacheFiles; Status = EOperationStatus.Succeed;
} }
internal override void InternalOnUpdate() internal override void InternalOnUpdate()
{ {
if (_steps == ESteps.None || _steps == ESteps.Done)
return;
if (_steps == ESteps.RecordCacheFiles)
{
if (_recordTiktokCacheFilesOp == null)
{
_recordTiktokCacheFilesOp = new RecordTiktokCacheFilesOperation(_fileSystem);
OperationSystem.StartOperation(_fileSystem.PackageName, _recordTiktokCacheFilesOp);
}
if (_recordTiktokCacheFilesOp.IsDone == false)
return;
if (_recordTiktokCacheFilesOp.Status == EOperationStatus.Succeed)
{
_steps = ESteps.Done;
Status = EOperationStatus.Succeed;
}
else
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = _recordTiktokCacheFilesOp.Error;
}
}
} }
} }
#endif #endif

View File

@ -1,57 +0,0 @@
#if UNITY_WEBGL && DOUYINMINIGAME
using YooAsset;
using TTSDK;
internal class RecordTiktokCacheFilesOperation : AsyncOperationBase
{
private enum ESteps
{
None,
RecordCacheFiles,
WaitResponse,
Done,
}
private readonly TiktokFileSystem _fileSystem;
private ESteps _steps = ESteps.None;
public RecordTiktokCacheFilesOperation(TiktokFileSystem fileSystem)
{
_fileSystem = fileSystem;
}
internal override void InternalOnStart()
{
_steps = ESteps.RecordCacheFiles;
}
internal override void InternalOnUpdate()
{
if (_steps == ESteps.None || _steps == ESteps.Done)
return;
if (_steps == ESteps.RecordCacheFiles)
{
_steps = ESteps.WaitResponse;
var fileSystemMgr = _fileSystem.GetFileSystemMgr();
var getSavedFileListParam = new GetSavedFileListParam();
getSavedFileListParam.success = (TTGetSavedFileListResponse response) =>
{
_steps = ESteps.Done;
Status = EOperationStatus.Succeed;
foreach (var fileInfo in response.fileList)
{
//TODO 需要确认存储文件为Bundle文件
_fileSystem.RecordBundleFile(fileInfo.filePath);
}
};
getSavedFileListParam.fail = (TTGetSavedFileListResponse response) =>
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = response.errMsg;
};
fileSystemMgr.GetSavedFileList(getSavedFileListParam);
}
}
}
#endif

View File

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

View File

@ -53,8 +53,7 @@ internal class TiktokFileSystem : IFileSystem
} }
} }
private readonly HashSet<string> _recorders = new HashSet<string>(); private readonly Dictionary<string, string> _cacheFilePathMapping = new Dictionary<string, string>(10000);
private readonly Dictionary<string, string> _cacheFilePaths = new Dictionary<string, string>(10000);
private TTFileSystemManager _fileSystemMgr; private TTFileSystemManager _fileSystemMgr;
private string _ttCacheRoot = string.Empty; private string _ttCacheRoot = string.Empty;
@ -81,7 +80,7 @@ internal class TiktokFileSystem : IFileSystem
{ {
get get
{ {
return _recorders.Count; return 0;
} }
} }
@ -185,8 +184,7 @@ internal class TiktokFileSystem : IFileSystem
} }
public virtual bool Exists(PackageBundle bundle) public virtual bool Exists(PackageBundle bundle)
{ {
string filePath = GetCacheFileLoadPath(bundle); return CheckCacheFileExist(bundle);
return _recorders.Contains(filePath);
} }
public virtual bool NeedDownload(PackageBundle bundle) public virtual bool NeedDownload(PackageBundle bundle)
{ {
@ -209,77 +207,49 @@ internal class TiktokFileSystem : IFileSystem
return GetCacheFileLoadPath(bundle); return GetCacheFileLoadPath(bundle);
} }
public virtual byte[] ReadBundleFileData(PackageBundle bundle) public virtual byte[] ReadBundleFileData(PackageBundle bundle)
{
if (CheckCacheFileExist(bundle))
{ {
string filePath = GetCacheFileLoadPath(bundle); string filePath = GetCacheFileLoadPath(bundle);
if (CheckCacheFileExist(filePath))
return _fileSystemMgr.ReadFileSync(filePath); return _fileSystemMgr.ReadFileSync(filePath);
}
else else
{
return Array.Empty<byte>(); return Array.Empty<byte>();
} }
}
public virtual string ReadBundleFileText(PackageBundle bundle) public virtual string ReadBundleFileText(PackageBundle bundle)
{
if (CheckCacheFileExist(bundle))
{ {
string filePath = GetCacheFileLoadPath(bundle); string filePath = GetCacheFileLoadPath(bundle);
if (CheckCacheFileExist(filePath))
return _fileSystemMgr.ReadFileSync(filePath, "utf8"); return _fileSystemMgr.ReadFileSync(filePath, "utf8");
}
else else
{
return string.Empty; return string.Empty;
} }
}
#region 内部方法 #region 内部方法
public TTFileSystemManager GetFileSystemMgr() public TTFileSystemManager GetFileSystemMgr()
{ {
return _fileSystemMgr; return _fileSystemMgr;
} }
public bool CheckCacheFileExist(string filePath) public bool CheckCacheFileExist(PackageBundle bundle)
{ {
return _fileSystemMgr.AccessSync(filePath); string url = RemoteServices.GetRemoteMainURL(bundle.FileName);
return _fileSystemMgr.IsUrlCached(url);
} }
private string GetCacheFileLoadPath(PackageBundle bundle) private string GetCacheFileLoadPath(PackageBundle bundle)
{ {
if (_cacheFilePaths.TryGetValue(bundle.BundleGUID, out string filePath) == false) if (_cacheFilePathMapping.TryGetValue(bundle.BundleGUID, out string filePath) == false)
{ {
filePath = _fileSystemMgr.GetLocalCachedPathForUrl(bundle.FileName); filePath = _fileSystemMgr.GetLocalCachedPathForUrl(bundle.FileName);
_cacheFilePaths.Add(bundle.BundleGUID, filePath); _cacheFilePathMapping.Add(bundle.BundleGUID, filePath);
} }
return filePath; return filePath;
} }
#endregion #endregion
#region 本地记录
public List<string> GetAllRecords()
{
return _recorders.ToList();
}
public bool RecordBundleFile(string filePath)
{
if (_recorders.Contains(filePath))
{
YooLogger.Error($"{nameof(TiktokFileSystem)} has element : {filePath}");
return false;
}
_recorders.Add(filePath);
return true;
}
public void TryRecordBundle(PackageBundle bundle)
{
string filePath = GetCacheFileLoadPath(bundle);
if (_recorders.Contains(filePath) == false)
{
_recorders.Add(filePath);
}
}
public void ClearAllRecords()
{
_recorders.Clear();
}
public void ClearRecord(string filePath)
{
if (_recorders.Contains(filePath))
{
_recorders.Remove(filePath);
}
}
#endregion
} }
#endif #endif

View File

@ -42,7 +42,6 @@ internal class WXFSClearAllBundleFilesOperation : FSClearCacheFilesOperation
YooLogger.Log("微信缓存清理成功!"); YooLogger.Log("微信缓存清理成功!");
_steps = ESteps.Done; _steps = ESteps.Done;
Status = EOperationStatus.Succeed; Status = EOperationStatus.Succeed;
_fileSystem.ClearAllRecords();
} }
else else
{ {

View File

@ -4,6 +4,7 @@ using System.IO;
using UnityEngine; using UnityEngine;
using YooAsset; using YooAsset;
using WeChatWASM; using WeChatWASM;
using static UnityEngine.Networking.UnityWebRequest;
internal class WXFSClearUnusedBundleFilesAsync : FSClearCacheFilesOperation internal class WXFSClearUnusedBundleFilesAsync : FSClearCacheFilesOperation
{ {
@ -11,6 +12,7 @@ internal class WXFSClearUnusedBundleFilesAsync : FSClearCacheFilesOperation
{ {
None, None,
GetUnusedCacheFiles, GetUnusedCacheFiles,
WaitingSearch,
ClearUnusedCacheFiles, ClearUnusedCacheFiles,
Done, Done,
} }
@ -37,20 +39,44 @@ internal class WXFSClearUnusedBundleFilesAsync : FSClearCacheFilesOperation
if (_steps == ESteps.GetUnusedCacheFiles) if (_steps == ESteps.GetUnusedCacheFiles)
{ {
_unusedCacheFiles = GetUnusedCacheFiles(); _steps = ESteps.WaitingSearch;
_unusedFileTotalCount = _unusedCacheFiles.Count;
var fileSystemMgr = _fileSystem.GetFileSystemMgr();
var statOption = new WXStatOption();
statOption.path = _fileSystem.FileRoot;
statOption.recursive = true;
statOption.success = (WXStatResponse response) =>
{
foreach (var fileStat in response.stats)
{
// 注意存储文件必须按照Bundle文件哈希值存储
string bundleGUID = Path.GetFileNameWithoutExtension(fileStat.path);
if (_manifest.TryGetPackageBundleByBundleGUID(bundleGUID, out PackageBundle value) == false)
{
_unusedCacheFiles.Add(fileStat.path);
}
}
_steps = ESteps.ClearUnusedCacheFiles; _steps = ESteps.ClearUnusedCacheFiles;
_unusedFileTotalCount = _unusedCacheFiles.Count;
YooLogger.Log($"Found unused cache files count : {_unusedFileTotalCount}"); YooLogger.Log($"Found unused cache files count : {_unusedFileTotalCount}");
};
statOption.fail = (WXStatResponse response) =>
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = response.errMsg;
};
fileSystemMgr.Stat(statOption);
} }
if (_steps == ESteps.ClearUnusedCacheFiles) if (_steps == ESteps.ClearUnusedCacheFiles)
{ {
for (int i = _unusedCacheFiles.Count - 1; i >= 0; i--) for (int i = _unusedCacheFiles.Count - 1; i >= 0; i--)
{ {
string clearFilePath = _unusedCacheFiles[i]; string filePath = _unusedCacheFiles[i];
_unusedCacheFiles.RemoveAt(i); _unusedCacheFiles.RemoveAt(i);
_fileSystem.ClearRecord(clearFilePath); WX.RemoveFile(filePath, null);
WX.RemoveFile(clearFilePath, null);
if (OperationSystem.IsBusy) if (OperationSystem.IsBusy)
break; break;
@ -68,30 +94,5 @@ internal class WXFSClearUnusedBundleFilesAsync : FSClearCacheFilesOperation
} }
} }
} }
private List<string> GetUnusedCacheFiles()
{
var allRecords = _fileSystem.GetAllRecords();
List<string> result = new List<string>(allRecords.Count);
foreach (var filePath in allRecords)
{
// 如果存储文件名是按照Bundle文件哈希值存储
string bundleGUID = Path.GetFileNameWithoutExtension(filePath);
if (_manifest.TryGetPackageBundleByBundleGUID(bundleGUID, out PackageBundle value) == false)
{
result.Add(filePath);
}
// 如果存储文件名是按照Bundle文件名称存储
/*
string bundleName = Path.GetFileNameWithoutExtension(filePath);
if (_manifest.TryGetPackageBundleByBundleName(bundleName, out PackageBundle value) == false)
{
result.Add(filePath);
}
*/
}
return result;
}
} }
#endif #endif

View File

@ -51,7 +51,6 @@ internal class WXFSDownloadFileOperation : DefaultDownloadFileOperation
{ {
_steps = ESteps.Done; _steps = ESteps.Done;
Status = EOperationStatus.Succeed; Status = EOperationStatus.Succeed;
_fileSystem.TryRecordBundle(Bundle); //记录下载文件
//TODO 解决微信小游戏插件问题 //TODO 解决微信小游戏插件问题
// Issue : https://github.com/wechat-miniprogram/minigame-unity-webgl-transform/issues/108# // Issue : https://github.com/wechat-miniprogram/minigame-unity-webgl-transform/issues/108#

View File

@ -3,16 +3,7 @@ using YooAsset;
internal partial class WXFSInitializeOperation : FSInitializeFileSystemOperation internal partial class WXFSInitializeOperation : FSInitializeFileSystemOperation
{ {
private enum ESteps
{
None,
RecordCacheFiles,
Done,
}
private readonly WechatFileSystem _fileSystem; private readonly WechatFileSystem _fileSystem;
private RecordWechatCacheFilesOperation _recordWechatCacheFilesOp;
private ESteps _steps = ESteps.None;
public WXFSInitializeOperation(WechatFileSystem fileSystem) public WXFSInitializeOperation(WechatFileSystem fileSystem)
{ {
@ -20,36 +11,10 @@ internal partial class WXFSInitializeOperation : FSInitializeFileSystemOperation
} }
internal override void InternalOnStart() internal override void InternalOnStart()
{ {
_steps = ESteps.RecordCacheFiles; Status = EOperationStatus.Succeed;
} }
internal override void InternalOnUpdate() internal override void InternalOnUpdate()
{ {
if (_steps == ESteps.None || _steps == ESteps.Done)
return;
if (_steps == ESteps.RecordCacheFiles)
{
if (_recordWechatCacheFilesOp == null)
{
_recordWechatCacheFilesOp = new RecordWechatCacheFilesOperation(_fileSystem);
OperationSystem.StartOperation(_fileSystem.PackageName, _recordWechatCacheFilesOp);
}
if (_recordWechatCacheFilesOp.IsDone == false)
return;
if (_recordWechatCacheFilesOp.Status == EOperationStatus.Succeed)
{
_steps = ESteps.Done;
Status = EOperationStatus.Succeed;
}
else
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = _recordWechatCacheFilesOp.Error;
}
}
} }
} }
#endif #endif

View File

@ -61,7 +61,6 @@ internal class WXFSLoadBundleOperation : FSLoadBundleOperation
_steps = ESteps.Done; _steps = ESteps.Done;
Result = new WXAssetBundleResult(_fileSystem, _bundle, assetBundle); Result = new WXAssetBundleResult(_fileSystem, _bundle, assetBundle);
Status = EOperationStatus.Succeed; Status = EOperationStatus.Succeed;
_fileSystem.TryRecordBundle(_bundle); //记录下载文件
//TODO 解决微信小游戏插件问题 //TODO 解决微信小游戏插件问题
// Issue : https://github.com/wechat-miniprogram/minigame-unity-webgl-transform/issues/108# // Issue : https://github.com/wechat-miniprogram/minigame-unity-webgl-transform/issues/108#

View File

@ -1,60 +0,0 @@
#if UNITY_WEBGL && WEIXINMINIGAME
using YooAsset;
using WeChatWASM;
using System.IO;
internal class RecordWechatCacheFilesOperation : AsyncOperationBase
{
private enum ESteps
{
None,
RecordCacheFiles,
WaitResponse,
Done,
}
private readonly WechatFileSystem _fileSystem;
private ESteps _steps = ESteps.None;
public RecordWechatCacheFilesOperation(WechatFileSystem fileSystem)
{
_fileSystem = fileSystem;
}
internal override void InternalOnStart()
{
_steps = ESteps.RecordCacheFiles;
}
internal override void InternalOnUpdate()
{
if (_steps == ESteps.None || _steps == ESteps.Done)
return;
if (_steps == ESteps.RecordCacheFiles)
{
_steps = ESteps.WaitResponse;
var fileSystemMgr = _fileSystem.GetFileSystemMgr();
var statOption = new WXStatOption();
statOption.path = _fileSystem.FileRoot;
statOption.recursive = true;
statOption.success = (WXStatResponse response) =>
{
_steps = ESteps.Done;
Status = EOperationStatus.Succeed;
foreach (var fileStat in response.stats)
{
//TODO 需要确认存储文件为Bundle文件
_fileSystem.RecordBundleFile(_fileSystem.FileRoot + fileStat.path);
}
};
statOption.fail = (WXStatResponse response) =>
{
_steps = ESteps.Done;
Status = EOperationStatus.Failed;
Error = response.errMsg;
};
fileSystemMgr.Stat(statOption);
}
}
}
#endif

View File

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

View File

@ -53,8 +53,7 @@ internal class WechatFileSystem : IFileSystem
} }
} }
private readonly HashSet<string> _recorders = new HashSet<string>(); private readonly Dictionary<string, string> _cacheFilePathMapping = new Dictionary<string, string>(10000);
private readonly Dictionary<string, string> _cacheFilePaths = new Dictionary<string, string>(10000);
private WXFileSystemManager _fileSystemMgr; private WXFileSystemManager _fileSystemMgr;
private string _wxCacheRoot = string.Empty; private string _wxCacheRoot = string.Empty;
@ -83,7 +82,7 @@ internal class WechatFileSystem : IFileSystem
{ {
get get
{ {
return _recorders.Count; return 0;
} }
} }
@ -174,10 +173,10 @@ internal class WechatFileSystem : IFileSystem
YooLogger.Warning($"Invalid parameter : {name}"); YooLogger.Warning($"Invalid parameter : {name}");
} }
} }
public virtual void OnCreate(string packageName, string rootDirectory) public virtual void OnCreate(string packageName, string packageRoot)
{ {
PackageName = packageName; PackageName = packageName;
_wxCacheRoot = rootDirectory; _wxCacheRoot = packageRoot;
if (string.IsNullOrEmpty(_wxCacheRoot)) if (string.IsNullOrEmpty(_wxCacheRoot))
{ {
@ -204,7 +203,7 @@ internal class WechatFileSystem : IFileSystem
public virtual bool Exists(PackageBundle bundle) public virtual bool Exists(PackageBundle bundle)
{ {
string filePath = GetCacheFileLoadPath(bundle); string filePath = GetCacheFileLoadPath(bundle);
return _recorders.Contains(filePath); return CheckCacheFileExist(filePath);
} }
public virtual bool NeedDownload(PackageBundle bundle) public virtual bool NeedDownload(PackageBundle bundle)
{ {
@ -250,55 +249,21 @@ internal class WechatFileSystem : IFileSystem
} }
public bool CheckCacheFileExist(string filePath) public bool CheckCacheFileExist(string filePath)
{ {
string result = _fileSystemMgr.AccessSync(filePath); string result = WX.GetCachePath(filePath);
return result.Equals("access:ok"); if (string.IsNullOrEmpty(result))
return false;
else
return true;
} }
public string GetCacheFileLoadPath(PackageBundle bundle) public string GetCacheFileLoadPath(PackageBundle bundle)
{ {
if (_cacheFilePaths.TryGetValue(bundle.BundleGUID, out string filePath) == false) if (_cacheFilePathMapping.TryGetValue(bundle.BundleGUID, out string filePath) == false)
{ {
filePath = PathUtility.Combine(_wxCacheRoot, "__GAME_FILE_CACHE", _packageRoot, bundle.FileName); filePath = PathUtility.Combine(_wxCacheRoot, bundle.FileName);
_cacheFilePaths.Add(bundle.BundleGUID, filePath); _cacheFilePathMapping.Add(bundle.BundleGUID, filePath);
} }
return filePath; return filePath;
} }
#endregion #endregion
#region 本地记录
public List<string> GetAllRecords()
{
return _recorders.ToList();
}
public bool RecordBundleFile(string filePath)
{
if (_recorders.Contains(filePath))
{
YooLogger.Error($"{nameof(WechatFileSystem)} has element : {filePath}");
return false;
}
_recorders.Add(filePath);
return true;
}
public void TryRecordBundle(PackageBundle bundle)
{
string filePath = GetCacheFileLoadPath(bundle);
if (_recorders.Contains(filePath) == false)
{
_recorders.Add(filePath);
}
}
public void ClearAllRecords()
{
_recorders.Clear();
}
public void ClearRecord(string filePath)
{
if (_recorders.Contains(filePath))
{
_recorders.Remove(filePath);
}
}
#endregion
} }
#endif #endif