245 lines
9.7 KiB
C#
245 lines
9.7 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using UnityEngine;
|
||
using UnityEngine.Events;
|
||
|
||
namespace AssetManagement
|
||
{
|
||
/// <summary>
|
||
/// 最终的资源管理器
|
||
/// </summary>
|
||
// 注：重启游戏不要随意摧毁这个组件，这个组件的数据，有部分是无法重新绑定的，比如：正在下载的资源
|
||
// 尚未加载完成的部分可以主动析构
|
||
// 注：清晰结构流程 - 所有操作均有Manager接收，然后操作具体BundleRecord。BundleRecord回调自身状态通知Manager，Manager再调整监视列表。
|
||
public class BundleManager
|
||
{
|
||
public readonly List<BundleRecord> activeRecords = new List<BundleRecord>();
|
||
public readonly Dictionary<string, BundleRecord> finishRecords = new Dictionary<string, BundleRecord>();
|
||
public event UnityAction<BundleRecord> onComplete;
|
||
|
||
public BundleManager(AssetPathHub assetPathHub, BundleLoadHub loadHub, BundleDownloadHub downloadHub)
|
||
{
|
||
this.assetPathHub = assetPathHub;
|
||
this.loadHub = loadHub;
|
||
this.downloadHub = downloadHub;
|
||
}
|
||
|
||
public AssetPathHub assetPathHub { get; private set; }
|
||
public BundleLoadHub loadHub { get; private set; }
|
||
public BundleDownloadHub downloadHub { get; private set; }
|
||
|
||
/// <summary>
|
||
/// 试图获得一个资源包，返回是否完成
|
||
/// </summary>
|
||
/// <param name="name">资源包名</param>
|
||
/// <param name="record">资源包记录</param>
|
||
public bool TryLoadBundle(string name, out BundleRecord record)
|
||
{
|
||
var result = finishRecords.TryGetValue(name, out record);
|
||
if (!result)
|
||
{
|
||
record = activeRecords.Find(a => a.name == name) ?? CreateBundle(name);
|
||
if (record != null)
|
||
record.ActiveLoad();
|
||
}
|
||
else
|
||
record.ActiveLoad();
|
||
return result;
|
||
}
|
||
|
||
// /// <summary>
|
||
// /// 阻塞加载Bundle的流程 - 立刻加载成功，不支持需要下载的Bundle
|
||
// /// </summary>
|
||
// // 注：阻塞加载有更严格的预先检查
|
||
public BundleRecord LoadBundleSync(string name)
|
||
{
|
||
BundleRecord result = null;
|
||
var record = GetBundle(name);
|
||
if (record != null)
|
||
{
|
||
result = record;
|
||
switch (record.state)
|
||
{
|
||
case BundleState.Downloading:
|
||
Debug.LogError(name + " is still downloading and cannot load from local position!");
|
||
break;
|
||
case BundleState.Loading:
|
||
case BundleState.WaitUnload:
|
||
case BundleState.WaitDependency:
|
||
case BundleState.Unload:
|
||
record.ActiveLoadSync();
|
||
break;
|
||
case BundleState.Done:
|
||
case BundleState.Error:
|
||
// 不需要处理已经加载完成的情况
|
||
break;
|
||
default:
|
||
Debug.LogError(string.Format("{0} has unhandled state {1} in sync load!", name, record.state));
|
||
break;
|
||
}
|
||
}
|
||
// 预先检查并防御依赖出现错误的情况
|
||
else
|
||
{
|
||
var valid = true;
|
||
var dependencies = assetPathHub.GetAllDependencies(name);
|
||
if (dependencies == null)
|
||
{
|
||
valid = false;
|
||
Debug.LogError(string.Format("Try to sync load an unmarked bundle {0}!", name));
|
||
}
|
||
else
|
||
{
|
||
foreach (var dependency in dependencies)
|
||
{
|
||
var pathType = assetPathHub.GetPathState(dependency);
|
||
// 注：思想是，Unmarked 直接跳过不管；报错会在实际获得依赖时出现
|
||
if (pathType == AssetPathState.online)
|
||
{
|
||
Debug.LogError(string.Format(
|
||
"{0} is depended by {1}, but not local and cannot be sync loaded!", dependency, name));
|
||
valid = false;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
Debug.LogWarning("Load Sync: " + name + ", Valid = " + valid);
|
||
if (valid)
|
||
{
|
||
foreach (var dependency in dependencies)
|
||
{
|
||
var dependRecord = GetBundle(dependency);
|
||
if (dependRecord != null)
|
||
{
|
||
switch (dependRecord.state)
|
||
{
|
||
case BundleState.Done:
|
||
case BundleState.Loading:
|
||
break;
|
||
case BundleState.Error:
|
||
valid = false;
|
||
Debug.LogError(string.Format("{0} is depended by {1}, but has error on loading!", dependency, name));
|
||
break;
|
||
default:
|
||
valid = false;
|
||
Debug.LogError(string.Format("{0} is depended by {1}, but async loading and cannot be loaded sync!", dependency, name));
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
if (valid)
|
||
{
|
||
record = CreateBundle(name);
|
||
if (record != null)
|
||
record.ActiveLoadSync();
|
||
result = record;
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public void UnloadBundle(string name)
|
||
{
|
||
BundleRecord record;
|
||
if (finishRecords.TryGetValue(name, out record))
|
||
record.ActiveUnload();
|
||
if (record == null)
|
||
{
|
||
record = activeRecords.Find(a => a.name == name);
|
||
if (record != null)
|
||
record.ActiveUnload();
|
||
}
|
||
}
|
||
|
||
public List<BundleRecord> GetDependencies(string name)
|
||
{
|
||
var dependencies = assetPathHub.GetAllDependencies(name);
|
||
// 注：CreateBundle 在路径不存在时，会返回空，暂时处理方式是内部报错，这里直接屏蔽防御
|
||
return dependencies == null ? null : dependencies.Select(dependency => GetBundle(dependency) ?? CreateBundle(dependency)).Where(item => item != null).ToList();
|
||
}
|
||
|
||
public BundleRecord GetBundle(string name)
|
||
{
|
||
BundleRecord record;
|
||
if (!finishRecords.TryGetValue(name, out record))
|
||
record = activeRecords.Find(a => a.name == name);
|
||
return record;
|
||
}
|
||
|
||
private BundleRecord CreateBundle(string name)
|
||
{
|
||
BundleRecord result = null;
|
||
var pathData = assetPathHub.GetPathData(name);
|
||
if (pathData != null)
|
||
{
|
||
result = new BundleRecord(pathData, this);
|
||
result.onStateUpdate += OnBundleStateUpdate;
|
||
// 注：新建的Record或者立刻被主动更新，或者立刻被依赖更新
|
||
// 因此等待回调后再更新列表
|
||
}
|
||
else
|
||
Debug.LogError(string.Format("Unable to Create unmarked asset for {0}!", name));
|
||
return result;
|
||
}
|
||
|
||
private void OnBundleStateUpdate(BundleRecord record)
|
||
{
|
||
switch (record.state)
|
||
{
|
||
case BundleState.Done:
|
||
{
|
||
MoveToFinish(record);
|
||
if (onComplete != null)
|
||
onComplete(record);
|
||
}
|
||
break;
|
||
case BundleState.Unload:
|
||
{
|
||
if (finishRecords.ContainsKey(record.name))
|
||
finishRecords.Remove(record.name);
|
||
activeRecords.Remove(record);
|
||
record.onStateUpdate -= OnBundleStateUpdate;
|
||
record.Dispose();
|
||
}
|
||
break;
|
||
case BundleState.Loading:
|
||
case BundleState.Downloading:
|
||
case BundleState.WaitUnload:
|
||
case BundleState.WaitDependency:
|
||
{
|
||
MoveToActive(record);
|
||
}
|
||
break;
|
||
case BundleState.Error:
|
||
MoveToFinish(record);
|
||
//Debug.LogError("Not Implemented Error: Bundle State Error will not be handled now!");
|
||
break;
|
||
default:
|
||
throw new ArgumentOutOfRangeException();
|
||
}
|
||
}
|
||
|
||
private void MoveToFinish(BundleRecord record)
|
||
{
|
||
activeRecords.Remove(record);
|
||
#if UNITY_EDITOR
|
||
// 额外增加一个编辑器检查，监控可能出现的故障
|
||
if (finishRecords.ContainsKey(record.name))
|
||
Debug.LogError("Bundle Manager has already marked the record " + record.name);
|
||
#endif
|
||
finishRecords[record.name] = record;
|
||
}
|
||
|
||
private void MoveToActive(BundleRecord record)
|
||
{
|
||
var i = activeRecords.IndexOf(record);
|
||
if (i < 0)
|
||
activeRecords.Add(record);
|
||
if (finishRecords.ContainsKey(record.name))
|
||
finishRecords.Remove(record.name);
|
||
}
|
||
}
|
||
} |