手机版
你好,游客 登录 注册
背景:
阅读新闻

Http异步发送之HttpWebRequest的BeginGetResponse

[日期:2019-12-25] 来源:cnblogs.com/rui1236  作者:rui1236 [字体: ]

关于http异步发送,一开始我的做法都是用thread或者task去完成的;后来发现HttpWebRequest本身就提供一个异步的方法。

总感觉.Net自己提供的异步方法可能要优于我们自己用线程去实现的好;

当然这只是我的猜想。个人感觉如果有大量异步发送还是用HttpWebRequest本身提供的异步方法好。

自己封装了下HttpWebRequest的异步请求。

/// <summary>
        /// http异步请求
        /// </summary>
        /// <param name="url">url</param>
        /// <param name="reqMethod">请求方法 GET、POST</param>
        /// <param name="callback">回调函数</param>
        /// <param name="ob">回传对象</param>
        /// <param name="postData">post数据</param>
        public static void HttpAsyncRequest(string url, string reqMethod, AsyRequetCallback callback, object ob = null, string postData = "")
        {
            Stream requestStream = null;
            try
            {
                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
                request.ContentType = "application/x-www-form-urlencoded";
                request.Method = reqMethod;
                if (reqMethod.ToUpper() == "POST")
                {
                    byte[] bytes = Encoding.UTF8.GetBytes(postData);
                    request.ContentLength = bytes.Length;
                    requestStream = request.GetRequestStream();
                    requestStream.Write(bytes, 0, bytes.Length);
                }
                //开始调用异步请求
                //AsyResultTag 是自定义类 用于传递调用时信息 其中HttpWebRequest 是必须传递对象。
                //因为回调需要用HttpWebRequest来获取HttpWebResponse
                request.BeginGetResponse(new AsyncCallback(HttpCallback), new AsyResultTag() { obj = ob, callback = callback, req = request });
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                if (requestStream != null)
                {
                    requestStream.Close();
                }
            }
        }


        /// <summary>
        /// http请求回调 由.net内部调用 参数必须为IAsyncResult
        /// </summary>
        /// <param name="asynchronousResult">http回调时回传对象</param>
        private static void HttpCallback(IAsyncResult asynchronousResult)
        {
            int statusCode = 0;
            string retString = "";
            AsyResultTag tag = new AsyResultTag();
            WebException webEx = null;
            try
            {
                //获取请求时传递的对象
                tag = asynchronousResult.AsyncState as AsyResultTag;
                HttpWebRequest req = tag.req;
                //获取异步返回的http结果
                HttpWebResponse response = req.EndGetResponse(asynchronousResult) as HttpWebResponse;
                Stream myResponseStream = response.GetResponseStream();
                StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.GetEncoding("utf-8"));
                retString = myStreamReader.ReadToEnd();
                myStreamReader.Close();
                myResponseStream.Close();
                statusCode = ((int)response.StatusCode);

            }
            catch (WebException ex)
            {
                if ((HttpWebResponse)ex.Response != null)
                {
                    statusCode = ((int)((HttpWebResponse)ex.Response).StatusCode);
                }
               
                webEx = ex;
            }
            //调用外部回调 即最外层的回调
            tag.callback(tag.obj, retString, statusCode, webEx);

        }

      /// <summary>
      /// 异步请求回调委托
      /// </summary>
      /// <param name="asyObj">回传对象</param>
      /// <param name="resStr">http响应结果</param>
      /// <param name="statusCode">http状态码</param>
      /// <param name="webEx">异常</param>
      public delegate void AsyRequetCallback(object asyObj, string respStr, int statusCode, WebException webEx);

    /// <summary>
    /// 异步返回对象
    /// </summary>
    class AsyResultTag
    {
        /// <summary>
        /// 回传对象
        /// </summary>
        public object obj { get; set; }
        /// <summary>
        /// 当前httpRequest请求实例
        /// </summary>
        public HttpWebRequest req { get; set; }
        /// <summary>
        /// 回调函数委托
        /// </summary>
        public AsyRequetCallback callback { get; set; }
    }

AsyRequetCallback 异步回调委托,即要回调的函数原型;说下每个参数的意义:

1、object asyObj:回传对象,即请求时附带的一个对象,如果没有可以不用传。比如我们当前的这个请求和用户有所关联,如当前的这个请求对应是某个用户的,请求后我要将结果写到这个用户的某个属性下面;这样我们就可以将此用户信息和当前请求一起携带过去。
2、string respStr:当前http返回结果。

3、int statusCode:http状态码,包括出错时的状态码。如404,403等。

4、WebException webEx 异常信息,异常信息也会随着回调传递到前面来,不直接向上抛或者直接log。好处在于,我们可以针对这个异常信息做单独处理。比如某个用户如果碰到什么403或者404我们应该怎么处理,又或者我们可以将错误信息随着当前用户进行保存,很好的跟踪每个用户的发送情况。

linux
相关资讯       Http异步发送 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款