使用C#的Delegate机制实现资源的异步读取的类

2024-08-20 16:08

本文主要是介绍使用C#的Delegate机制实现资源的异步读取的类,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

制作网页网游,常常需要从Server端临时下载一个资源进来,然后读取,通常使用WWW下载AssetBundle的方法来实现。而下载过程需要时间,不可能立即完成,这通常需要提供下载需求的用户自己实现同步的机制,比较麻烦,而且需要重复劳动。因此我想提供一个简单的资源下载管理的类,这个类大概提供以下的功能:

1提供一个简单的异步加载的回调机制。调用这个类的一个函数,提供一个资源下载请求,接到请求后,这个类开始下载这个资源,当资源完成后,就调用用户所提供的回调函数,通知用户下载已经完成,这时用户可以选择如何处理下载完的对象。

2.用户提出请求时,可以提供一个自定义的参数,这个参数在回调函数中,作为参数传入,这样方便用户传输一些这个资源特定的信息,方便在同一个回调函数中处理不同种类的资源。

3.可以多次请求同一资源的下载请求,但不会造成实际的多次下载。而会直接把之前下载完成后的资源返回。

下面是这个类的实现代码:

using UnityEngine;

using System;

using System.Collections.Generic;


public class MyResourceManager : MonoBehaviour

{





public delegate void DownFinishDelegate (WWW wwwObj,object customParam);



public class WWWRequest

{

public string requestURl;

public DownFinishDelegate calbackFun;

public WWW wwwObject = null;

public bool bHasDeal = false;

public List customParams = new List();



public WWWRequest(){}

public WWWRequest (string url, DownFinishDelegate cbFun,object customParam=null)

{

requestURl = url;

calbackFun = new DownFinishDelegate (cbFun);

wwwObject = new WWW (url);

customParams.Add(customParam);





}

}



//WWW Request List

private Dictionary m_WWWMap = new Dictionary ();





public void AddDownRequest (string url, DownFinishDelegate callBackFun,object customParam=null)

{

if(url != "")

{

//增加新的资源下载需求

if (!m_WWWMap.ContainsKey (url))

{

m_WWWMap.Add (url, new WWWRequest (url, callBackFun,customParam));



}

else

{

//已经提交相同请求,但是没有下载完成

if(!m_WWWMap[url].wwwObject.isDone)

{

m_WWWMap[url].calbackFun += callBackFun;

m_WWWMap[url].customParams.Add(customParam);



}

//已下载资源,直接调用回调函数

else

{

callBackFun.Invoke (m_WWWMap[url].wwwObject,customParam);

}



}

}

}





// Use this for initialization

void Start ()

{



}



// Update is called once per frame

void Update ()

{



foreach (KeyValuePair wwwPair in m_WWWMap)

{

WWWRequest wwwReq = wwwPair.Value;

//如果尚未调用回调,并且下载完成,则调用

if ((!wwwReq.bHasDeal) && wwwReq.wwwObject.isDone)

{

//print("DelegationCount:"+wwwReq.calbackFun.GetInvocationList().GetLength(0));

for(int i=0;i<wwwreq.calbackfun.getinvocationlist().getlength(0);i++)

{
((DownFinishDelegate)wwwReq.calbackFun.GetInvocationList()[i]).Invoke(wwwReq.wwwObject,wwwReq.customParams[i]);

}

wwwReq.bHasDeal = true;

}

}

}







}
复制代码
关于实现,有以下一些考虑和说明:

1. 这个类继承自脚本的类MonoBehaviour,这样主要是为了可以被放到主循环里,在Update函数检查每个请求是否已经下载完成,这样需要在场景中添加一个GameObject,将这个脚本附加到上边。

2.回调托管函数的原型声明为:

public delegate void DownFinishDelegate (WWW wwwObj,object customParam);

是一个无返回值,带有两个参数的函数,第一个参数是下载的WWW对象,第二个是自定义参数。

3.类中包含一个内部类WWWRequest,这个类代表一种资源的下载请求,而不是一次。这里的一种是以一个URL来区分的,也就是说可以多次请求同一个URL资源下载,但是可以提供不同的回调和自定义参数,这多次的下载请求都属于同一个WWWRequest,这样提供了更多的灵活性,也不需要重复下载同一个资源多次。为了实现这个功能,使用了C#中的Dictionary类型,这个字典类型类似于C++中的map,由一个键值索引一个值,这个键值就是url的字符串。值就是这个WWWRequest对象。

这个对象中包含了以下属性:

url字符串:
string requestURl
复制代码
回调函数的托管对象:
DownFinishDelegate calbackFun
复制代码
资源下载所用到的WWW对象:WWW wwwObject

标示是否下载完成的旗标:bool bHasDeal

自定义参数列表:List customParams

因为一个托管对象,可以加载多个托管函数,因此这里只使用一个托管对象,而自定义参数需要提供一个列表。每个托管的回调函数按顺序一一对应列表中的参数。

3.AddDownRequest就是提供下载资源请求所需要调用的函数。实现比较简单,先检查在Dictonary里是否已有这个资源的下载请求,如果没有增添一个新的请求,创建一个WWWRequest对象加入到字典中。

如果已有,那么检查当前的状态,如果已经下载完成,则直接调用用户提供的回调函数。

如果还没下载完成,就在字典中已经创建的WWWRequest中的托管对象 和参数列表中相应都增加新的一项,等待下载完成后调用。

4.在Update函数中,遍历检查每个WWWRequest中的WWW对象的当前状态,如果有完成的,则依次调用每个注册到这个WWWRequest的回调函数,传入对应的自定义参数。

调用完成后,将旗标置位,防止下次更新再调用。

【使用方法】:

要使用这个类,首先需要找到场景中的资源管理的GameObject,并且获得脚本类对象。

1.MyResourceManager resMgr = (MyResourceManager)GameObject.Find("MyResourceManager").GetComponent("MyResourceManager") ;

然后提出下载请求:

1.resMgr.AddDownRequest("http://"+GlobalConfig.GetConnectIP()+"/AssetBundleResource/Terrain/Terrain3.unity3d",DownFinishDelegate,null);

这里第一个参数就是下载的Url,第二个是回调函数,自定义参数因为这里没用到,传入null。

然后需要声明回调处理函数:

public void DownFinishDelegate (WWW wwwParam,object customParam)

{

wwwObj = wwwParam;

}
复制代码
这个函数在资源下载完成后会被调用,这里的处理逻辑比较简单,只是简单保存下下载的WWW对象,以便之后使用其中的assetBundle对象。

这篇关于使用C#的Delegate机制实现资源的异步读取的类的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1090535

相关文章

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts?二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security?—— 核心思想二、如何在 Java 项目中使用?——

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步:安装必要的依赖库第二步:获取并构建 BoringSSL第三步:获取 Nginx

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函