feat(WebManager): 添加二进制数据POST请求支持

新增对二进制数据POST请求的处理功能，包括：
1. 添加WebBinaryData类处理二进制请求
2. 实现MakeBinaryBytesRequest方法处理二进制请求
3. 新增PostToBytes接口支持二进制数据上传

Author: AlianBlank

Runtime/Web/IWebManager.cs

@@ -127,6 +127,18 @@ public interface IWebManager
         /// <returns>返回WebBufferResult类型的异步任务</returns>
         Task<WebBufferResult> PostToBytes(string url, Dictionary<string, object> from, Dictionary<string, string> queryString, Dictionary<string, string> header, object userData = null);
 
+        /// <summary>
+        /// 发送字节数组Post请求，返回字节数组结果
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <param name="from">要发送的字节数组数据</param>
+        /// <param name="queryString">URL查询参数字典</param>
+        /// <param name="header">HTTP请求头字典</param>
+        /// <param name="userData">用户自定义数据</param>
+        /// <returns>返回WebBufferResult类型的异步任务</returns>
+        Task<WebBufferResult> PostToBytes(string url, byte[] from, Dictionary<string, string> queryString, Dictionary<string, string> header, object userData = null);
+
+
 #if ENABLE_GAME_FRAME_X_WEB_PROTOBUF_NETWORK
         /// <summary>
         /// 发送Protobuf消息的Post请求，并接收指定类型的响应

Runtime/Web/WebManager.Binary.cs

@@ -0,0 +1,183 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Text;
+using System.Threading.Tasks;
+using GameFrameX.Network.Runtime;
+using GameFrameX.Runtime;
+using ProtoBuf;
+#if UNITY_WEBGL
+using UnityEngine.Networking;
+#endif
+
+namespace GameFrameX.Web.Runtime
+{
+    /// <summary>
+    /// Web请求管理器的ProtoBuf部分实现
+    /// </summary>
+    public partial class WebManager : GameFrameworkModule, IWebManager
+    {
+        /// <summary>
+        /// 等待处理的Binary请求队列
+        /// </summary>
+        private readonly Queue<WebBinaryData> m_WaitingBinaryQueue = new Queue<WebBinaryData>(256);
+
+        /// <summary>
+        /// 正在处理的Binary请求列表
+        /// </summary>
+        private readonly List<WebBinaryData> m_SendingBinaryList = new List<WebBinaryData>(16);
+
+        /// <summary>
+        /// 更新处理ProtoBuf请求队列
+        /// </summary>
+        /// <param name="elapseSeconds">逻辑流逝时间，以秒为单位</param>
+        /// <param name="realElapseSeconds">真实流逝时间，以秒为单位</param>
+        void UpdateBinary(float elapseSeconds, float realElapseSeconds)
+        {
+            lock (m_StringBuilder)
+            {
+                if (m_SendingBinaryList.Count < MaxConnectionPerServer)
+                {
+                    if (m_WaitingBinaryQueue.Count > 0)
+                    {
+                        var webBinaryData = m_WaitingBinaryQueue.Dequeue();
+
+                        MakeBinaryBytesRequest(webBinaryData);
+
+                        m_SendingBinaryList.Add(webBinaryData);
+                    }
+                }
+            }
+        }
+
+        /// <summary>
+        /// 关闭ProtoBuf请求处理，清理资源
+        /// </summary>
+        private void ShutdownBinary()
+        {
+            while (m_WaitingBinaryQueue.Count > 0)
+            {
+                var webData = m_WaitingBinaryQueue.Dequeue();
+                webData.Dispose();
+            }
+
+            m_WaitingBinaryQueue.Clear();
+            while (m_SendingBinaryList.Count > 0)
+            {
+                var webData = m_SendingBinaryList[0];
+                m_SendingBinaryList.RemoveAt(0);
+                webData.Dispose();
+            }
+
+            m_SendingBinaryList.Clear();
+
+            m_MemoryStream.Dispose();
+        }
+
+        /// <summary>
+        /// 执行ProtoBuf字节请求
+        /// </summary>
+        /// <param name="webData">ProtoBuf请求数据</param>
+        private async void MakeBinaryBytesRequest(WebBinaryData webData)
+        {
+#if UNITY_WEBGL
+            UnityWebRequest unityWebRequest;
+            if (webData.IsGet)
+            {
+                unityWebRequest = UnityWebRequest.Get(webData.URL);
+            }
+            else
+            {
+                unityWebRequest = UnityWebRequest.Post(webData.URL, string.Empty);
+            }
+
+            unityWebRequest.timeout = (int)RequestTimeout.TotalSeconds;
+            {
+                byte[] postData = webData.SendData;
+                unityWebRequest.uploadHandler = new UploadHandlerRaw(postData);
+            }
+
+            var asyncOperation = unityWebRequest.SendWebRequest();
+            asyncOperation.completed += (asyncOperation2) =>
+            {
+                m_SendingBinaryList.Remove(webData);
+                if (unityWebRequest.isNetworkError || unityWebRequest.isHttpError || unityWebRequest.error != null)
+                {
+                    webData.Task.TrySetException(new Exception(unityWebRequest.error));
+                    return;
+                }
+
+                webData.Task.SetResult(new WebBufferResult(webData.UserData, unityWebRequest.downloadHandler.data));
+            };
+#else
+            try
+            {
+                HttpWebRequest request = WebRequest.CreateHttp(webData.URL);
+                request.Method = webData.IsGet ? WebRequestMethods.Http.Get : WebRequestMethods.Http.Post;
+                request.Timeout = (int)RequestTimeout.TotalMilliseconds; // 设置请求超时时间
+                byte[] postData = webData.SendData;
+                request.ContentLength = postData.Length;
+                using (Stream requestStream = request.GetRequestStream())
+                {
+                    await requestStream.WriteAsync(postData, 0, postData.Length);
+                }
+
+                using (HttpWebResponse response = (HttpWebResponse)await request.GetResponseAsync())
+                {
+                    using (Stream responseStream = response.GetResponseStream())
+                    {
+                        m_MemoryStream.SetLength(response.ContentLength);
+                        m_MemoryStream.Position = 0;
+                        await responseStream.CopyToAsync(m_MemoryStream);
+                        webData.Task.SetResult(new WebBufferResult(webData.UserData, m_MemoryStream.ToArray())); // 将流的内容复制到内存流中并转换为byte数组 
+                    }
+                }
+            }
+            catch (WebException e)
+            {
+                // 捕获超时异常
+                if (e.Status == WebExceptionStatus.Timeout)
+                {
+                    webData.Task.SetException(new TimeoutException(e.Message));
+                    return;
+                }
+
+                webData.Task.SetException(e);
+            }
+            catch (IOException e)
+            {
+                webData.Task.SetException(e);
+            }
+            catch (Exception e)
+            {
+                webData.Task.SetException(e);
+            }
+            finally
+            {
+                m_SendingBinaryList.Remove(webData);
+            }
+#endif
+        }
+
+
+        /// <summary>
+        /// 发送字节数组Post请求，返回字节数组结果
+        /// </summary>
+        /// <param name="url">请求地址</param>
+        /// <param name="from">要发送的字节数组数据</param>
+        /// <param name="queryString">URL查询参数字典</param>
+        /// <param name="header">HTTP请求头字典</param>
+        /// <param name="userData">用户自定义数据</param>
+        /// <returns>返回WebBufferResult类型的异步任务</returns>
+        public Task<WebBufferResult> PostToBytes(string url, byte[] from, Dictionary<string, string> queryString, Dictionary<string, string> header, object userData = null)
+        {
+            var uniTaskCompletionSource = new TaskCompletionSource<WebBufferResult>();
+            url = UrlHandler(url, queryString);
+            var webData = new WebBinaryData(url, from, uniTaskCompletionSource, userData);
+            m_SendingBinaryList.Add(webData);
+            MakeBinaryBytesRequest(webData);
+            return uniTaskCompletionSource.Task;
+        }
+    }
+}

