HTTP接口访问类

using UnityEngine;
using System.Collections;
using System;
using System.Text;
using LitJson;
using System.Collections.Generic;
using NetworkMessages;
using System.Reflection;

/// <summary>
/// HTTP接口访问类
/// </summary>
public class WebAccess : MonoBehaviour
{
???/// <summary>
???/// 接口分类与后台服务基地址映射关系
???/// </summary>
???private static Dictionary<string, string> apiTypeToServerBaseUrlMap;

???private static void InitializeApiTypeToServerUrlMap()
???{
???????apiTypeToServerBaseUrlMap = new Dictionary<string, string>
???????{
???????????{ "account", "http://192.168.0.75:8990/" },
???????????{ "logic", "http://192.168.0.75:9601/" },
???????????{ "PENDING", "http://192.168.0.75:11001/" },
???????};
???}
???private const float timeout = 3f;
???static WebAccess instance;

???public static WebAccess Instance
???{
???????get
???????{
???????????if (instance == null)
???????????{
???????????????InitializeApiMaps();
???????????????InitializeApiTypeToServerUrlMap();
???????????????GameObject go = new GameObject("WebAccess");
???????????????instance = go.AddComponent<WebAccess>();
???????????????DontDestroyOnLoad(go);
???????????????return instance;
???????????}
???????????else
???????????{
???????????????return instance;
???????????}
???????}
???}

???private string token;
???private Dictionary<string, string> headersToSend = new Dictionary<string, string>();

???public string Token
???{
???????get
???????{
???????????return token;
???????}
???????set
???????{
???????????token = value;
???????????Debug.Log("set token to " + value);
???????????headersToSend["Authorization"] = token;
???????}
???}

???/// <summary>
???/// HTTP接口的返回结果类型与该接口对应的名称的字典
???/// </summary>
???static Dictionary<Type, string> apiNameMaps = null;
???static Dictionary<Type, string> apiTypeMaps = null;

???static void InitializeApiMaps()
???{
???????apiNameMaps = new Dictionary<Type, string>();
???????apiTypeMaps = new Dictionary<Type, string>();
???????// 添加所有用到的HTTP接口的返回结果类型
???????Assembly current = Assembly.GetExecutingAssembly();
???????Type[] allTypes = current.GetTypes();
???????for (int i = 0; i < allTypes.Length; i++)
???????{
???????????Type type = allTypes[i];
???????????if (type.IsDefined(typeof(WebApiResultAttribute), false))
???????????{
???????????????WebApiResultAttribute attr = type.GetCustomAttributes(typeof(WebApiResultAttribute), false)[0] as WebApiResultAttribute;
???????????????apiNameMaps.Add(type, attr.ApiName);
???????????????apiTypeMaps.Add(type, attr.ApiType);
???????????}
???????}
???????Debug.Log("registered Web-API count: " + apiNameMaps.Count);
???}

???void OnDestroy()
???{
???????instance = null;
???????if (apiNameMaps != null)
???????{
???????????apiNameMaps.Clear();
???????????apiNameMaps = null;
???????}
???????if (apiTypeMaps != null)
???????{
???????????apiTypeMaps.Clear();
???????????apiTypeMaps = null;
???????}
???}

???string GetApiUrlByType(Type type)
???{
???????string apiType = apiTypeMaps[type];
???????string apiName = apiNameMaps[type];
???????return apiTypeToServerBaseUrlMap[apiType] + apiName;
???}

???/// <summary>
???/// 执行HTTP接口
???/// </summary>
???/// <param name="parameters">接口所需的参数</param>
???/// <param name="onSuccess">接口调用成功时回调</param>
???/// <param name="onFail">接口调用失败时的回调</param>
???/// <typeparam name="TResult">该HTTP接口的返回结果类型</typeparam>
???public void RunAPI<TResult>(WebApiParameter parameters, Action<WebApiResult> onSuccess, Action<WebApiError> onFail) where TResult : WebApiResult
???{
???????DialogTipsCtrl.Instance.BeginWait();
???????StartCoroutine(GetData(parameters, typeof(TResult), onSuccess, onFail));
???}

???/// <summary>
???/// 以协程方式访问HTTP接口
???/// </summary>
???/// <param name="parameters">接口所需的参数</param>
???/// <param name="resultType">返回结果类型</param>
???/// <param name="onSuccess">接口调用成功时回调</param>
???/// <param name="onFail">接口调用失败时的回调</param>
???IEnumerator GetData(WebApiParameter parameters, Type resultType, Action<WebApiResult> onSuccess, Action<WebApiError> onFail)
???{
???????string json = JsonMapper.ToJson(parameters);
???????string encrypted = Web.Networking.AesBase64Encrypt.Encrypt(json);
???????byte[] rawData = Encoding.UTF8.GetBytes(encrypted);
???????string fullUrl = GetApiUrlByType(resultType);
???????Debug.Log("accessing " + fullUrl + " with parameters: " + json + " with rawdata: " + encrypted);
???????WWW www = new WWW(fullUrl, rawData, headersToSend);
???????float time = 0f;
???????float progress = 0f;
???????while (string.IsNullOrEmpty(www.error) && !www.isDone)
???????{
???????????// 如果进度长时间不动，就累积这个时间，做超时处理。
???????????if (www.progress != progress)
???????????{
???????????????// 如果进度变化，重置超时计时为0
???????????????time = 0f;
???????????????progress = www.progress;
???????????}
???????????time += Time.deltaTime;
???????????if (time > timeout)
???????????{
???????????????break;
???????????}
???????????yield return null;
???????}
???????try
???????{
???????????if (time > timeout)
???????????{
???????????????Debug.LogError("HTTP接口访问超时");
???????????????SafelyInvokeOnFailCallback(onFail, new WebApiError("HTTP接口访问超时"));
???????????}
???????????else if (string.IsNullOrEmpty(www.error))
???????????{
???????????????string webResult = www.text;
???????????????Debug.Log("server reply: " + www.text);
???????????????string decrypted = Web.Networking.AesBase64Encrypt.Decrypt(webResult);
???????????????Debug.Log("decrypted server reply: " + decrypted);
???????????????object obj = JsonMapper.ToObject(decrypted, resultType);
???????????????WebApiResult result = (WebApiResult)obj;
???????????????if (result.result == 0)
???????????????{
???????????????????SafelyInvokeOnSuccessCallback(onSuccess, result);
???????????????}
???????????????else
???????????????{
???????????????????SafelyInvokeOnFailCallback(onFail, new WebApiError(result.result));
???????????????}
???????????}
???????????else
???????????{
???????????????SafelyInvokeOnFailCallback(onFail, new WebApiError(www.error));
???????????}
???????}
???????catch (Exception e)
???????{
???????????Debug.LogException(e);
???????????SafelyInvokeOnFailCallback(onFail, new WebApiError(e));
???????}
???????finally
???????{
???????????DialogTipsCtrl.Instance.EndWait();
???????}
???}

???/// <summary>
???/// 安全地调用成功回调方法
???/// </summary>
???void SafelyInvokeOnSuccessCallback(Action<WebApiResult> onSuccess, WebApiResult result)
???{
???????if (onSuccess != null)
???????{
???????????// 包裹回调调用，可以避免因为回调本身的异常被判定为 RunAPI 的错误。
???????????try
???????????{
???????????????onSuccess(result);
???????????}
???????????catch (Exception e)
???????????{
???????????????Debug.LogException(e);
???????????}
???????}
???}

???/// <summary>
???/// 安全地调用失败回调方法
???/// </summary>
???void SafelyInvokeOnFailCallback(Action<WebApiError> onFail, WebApiError error)
???{
???????if (onFail != null)
???????{
???????????// 包裹回调调用，可以避免因为回调本身的异常被判定为 RunAPI 的错误。
???????????try
???????????{
???????????????onFail(error);
???????????}
???????????catch (Exception e)
???????????{
???????????????Debug.LogException(e);
???????????}
???????}
???}

}

HTTP接口访问类

原文地址：http://www.cnblogs.com/0315cz/p/7993312.html