赞
踩
BestHTTP/2是一个HTTP/1.1和HTTP/2实现,支持几乎所有的Unity 移动和独立平台。(官网)
Http
请求类:HTTPRequest
;构造函数共有 8 个:
public HTTPRequest(Uri uri);
public HTTPRequest(Uri uri, OnRequestFinishedDelegate callback);
public HTTPRequest(Uri uri, HTTPMethods methodType);
public HTTPRequest(Uri uri, bool isKeepAlive, OnRequestFinishedDelegate callback);
public HTTPRequest(Uri uri, HTTPMethods methodType, OnRequestFinishedDelegate callback);
public HTTPRequest(Uri uri, HTTPMethods methodType, bool isKeepAlive, OnRequestFinishedDelegate callback);
public HTTPRequest(Uri uri, bool isKeepAlive, bool disableCache, OnRequestFinishedDelegate callback);
public HTTPRequest(Uri uri, HTTPMethods methodType, bool isKeepAlive, bool disableCache, OnRequestFinishedDelegate callback);
HTTPRequest
参数说明:
uri
:请求的目标 URL 或 URI。methodType
:指定 HTTP 请求的方法类型,例如 GET、POST、PUT 等。isKeepAlive
:指示是否保持与服务器的连接活动状态。如果设置为 true,则在请求完成后保持连接打开;如果设置为 false,则在每个请求完成后关闭连接。disableCache
:指示是否禁用缓存。如果设置为 true,则禁用缓存,确保每次请求都会从服务器获取最新的数据。callback
:请求完成时的回调函数,可以在其中处理响应数据。
示例:
//创建一个 get 请求,禁用缓存并在请求完成后关闭连接,接收到返回数据时将返回数据打印到控制台
HTTPRequest request = new HTTPRequest(new Uri("http://127.0.0.1/info"), HTTPMethods.Get, false, true, (request, response) =>
{
Debug.Log(response.Data);
});
路径参数:
路径参数直接拼接到
Uri
即可;
示例:
int infoId = 1;
string myUri = $"http://127.0.0.1/info/{infoId}";
HTTPRequest request = new HTTPRequest(new Uri(myUri), HTTPMethods.Get);
请求参数:
使用
AddField
进行添加,AddField
有两个参数,参数一是fieldName
,参数二是value
;
示例:
HTTPRequest request = new HTTPRequest(new Uri("http://127.0.0.1/login"), HTTPMethods.Post, OnRequestFinished);
request.AddField("username", "admin");
request.AddField("password", "123456");
请求头参数:
使用
AddHeader
进行添加请求头,和AddField
类似AddHeader
也是两个参数,参数一是name
,参数二是value
;
示例:
var request = new HTTPRequest(new Uri("http://127.0.0.1/login"), HTTPMethods.Get, OnRequestFinished);
request.AddHeader("Authorization", "mytoken");
请求体参数:
HTTPRequest
的实例的RawData
属用于存放请求体请求体
// 将JSON数据序列化为字符串
var jsonData = "{\"username\":\"admin\",\"password\":\"123456\""}";
// 将字符串编码为UTF-8字节数组
var bytes = System.Text.Encoding.UTF8.GetBytes(jsonData);
// 创建请求并将字节数组作为请求体发送
var request = new HTTPRequest(new Uri("http://127.0.0.1/login"), HTTPMethods.Post, OnRequestFinished);
request.RawData = bytes;
request.AddHeader("Content-Type", "application/json");
request.Send();
WebSocket webSocket = new WebSocket(new Uri("ws://127.0.0.1/webSocket"));
OnOpen
事件:在建立与服务器的连接时调用。
- 当连接建立成功后,会触发该事件,并将
WebSocket
对象传递给OnWebSocketOpen
方法。。
OnMessage
事件:从服务器收到文本消息时调用。
- 当从服务器接收到文本消息时,会触发该事件,并将WebSocket对象和消息内容传递给
OnMessageReceived
方法。
OnBinary
事件:从服务器收到二进制blob消息时调用。
- 当从服务器接收到二进制消息时,会触发该事件,并将WebSocket对象和消息字节数组传递给
OnBinaryMessageReceived
方法。
OnClosed
事件:在客户端或服务器关闭连接时调用,或发生内部错误。
- 当连接关闭时,会触发该事件,并将WebSocket对象、关闭代码和关闭消息传递给
OnWebSocketClosed
方法。
OnError
事件:当无法连接到服务器、发生内部错误或连接丢失时调用。
- 当发生错误时,会触发该事件,并将WebSocket对象和异常对象传递给
OnError
方法。
Open
:建立连接;
Send
:发送消息到服务器;
Close
:断开连接;
示例:
/// <summary> /// websocket客户端 /// </summary> public class WebSocketClient : SingletonManager<WebSocketClient> { private static readonly object padlock = new object(); /// <summary> /// websocket客户端实例 /// </summary> protected static WebSocketClient instance; /// <summary> /// 获取单例 /// </summary> public static WebSocketClient getInst() { if (instance == null) { lock (padlock) { if (instance == null) { instance = new WebSocketClient(); } } } return instance; } private WebSocket webSocket; /// <summary> /// 连接初始化 /// </summary> public void init(long pid) { string url = GlobalConstant.WEBSOCKET_PATH + pid; webSocket = new WebSocket(new Uri(url)); webSocket.OnOpen += OnWebSocketOpen; webSocket.OnMessage += OnMessageReceived; webSocket.OnBinary += OnBinaryMessageReceived; webSocket.OnClosed += OnWebSocketClosed; webSocket.OnError += OnError; webSocket.Open(); } /// <summary> /// 服务器字符串消息 /// </summary> /// <param name="webSocket"></param> /// <param name="message"></param> protected void OnMessageReceived(WebSocket webSocket, string message) { //Debug.Log("Text Message received from server: " + message); } /// <summary> /// 连接回调 /// </summary> /// <param name="webSocket"></param> protected void OnWebSocketOpen(WebSocket webSocket) { Debug.Log("WebSocket Open!"); } /// <summary> /// 服务器二进制消息 /// </summary> /// <param name="webSocket"></param> /// <param name="message"></param> protected void OnBinaryMessageReceived(WebSocket webSocket, byte[] bytes) { WsResult result = ProtoBufUtil.Deserialize<WsResult>(bytes); if (result.status.code != 200) { Debug.Log(result.status.code); Debug.Log(result.status.msg); return; } if (result.status.code == 200) { AnalysisUtils.getProxy()[result.sendType](bytes); } } /// <summary> /// 关闭连接回调 /// </summary> /// <param name="webSocket"></param> /// <param name="code"></param> /// <param name="message"></param> protected void OnWebSocketClosed(WebSocket webSocket, UInt16 code, string message) { Debug.Log("WebSocket Closed!"); } /// <summary> /// 错误通知 /// </summary> /// <param name="ws"></param> /// <param name="ex"></param> protected void OnError(WebSocket ws, string ex) { string errorMsg = string.Empty; if (ws.InternalRequest.Response != null) { errorMsg = string.Format("Status Code from Server: {0} and Message: {1}", ws.InternalRequest.Response.StatusCode, ws.InternalRequest.Response.Message); } Debug.Log("An error occured: " + (ex != null ? ex : "Unknown: " + errorMsg)); } /// <summary> /// 发送字符串: /// </summary> /// <param name="msg"></param> public void OnSend(string msg) { webSocket.Send(msg); } /// <summary> /// 发送二进制流: /// </summary> /// <param name="msg"></param> public void OnSend(byte[] buffer) { webSocket.Send(buffer); } /// <summary> /// 断开连接 /// </summary> public void OnClose() { webSocket.Close(); } }
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。