使用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

相关文章

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流(parallelStream)的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS

C++中unordered_set哈希集合的实现

《C++中unordered_set哈希集合的实现》std::unordered_set是C++标准库中的无序关联容器,基于哈希表实现,具有元素唯一性和无序性特点,本文就来详细的介绍一下unorder... 目录一、概述二、头文件与命名空间三、常用方法与示例1. 构造与析构2. 迭代器与遍历3. 容量相关4

Linux join命令的使用及说明

《Linuxjoin命令的使用及说明》`join`命令用于在Linux中按字段将两个文件进行连接,类似于SQL的JOIN,它需要两个文件按用于匹配的字段排序,并且第一个文件的换行符必须是LF,`jo... 目录一. 基本语法二. 数据准备三. 指定文件的连接key四.-a输出指定文件的所有行五.-o指定输出

Linux jq命令的使用解读

《Linuxjq命令的使用解读》jq是一个强大的命令行工具,用于处理JSON数据,它可以用来查看、过滤、修改、格式化JSON数据,通过使用各种选项和过滤器,可以实现复杂的JSON处理任务... 目录一. 简介二. 选项2.1.2.2-c2.3-r2.4-R三. 字段提取3.1 普通字段3.2 数组字段四.

C++中悬垂引用(Dangling Reference) 的实现

《C++中悬垂引用(DanglingReference)的实现》C++中的悬垂引用指引用绑定的对象被销毁后引用仍存在的情况,会导致访问无效内存,下面就来详细的介绍一下产生的原因以及如何避免,感兴趣... 目录悬垂引用的产生原因1. 引用绑定到局部变量,变量超出作用域后销毁2. 引用绑定到动态分配的对象,对象

Linux kill正在执行的后台任务 kill进程组使用详解

《Linuxkill正在执行的后台任务kill进程组使用详解》文章介绍了两个脚本的功能和区别,以及执行这些脚本时遇到的进程管理问题,通过查看进程树、使用`kill`命令和`lsof`命令,分析了子... 目录零. 用到的命令一. 待执行的脚本二. 执行含子进程的脚本,并kill2.1 进程查看2.2 遇到的

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述:HashMap的宏观结构二、核心数据结构解析1. 数组(桶数组)2. 链表节点(Node

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储:配置灵活性:编码示例引入依赖:配置ehcache.XML文件:配置