Runtime/Web/WebManager.Binary.cs.meta

@@ -0,0 +1,37 @@
+using System.Threading.Tasks;
+
+namespace GameFrameX.Web.Runtime
+{
+    public partial class WebManager
+    {
+        /// <summary>
+        /// Web Binary请求数据类，用于处理Binary格式的Web请求
+        /// </summary>
+        private sealed class WebBinaryData : WebData
+        {
+            /// <summary>
+            /// 获取请求任务的完成源，用于异步操作的控制和结果返回
+            /// </summary>
+            public readonly TaskCompletionSource<WebBufferResult> Task;
+
+            /// <summary>
+            /// 获取要发送的Protocol Buffer序列化后的字节数组数据
+            /// </summary>
+            public readonly byte[] SendData;
+
+            /// <summary>
+            /// 初始化Web Binary请求数据
+            /// </summary>
+            /// <param name="url">请求URL</param>
+            /// <param name="sendData">要发送的Binary序列化数据</param>
+            /// <param name="task">请求任务的完成源</param>
+            /// <param name="userData">用户自定义数据</param>
+            public WebBinaryData(string url, byte[] sendData, TaskCompletionSource<WebBufferResult> task, object userData) : base(false, url, userData)
+            {
+                task.CheckNull(nameof(task));
+                SendData = sendData;
+                Task = task;
+            }
+        }
+    }
+}

Runtime/Web/WebManager.WebBinaryData.cs

@@ -99,6 +99,7 @@ protected override void Update(float elapseSeconds, float realElapseSeconds)
                 }
 
                 UpdateProtoBuf(elapseSeconds, realElapseSeconds);
+                UpdateBinary(elapseSeconds, realElapseSeconds);
             }
         }
 
@@ -123,7 +124,7 @@ protected override void Shutdown()
 
             m_SendingNormalList.Clear();
             ShutdownProtoBuf();
-
+            ShutdownBinary();
             m_MemoryStream.Dispose();
         }