12.资源更新-资源更新删除-获取本地对比文件
12.1 知识点
定义用于存储本地AB包信息的字典，主要用于和远端信息对比
private Dictionary<string, AssetBundleInfo> localAssetBundleInfoDictionary = new Dictionary<string, AssetBundleInfo>();
解析对比文件字符串到字典中的逻辑，远程和本地都可以共用的，把GetRemoteABCompareFileInfo可以改成GetABCompareFileInfoToDictionary并修改其参数。
/// <summary>
/// 获取AB包对比文件中的信息并解析到对应的字典中 可能是远程字典也可能是本地字典
/// </summary>
/// <param name="info"></param>
/// <param name="assetBundleInfoDictionary"></param>
public void GetABCompareFileInfoToDictionary(string info, Dictionary<string, AssetBundleInfo> assetBundleInfoDictionary)
{
//这就不去读取文件了 直接让外部读好了 传进来
// 读取资源对比文件的内容
//string info = File.ReadAllText(Application.persistentDataPath + "/ABCompareInfo_TMP.txt");
// 使用竖线分割字符串，将每个AB包的信息分离
string[] strs = info.Split('|');
string[] infos = null;
// 遍历每个分割后的AB包信息
for (int i = 0; i < strs.Length; i++)
{
// 使用空格分割每个AB包的详细信息
infos = strs[i].Split(' ');
// 记录每一个远端AB包的信息，之后用于对比
assetBundleInfoDictionary.Add(infos[0], new AssetBundleInfo(infos[0], infos[1], infos[2]));
}
}
定义加载本地对比文件并解析的方法，使用协程
/// <summary>
/// 本地AB包对比文件加载 并解析信息到本地字典
/// </summary>
public void GetLocalABCompareFileInfo(UnityAction<bool> overCallBack)
{
//Application.persistentDataPath;
//如果可读可写文件夹中 存在对比文件 说明之前我们已经下载更新过了
if (File.Exists(Application.persistentDataPath + "/ABCompareInfo.txt"))
{
StartCoroutine(GetLocalABCOmpareFileInfo(Application.persistentDataPath + "/ABCompareInfo.txt", overCallBack));
}
//只有当可读可写中没有对比文件时 且默认资源有对比文件 才会来加载默认资源（第一次进游戏时才会发生）
else if (File.Exists(Application.streamingAssetsPath + "/ABCompareInfo.txt"))
{
StartCoroutine(GetLocalABCOmpareFileInfo(Application.streamingAssetsPath + "/ABCompareInfo.txt", overCallBack));
}
//如果两个都不进 证明第一次并且没有默认资源
else
{
overCallBack(true);
}
}
/// <summary>
/// 协同程序 本地AB包对比文件加载 并解析信息到本地字典
/// </summary>
/// <param name="filePath"></param>
/// <returns></returns>
private IEnumerator GetLocalABCOmpareFileInfo(string filePath, UnityAction<bool> overCallBack)
{
//通过 UnityWebRequest 去加载本地文件
UnityWebRequest unityWebRequest = UnityWebRequest.Get(filePath);
yield return unityWebRequest.SendWebRequest();
//获取文件成功 继续往下执行
if (unityWebRequest.result == UnityWebRequest.Result.Success)
{
GetABCompareFileInfoToDictionary(unityWebRequest.downloadHandler.text, localAssetBundleInfoDictionary);
overCallBack(true);
}
else
{
overCallBack(false);
}
}
定义给外部调用的检查AB包更新的方法，先加载远端资源对比文件并解析，再加载本地资源对比文件并解析，之后补充对比本地和远端对比文件来下载AB包的逻辑
/// <summary>
/// 外部调用的检查AB包更新的方法
/// </summary>
/// <param name="overCallBack">检查完的回调</param>
/// <param name="updateInfoCallBack">更新信息的委托</param>
public void CheckUpdate(UnityAction<bool> overCallBack, UnityAction<string> updateInfoCallBack)
{
//1.加载远端资源对比文件
DownLoadABCompareFile((isOver) =>
{
updateInfoCallBack("开始更新资源");
if (isOver)
{
updateInfoCallBack("远端对比文件下载结束");
string remoteInfo = File.ReadAllText(Application.persistentDataPath + "/ABCompareInfo_TMP.txt");
updateInfoCallBack("得到远端对比文件信息并开始解析到字典");
GetABCompareFileInfoToDictionary(remoteInfo, remoteAssetBundleInfoDictionary);
updateInfoCallBack("解析远端对比文件完成");
//2.加载本地资源对比文件
GetLocalABCompareFileInfo((isOver) => {
if (isOver)
{
updateInfoCallBack("解析本地对比文件完成");
//3.对比他们 然后进行AB包下载
}
else
{
overCallBack(false);
}
});
}
else
{
overCallBack(false);
}
});
}
进行测试
AssetBundleUpdateManager.Instance.CheckUpdate((isOver) =>
{
print("检查更新完成");
},(infoString)=>
{
print(infoString);
});
12.2 知识点代码
AssetBundleUpdateManager
using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Threading.Tasks;
using UnityEngine;
using UnityEngine.Events;
using UnityEngine.Networking;
using static ABUpdateMgr;
//AB包更新管理器
public class AssetBundleUpdateManager : BaseSingletonInMonoBehaviour<AssetBundleUpdateManager>
{
//用于存储远端AB包信息的字典 之后 和本地进行对比即可完成 更新 下载相关逻辑
private Dictionary<string, AssetBundleInfo> remoteAssetBundleInfoDictionary = new Dictionary<string, AssetBundleInfo>();
//用于存储本地AB包信息的字典 主要用于和远端信息对比
private Dictionary<string, AssetBundleInfo> localAssetBundleInfoDictionary = new Dictionary<string, AssetBundleInfo>();
//这个是待下载的AB包列表文件 存储AB包的名字
private List<string> assetBundleDownLoadList = new List<string>();
/// <summary>
/// 外部调用的检查AB包更新的方法
/// </summary>
/// <param name="overCallBack">检查完的回调</param>
/// <param name="updateInfoCallBack">更新信息的委托</param>
public void CheckUpdate(UnityAction<bool> overCallBack, UnityAction<string> updateInfoCallBack)
{
//1.加载远端资源对比文件
DownLoadABCompareFile((isOver) =>
{
updateInfoCallBack("开始更新资源");
if (isOver)
{
updateInfoCallBack("远端对比文件下载结束");
string remoteInfo = File.ReadAllText(Application.persistentDataPath + "/ABCompareInfo_TMP.txt");
updateInfoCallBack("得到远端对比文件信息并开始解析到字典");
GetABCompareFileInfoToDictionary(remoteInfo, remoteAssetBundleInfoDictionary);
updateInfoCallBack("解析远端对比文件完成");
//2.加载本地资源对比文件
GetLocalABCompareFileInfo((isOver) => {
if (isOver)
{
updateInfoCallBack("解析本地对比文件完成");
//3.对比他们 然后进行AB包下载
}
else
{
overCallBack(false);
}
});
}
else
{
overCallBack(false);
}
});
}
/// <summary>
/// 下载服务器中的文件
/// </summary>
/// <param name="fileName">文件名</param>
/// <param name="localPath">本地路径</param>
/// <returns></returns>
private bool DownLoadFile(string fileName, string localPath)
{
try
{
//1.创建一个FTP连接 用于下载
FtpWebRequest ftpWebRequest = FtpWebRequest.Create(new Uri("ftp://127.0.0.1/AB/PC/" + fileName)) as FtpWebRequest;
//2.设置一个通信凭证 这样才能下载（如果有匿名账号 可以不设置凭证 但是实际开发中 建议 还是不要设置匿名账号）
NetworkCredential networkCredential = new NetworkCredential("MrTao", "MrTao");
ftpWebRequest.Credentials = networkCredential;
//3.其它设置
// 设置代理为null
ftpWebRequest.Proxy = null;
// 请求完毕后 是否关闭控制连接
ftpWebRequest.KeepAlive = false;
// 操作命令-下载
ftpWebRequest.Method = WebRequestMethods.Ftp.DownloadFile;
// 指定传输的类型 2进制
ftpWebRequest.UseBinary = true;
//4.下载文件
// ftp的流对象
FtpWebResponse ftpWebResponse = ftpWebRequest.GetResponse() as FtpWebResponse;
Stream downLoadStream = ftpWebResponse.GetResponseStream();
using (FileStream fileStream = File.Create(localPath))
{
//一点一点的下载内容
byte[] bytes = new byte[2048];
//返回值 代表读取了多少个字节
int contentLength = downLoadStream.Read(bytes, 0, bytes.Length);
//循环下载数据
while (contentLength != 0)
{
//写入到本地文件流中
fileStream.Write(bytes, 0, contentLength);
//写完再读
contentLength = downLoadStream.Read(bytes, 0, bytes.Length);
}
//循环完毕后 证明下载结束
fileStream.Close();
downLoadStream.Close();
print(fileName + "下载成功");
return true;
}
}
catch (Exception ex)
{
print(fileName + "下载失败" + ex.Message);
return false;
}
}
/// <summary>
/// 异步下载远端资源对比文件的函数，提供回调通知下载完成状态
/// </summary>
/// <param name="overCallBack">下载完成后的回调 通常会调用获取下载下来的AB包中的信息函数</param>
public async void DownLoadABCompareFile(UnityAction<bool> overCallBack)
{
// 打印本地持久化数据路径
print(Application.persistentDataPath);
// 初始化下载是否成功的标志
bool isOver = false;
// 设置重新下载的最大次数
int reDownLoadMaxNum = 5;
// 本地存储路径，由于多线程不能访问Unity主线程的Application，所以在外面声明
string localPath = Application.persistentDataPath;
// 循环下载，直到下载成功或达到最大重新下载次数
while (!isOver && reDownLoadMaxNum > 0)
{
// 使用异步任务Task.Run在后台线程中执行下载操作
await Task.Run(() =>
{
// 执行下载文件的操作，将下载结果存储在isOver中
isOver = DownLoadFile("ABCompareInfo.txt", localPath + "/ABCompareInfo_TMP.txt");
});
// 递减重新下载的次数
--reDownLoadMaxNum;
}
// 通过回调通知外部下载是否完成
overCallBack?.Invoke(isOver);
}
/// <summary>
/// 获取AB包对比文件中的信息并解析到对应的字典中 可能是远程字典也可能是本地字典
/// </summary>
/// <param name="info"></param>
/// <param name="assetBundleInfoDictionary"></param>
public void GetABCompareFileInfoToDictionary(string info, Dictionary<string, AssetBundleInfo> assetBundleInfoDictionary)
{
//这就不去读取文件了 直接让外部读好了 传进来
// 读取资源对比文件的内容
//string info = File.ReadAllText(Application.persistentDataPath + "/ABCompareInfo_TMP.txt");
// 使用竖线分割字符串，将每个AB包的信息分离
string[] strs = info.Split('|');
string[] infos = null;
// 遍历每个分割后的AB包信息
for (int i = 0; i < strs.Length; i++)
{
// 使用空格分割每个AB包的详细信息
infos = strs[i].Split(' ');
// 记录每一个远端AB包的信息，之后用于对比
assetBundleInfoDictionary.Add(infos[0], new AssetBundleInfo(infos[0], infos[1], infos[2]));
}
}
/// <summary>
/// 本地AB包对比文件加载 并解析信息到本地字典
/// </summary>
public void GetLocalABCompareFileInfo(UnityAction<bool> overCallBack)
{
//Application.persistentDataPath;
//如果可读可写文件夹中 存在对比文件 说明之前我们已经下载更新过了
if (File.Exists(Application.persistentDataPath + "/ABCompareInfo.txt"))
{
StartCoroutine(GetLocalABCOmpareFileInfo(Application.persistentDataPath + "/ABCompareInfo.txt", overCallBack));
}
//只有当可读可写中没有对比文件时 才会来加载默认资源（第一次进游戏时才会发生）
else if (File.Exists(Application.streamingAssetsPath + "/ABCompareInfo.txt"))
{
StartCoroutine(GetLocalABCOmpareFileInfo(Application.streamingAssetsPath + "/ABCompareInfo.txt", overCallBack));
}
//如果两个都不进 证明第一次并且没有默认资源
else
{
overCallBack(true);
}
}
/// <summary>
/// 协同程序 本地AB包对比文件加载 并解析信息到本地字典
/// </summary>
/// <param name="filePath"></param>
/// <returns></returns>
private IEnumerator GetLocalABCOmpareFileInfo(string filePath, UnityAction<bool> overCallBack)
{
//通过 UnityWebRequest 去加载本地文件
UnityWebRequest unityWebRequest = UnityWebRequest.Get(filePath);
yield return unityWebRequest.SendWebRequest();
//获取文件成功 继续往下执行
if (unityWebRequest.result == UnityWebRequest.Result.Success)
{
GetABCompareFileInfoToDictionary(unityWebRequest.downloadHandler.text, localAssetBundleInfoDictionary);
overCallBack(true);
}
else
{
overCallBack(false);
}
}
/// <summary>
/// 下载远程AssetBundle文件的函数，异步执行。
/// </summary>
/// <param name="overCallBack">下载完成回调，参数为是否全部下载成功。</param>
/// <param name="updatePro">更新下载进度回调，参数为已下载资源数量和总资源数量。</param>
public async void DownLoadABFile(UnityAction<bool> overCallBack, UnityAction<int, int> updatePro)
{
// 1. 遍历字典的键，根据文件名将AssetBundle包添加到待下载列表中
foreach (string name in remoteAssetBundleInfoDictionary.Keys)
{
// 直接将文件名放入待下载列表中
assetBundleDownLoadList.Add(name);
}
// 本地存储路径，由于多线程不能访问Unity相关内容，因此在外部声明
string localPath = Application.persistentDataPath + "/";
// 是否下载成功的标志
bool isOver = false;
// 下载成功的文件名列表，用于移除下载成功的内容
List<string> tempList = new List<string>();
// 重新下载的最大次数
int reDownLoadMaxNum = 5;
// 下载成功的资源数量
int downLoadOverNum = 0;
// 需要下载的总资源数量
int downLoadMaxNum = assetBundleDownLoadList.Count;
// while循环的目的是进行n次重新下载，避免网络异常时下载失败
while (assetBundleDownLoadList.Count > 0 && reDownLoadMaxNum > 0)
{
for (int i = 0; i < assetBundleDownLoadList.Count; i++)
{
// 通过Task.Run在异步线程中执行下载操作
isOver = false;
await Task.Run(() =>
{
isOver = DownLoadFile(assetBundleDownLoadList[i], localPath + assetBundleDownLoadList[i]);
});
if (isOver)
{
// 2. 更新下载进度，通知外部已下载资源数量和总资源数量
updatePro(++downLoadOverNum, downLoadMaxNum);
tempList.Add(assetBundleDownLoadList[i]); // 下载成功记录下来
}
}
// 将下载成功的文件名从待下载列表中移除
for (int i = 0; i < tempList.Count; i++)
assetBundleDownLoadList.Remove(tempList[i]);
// 递减重新下载的次数
--reDownLoadMaxNum;
}
// 所有内容都下载完毕，通过回调告知外部是否下载完成
overCallBack(assetBundleDownLoadList.Count == 0);
}
}
Lesson12_资源更新_资源更新删除_获取本地对比文件
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
public class Lesson12_资源更新_资源更新删除_获取本地对比文件 : MonoBehaviour
{
void Start()
{
AssetBundleUpdateManager.Instance.CheckUpdate((isOver) =>
{
print("检查更新完成");
},(infoString)=>
{
print(infoString);
});
}
}
转载请注明来源，欢迎对文章中的引用来源进行考证，欢迎指出任何有错误或不够清晰的表达。可以在下面评论区评论，也可以邮件至 785293209@qq.com
