一、http请求代办代理类

public class HttpProxy { /// <summary> /// get请求 /// </summary> /// <param>接口地点</param> /// <returns></returns> public static string HttpGet(string url) { string result = string.Empty; try { //创建http 请求 HttpWebRequest httpRequset = (HttpWebRequest)HttpWebRequest.Create(url); httpRequset.Method = "GET"; httpRequset.ContentType = "text/html;charset=UTF-8"; httpRequset.Headers.Add("ignore-identity", "true"); HttpWebResponse response = (HttpWebResponse)httpRequset.GetResponse(); using (Stream responseStream = response.GetResponseStream()) { using (StreamReader sReader = new StreamReader(responseStream, Encoding.GetEncoding("utf-8"))) { result = sReader.ReadToEnd(); } } } catch (Exception ex) { throw ex; } return result; } /// <summary> /// post请求 /// </summary> /// <param>接口地点</param> /// <param>json格局</param> /// <param>自界说header信息</param> /// <returns></returns> public static string HttpPost(string url, string paramData, Dictionary<string, string> headerDic = null) { CookieContainer cookie = new CookieContainer(); string result = string.Empty; try { HttpWebRequest wbRequest = (HttpWebRequest)WebRequest.Create(url); wbRequest.Headers.Add("ignore-identity", "true"); wbRequest.CookieContainer = cookie; wbRequest.Method = "POST"; wbRequest.ContentType = "application/x-www-form-urlencoded"; wbRequest.ContentLength = Encoding.UTF8.GetByteCount(paramData); if (headerDic != null && headerDic.Count > 0) { foreach (var item in headerDic) { wbRequest.Headers.Add(item.Key, item.Value); } } using (Stream requestStream = wbRequest.GetRequestStream()) { using (StreamWriter swrite = new StreamWriter(requestStream)) { swrite.Write(paramData); } } HttpWebResponse wbResponse = (HttpWebResponse)wbRequest.GetResponse(); wbResponse.Cookies = cookie.GetCookies(wbResponse.ResponseUri); using (Stream responseStream = wbResponse.GetResponseStream()) { using (StreamReader sread = new StreamReader(responseStream)) { result = sread.ReadToEnd(); } } } catch (Exception ex) { throw ex; } return result; } }

二、客户端挪用

public class RPCService { public dynamic GetRPCData() { var url = ConfigSettings.SubjectStatRpcUrl;// :61558/stat/RpcService/SubjectStat.ashx var par = new { functionName = "GetSubjectStatByProgress", token = "c4b500e643f24dc78da2229e24557de3", codeList = new List<int> { 9527, 1434 } }; var parJson = System.Web.HttpUtility.UrlEncode(JsonConvert.SerializeObject(par)); parJson = $"cmd={parJson}"; //get 请求 var data = JsonConvert.DeserializeObject<dynamic>(HttpProxy.HttpGet($"{url}?{parJson}")); // post 请求 var data1 = JsonConvert.DeserializeObject<dynamic>(HttpProxy.HttpPost(url, parJson)); return data; } }

　三、处事端代码

public class SubjectStat : IHttpHandler { private ISubjectStatRpcService<dynamic> _iSubjectStatRpcService = new SubjectStatRpcService<dynamic>(); public void ProcessRequest(HttpContext context) { context.Response.ContentType = "application/json"; RpcService(context); } /// <summary> /// 挪用处事 /// </summary> /// <param></param> private void RpcService(HttpContext context) { try { //启用cmd={cname:"rpc",isAsync:true,functionName:"getDiscussByFile",fileCode:"",userId:""} var command = Json.Decode(System.Web.HttpUtility.UrlDecode(context.Request["cmd"])); // 要领名称 if (string.IsNullOrWhiteSpace(command.functionName)) { context.Response.Write(Json.Encode(new HandlerResult(HttpStatusCode.InternalServerError, "参数funcName不能为空"))); } // 登录验证暂时没有加，每个接口都传了一个token,是否需要验证是否登录 if (string.IsNullOrWhiteSpace(command.token)) { context.Response.Write(Json.Encode(new HandlerResult(HttpStatusCode.InternalServerError, "参数token不能为空"))); } //按照函数名调取相应的数据 switch (command.functionName.ToLower()) { case "getsubjectstatbydeptlist"://凭据部门统计 context.Response.Write(Json.Encode(GetSubjectStatByDeptList(command))); break; case "getsubjectstatbyprogress"://凭据课题研究进度统计 context.Response.Write(Json.Encode(GetSubjectStatByProgress(command))); break; default: context.Response.Write(Json.Encode(new HandlerResult(HttpStatusCode.InternalServerError, "挪用的要领不存在"))); break; } } catch (Exception ex) { context.Response.Write(Json.Encode(new HandlerResult(HttpStatusCode.InternalServerError, ex.Message))); } } /// <summary> /// 凭据部门统计 /// </summary> /// <returns></returns> private HandlerResult GetSubjectStatByDeptList(dynamic par) { // 参数验证 Todo var allCount = 0; SubjectByDeptView totalRowData = new SubjectByDeptView(); var ret = new object(); return new HandlerResult(HttpStatusCode.OK, ret); } /// <summary> /// 凭据课题研究进度统计 /// </summary> /// <returns></returns> private HandlerResult GetSubjectStatByProgress(dynamic par) { // 参数验证 Todo var allCount = 0; SubjectByDeptView totalRowData = new SubjectByDeptView(); var ret = _iSubjectStatRpcService.GetSubjectStatByProgress(par); return new HandlerResult(HttpStatusCode.OK, ret); } public bool IsReusable { get { return false; } } }