C# WebClient调用WebService

WebClient调用WebService

（文末下载完整代码）

先上代码：

      object[] inObjects = new[] { "14630, 14631" };
      HttpWebClient wc = new HttpWebClient(2300);
      var result1 = WebServiceClientHelper.InvokeWebService("ESBService_TEST", "http://localhost/ESBService/VitalSign.svc?wsdl", "QueryVocabSet", inObjects, wc);
      WriteLine(result1.ToString());

    public class HttpWebClient : WebClient
    {
        /// <summary>
        /// 初始化需要设置超时时间，以毫秒为单位
        /// </summary>
        /// <param name="timeout">毫秒为单位</param>
        public HttpWebClient(int timeout)
        {
            Timeout = timeout;
        }

        public int Timeout { get; set; }

        /// <summary>
        /// 重写 GetWebRequest，添加 WebRequest 对象超时时间
        /// </summary>
        protected override WebRequest GetWebRequest(Uri address)
        {
            HttpWebRequest request = (HttpWebRequest)base.GetWebRequest(address);
            request.Timeout = Timeout;
            request.ReadWriteTimeout = Timeout;
            return request;
        }
    }

　　HttpWebRequest 改造依据：

WebClient	HttpWebRequest
提供用于将数据发送到由 URI 标识的资源及从这样的资源接收数据的常用方法。	public class HttpWebRequest : WebRequest, ISerializable
Assembly location: C:\Windows\Microsoft.NET\Framework\v4.0.30319\System.dll	Assembly location: C:\Windows\Microsoft.NET\Framework\v4.0.30319\System.dll
protected virtual WebRequest GetWebRequest(Uri address) { WebRequest request = WebRequest.Create(address); this.CopyHeadersTo(request); if (this.Credentials != null) request.Credentials = this.Credentials; if (this.m_Method != null) request.Method = this.m_Method; if (this.m_ContentLength != -1L) request.ContentLength = this.m_ContentLength; if (this.m_ProxySet) request.Proxy = this.m_Proxy; if (this.m_CachePolicy != null) request.CachePolicy = this.m_CachePolicy; return request; } protected virtual WebResponse GetWebResponse(WebRequest request) { WebResponse response = request.GetResponse(); this.m_WebResponse = response; return response; }	public class HttpWebClient : WebClient { /// <summary> /// 初始化需要设置超时时间，以毫秒为单位 /// </summary> /// <param name="timeout">毫秒为单位</param> public HttpWebClient(int timeout) { Timeout = timeout; } public int Timeout { get; set; } /// <summary> /// 重写 GetWebRequest，添加 WebRequest 对象超时时间 /// </summary> protected override WebRequest GetWebRequest(Uri address) { HttpWebRequest request = (HttpWebRequest)base.GetWebRequest(address); request.Timeout = Timeout; request.ReadWriteTimeout = Timeout; return request; } }

　　调用服务处理：

        public static object InvokeWebService(string providerName, string url, string methodName, object[] args, WebClient wc = null)
        {
            object result = null;

            if (wc == null) wc = new WebClient();
            using (wc)
            {
                using (Stream wsdl = wc.OpenRead(url))
                {
                    var client = GetClient(wsdl, url, methodName, providerName);
                    client.SetValue("Timeout", wsdl.ReadTimeout);
                    result = client.InvokeService(args);
                }
            }

            return result;
        }

　　形如这样 http://192.168.2.100:8090/services/dududuTest?wsdl 的地址，

　　返回的是 dududuTest 服务下公开的方法，以流的形式，

　　代码处理里面需要解读这种流，目前看到的一种方式是，把这个流解读编译成一个动态的dll，利用反射，动态调用方法。

    /// <summary>为从具有 <see cref="T:System.String" /> 指定的 URI 的资源下载的数据打开一个可读的流。</summary>
    /// <returns>一个 <see cref="T:System.IO.Stream" />，用于从资源读取数据。</returns>
    /// <param name="address">以 <see cref="T:System.String" /> 形式指定的 URI，将从中下载数据。</param>
    public Stream OpenRead(string address)
    {
      if (address == null)
        throw new ArgumentNullException(nameof (address));
      return this.OpenRead(this.GetUri(address));
    }

    /// <summary>为从具有 <see cref="T:System.Uri" /> 指定的 URI 的资源下载的数据打开一个可读的流</summary>
    /// <returns>一个 <see cref="T:System.IO.Stream" />，用于从资源读取数据。</returns>
    /// <param name="address">以 <see cref="T:System.Uri" /> 形式指定的 URI，将从中下载数据。</param>
    public Stream OpenRead(Uri address)
    {
      if (Logging.On)
        Logging.Enter(Logging.Web, (object) this, nameof (OpenRead), (object) address);
      if (address == (Uri) null)
        throw new ArgumentNullException(nameof (address));
      WebRequest request = (WebRequest) null;
      this.ClearWebClientState();
      try
      {
        request = this.m_WebRequest = this.GetWebRequest(this.GetUri(address));
        Stream responseStream = (this.m_WebResponse = this.GetWebResponse(request)).GetResponseStream();
        if (Logging.On)
          Logging.Exit(Logging.Web, (object) this, nameof (OpenRead), (object) responseStream);
        return responseStream;
      }
      catch (Exception ex)
      {
        Exception innerException = ex;
        if (innerException is ThreadAbortException || innerException is StackOverflowException || innerException is OutOfMemoryException)
        {
          throw;
        }
        else
        {
          if (!(innerException is WebException) && !(innerException is SecurityException))
            innerException = (Exception) new WebException(SR.GetString("net_webclient"), innerException);
          WebClient.AbortRequest(request);
          throw innerException;
        }
      }
      finally
      {
        this.CompleteWebClientState();
      }
    }

View Code