当前位置: 首页 > news >正文

Unity网络请求队列

引子

最近的一个项目中由于某个需求,需要多次请求后台接口数据,就自己封装了一下网络请求的队列;刚刚好给大家分享一下,互相交流学习

简述

Unity 的网络请求队列是由 UnityWebRequestQueue 类实现的。这个类继承自 MonoBehaviour 类,可以在 Unity 的场景中创建一个 GameObject,并将 UnityWebRequestQueue 挂载到这个 GameObject 上,就可以在该场景中使用了。

Unity的WebRequest模块将网络请求封装成了一个队列,按照发送请求的先后顺序进行处理。当一个请求被添加到队列中后,WebRequest会判断当前是否有正在进行的请求,如果有,则将请求添加到等待队列中,等待正在进行的请求结束后再发送。如果没有正在进行的请求,则直接发送请求。当一个请求结束后,WebRequest会从等待队列中取出下一个请求进行发送。

GET 请求队列

GET 请求队列的核心代码如下:

public class GetRequestQueue : MonoBehaviour
{private Queue<UnityWebRequest> webRequestQueue = new Queue<UnityWebRequest>();void Update(){if (webRequestQueue.Count > 0){UnityWebRequest webRequest = webRequestQueue.Peek();if (webRequest.isDone){string responseText = webRequest.downloadHandler.text;Debug.Log(responseText);webRequestQueue.Dequeue();}else if (webRequest.isHttpError || webRequest.isNetworkError){Debug.Log(webRequest.error);webRequestQueue.Dequeue();}}}public void AddRequest(string url){UnityWebRequest webRequest = UnityWebRequest.Get(url);webRequestQueue.Enqueue(webRequest);StartCoroutine(webRequest.SendWebRequest());}
}

这个类定义了一个 Queue 对象 webRequestQueue 来缓存所有 GET 请求。在 Update 方法中,每次检查队列是否有请求,如果有请求,就取出队列中的第一个请求,并启动协程将这个请求发送出去。如果请求完成,则将请求从队列中删除,否则如果请求出错也将请求从队列中删除。

你可以将 AddRequest 方法暴露在其他类中,用于向 GET 请求队列中添加请求。如下所示:

public class GetRequestDemo : MonoBehaviour
{public string url = "http://localhost:8080/get";private GetRequestQueue getRequestQueue;void Start(){getRequestQueue = GameObject.Find("GetRequestQueue").GetComponent<GetRequestQueue>();}void OnGUI(){if (GUI.Button(new Rect(10, 10, 100, 50), "Send GET Request")){getRequestQueue.AddRequest(url);}}
}

在这个例子中,我们定义了一个 GET 请求的 Demo 类,当用户点击按钮时,调用 AddRequest 方法将请求添加到队列中。

POST请求队列

POST 请求队列的实现与 GET 请求队列类似,主要区别在于我们需要为 POST 请求添加请求体。下面是 POST 请求队列的实现代码:

public class PostRequestQueue : MonoBehaviour
{private Queue<UnityWebRequest> webRequestQueue = new Queue<UnityWebRequest>();void Update(){if (webRequestQueue.Count > 0){UnityWebRequest webRequest = webRequestQueue.Peek();if (webRequest.isDone){string responseText = webRequest.downloadHandler.text;Debug.Log(responseText);webRequestQueue.Dequeue();}else if (webRequest.isHttpError || webRequest.isNetworkError){Debug.Log(webRequest.error);webRequestQueue.Dequeue();}}}public void AddRequest(string url, string requestBody){UnityWebRequest webRequest = UnityWebRequest.Post(url, requestBody);webRequestQueue.Enqueue(webRequest);StartCoroutine(webRequest.SendWebRequest());}
}

这个类定义了一个 Queue 对象 webRequestQueue 来缓存所有 POST 请求。在 AddRequest 方法中,我们使用 UnityWebRequest.Post 方法创建一个 POST 请求,并将请求体 requestBody 传递给该方法。

同样的,你可以将 AddRequest 方法暴露在其他类中,用于向 POST 请求队列中添加请求。如下所示:

public class PostRequestDemo : MonoBehaviour
{public string url = "http://localhost:8080/post";public string requestBody = "{\"key\": \"value\"}";private PostRequestQueue postRequestQueue;void Start(){postRequestQueue = GameObject.Find("PostRequestQueue").GetComponent<PostRequestQueue>();}void OnGUI(){if (GUI.Button(new Rect(10, 10, 100, 50), "Send POST Request")){postRequestQueue.AddRequest(url, requestBody);}}
}

在这个例子中,我们定义了一个 POST 请求的 Demo 类,当用户点击按钮时,调用 AddRequest 方法将请求添加到队列中,并将请求体 requestBody 传递给 AddRequest 方法。

注意

在队列中,WebRequest支持设置最大并发数,即同时能进行的最大请求数。当队列中的请求数达到最大并发数时,新的请求会被添加到等待队列中,直到有请求结束后再进行发送。这样可以保证不会过度的进行网络请求,避免出现网络拥堵等问题。

Unity的WebRequest模块的网络请求队列原理就是将请求封装成队列,并按照先进先出的原则进行处理,支持设置最大并发数,保证并发请求的数量不会过度,避免出现网络拥堵等问题。

http://www.lryc.cn/news/153434.html

相关文章:

  • 【Spring Boot】使用XML配置文件实现数据库操作(一)
  • PMP中常用英文术语
  • 【Apollo学习笔记】——规划模块TASK之SPEED_BOUNDS_PRIORI_DECIDERSPEED_BOUNDS_FINAL_DECIDER
  • score_inverse_problems运行环境,pycharm重新安装,jax,jaxlib的GPU版本安装-230831
  • VSC++: 奇怪的风吹
  • 被动操作系统指纹识别的强大功能可实现准确的物联网设备识别
  • QT/C++获取电脑系统,主板型号,CPU型号,硬盘型号,内存大小等相关信息(二)通过Windows Server (WMI)查询
  • 自建音乐服务器Navidrome之一
  • ACL 访问控制 过滤数据 维护网络安全(第七课)
  • 3D视觉测量:面对面的对称度 点对(附源码)
  • 无涯教程-JavaScript - RANK函数
  • 蓝牙发展现状
  • 排序算法问题
  • PlotlyJs 指定画布的宽度并页面居中
  • java基础-----第八篇
  • 【Java 基础篇】StringBuilder的魔力:Java字符串处理探究
  • Shell 编程技巧:批量转换Markdown文件
  • EasyAVFilter的初衷:把ffmpeg.c当做SDK来用,而不是当做EXE来用
  • 内存管理之:内存空间分布和栈攻击(黑客常用攻击手段)
  • 一米facebook功能点
  • uni-app:监听数据变化(watch监听、@input事件)
  • 提升C语言的方法?
  • WPF_布局基础
  • 【SA8295P 源码分析】87 - SA8295P HQNX + Android 编译环境搭建指导
  • java基础-----第九篇
  • 数学建模--整数规划匈牙利算法的Python实现
  • OpenCV(十三):图像中绘制直线、圆形、椭圆形、矩形、多边形和文字
  • [华为云云服务器评测] Unbutnu添加SSH Key、编译启动Springboot项目
  • 【MySQL学习笔记】(七)内置函数
  • 《Python魔法大冒险》004第一个魔法程序