国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > C# > 正文

總結C#動態調用WCF接口的兩種方法

2019-10-29 21:21:02
字體:
來源:轉載
供稿:網友

如何使用

1、第一種方式比較簡單,而且也是大家喜歡的,因為不需要任何配置文件就可解決,只需知道服務契約接口和服務地址就可以調用。

2、使用Invoke的方式,但是需要在調用客戶端配置WCF,配置后在Invoke類里封裝服務契約接口即可。

客戶端調用DEMO

//第一種方式string url = "http://localhost:3000/DoubleService.svc";IDoubleService proxy = WcfInvokeFactory.CreateServiceByUrl<IDoubleService>(url);int result = proxy.Add(1, 3);  //第二種方式<br><br>int result1 = WCFInvoke.Invoke(t => t.Add(1, 3));<br><br><system.serviceModel>  <behaviors>   <endpointBehaviors>    <behavior name="NewBehavior">     <dataContractSerializer maxItemsInObjectGraph="65536000" />    </behavior>   </endpointBehaviors>  </behaviors>  <bindings>   <basicHttpBinding>      <binding name="BasicHttpBinding_IDoubleService"        closeTimeout="01:00:00"        openTimeout="01:00:00"        sendTimeout="01:00:00"        receiveTimeout="01:00:00"        maxBufferSize="2147483647"        maxBufferPoolSize="524288"        maxReceivedMessageSize="2147483647">     <readerQuotas maxDepth="128" maxStringContentLength="2147483647" maxArrayLength="16384" maxBytesPerRead="4096" maxNameTableCharCount="16384" />    </binding>   </basicHttpBinding>   <netMsmqBinding>    <binding name="NetMsmqBinding_IAsyncSender">     <security mode="None" />    </binding>   </netMsmqBinding>  </bindings>  <client>      <endpoint address="http://localhost:3000/DoubleService.svc"        binding="basicHttpBinding"        bindingConfiguration="BasicHttpBinding_IDoubleService"        contract="DoubleStone.WebHost.IDoubleService"        name="BasicHttpBinding_IDoubleService" />    </client> </system.serviceModel>

第一種調用方式

public class WcfInvokeFactory  {    #region WCF服務工廠    public static T CreateServiceByUrl<T>(string url)    {      return CreateServiceByUrl<T>(url, "basicHttpBinding");    }     public static T CreateServiceByUrl<T>(string url, string bing)    {      try      {        if (string.IsNullOrEmpty(url)) throw new NotSupportedException("This url is not Null or Empty!");        EndpointAddress address = new EndpointAddress(url);        Binding binding = CreateBinding(bing);        ChannelFactory<T> factory = new ChannelFactory<T>(binding, address);        return factory.CreateChannel();      }      catch (Exception ex)      {        throw new Exception("創建服務工廠出現異常.");      }    }    #endregion     #region 創建傳輸協議    /// <summary>    /// 創建傳輸協議    /// </summary>    /// <param name="binding">傳輸協議名稱</param>    /// <returns></returns>    private static Binding CreateBinding(string binding)    {      Binding bindinginstance = null;      if (binding.ToLower() == "basichttpbinding")      {        BasicHttpBinding ws = new BasicHttpBinding();        ws.MaxBufferSize = 2147483647;        ws.MaxBufferPoolSize = 2147483647;        ws.MaxReceivedMessageSize = 2147483647;        ws.ReaderQuotas.MaxStringContentLength = 2147483647;        ws.CloseTimeout = new TimeSpan(0, 30, 0);        ws.OpenTimeout = new TimeSpan(0, 30, 0);        ws.ReceiveTimeout = new TimeSpan(0, 30, 0);        ws.SendTimeout = new TimeSpan(0, 30, 0);         bindinginstance = ws;      }      else if (binding.ToLower() == "nettcpbinding")      {        NetTcpBinding ws = new NetTcpBinding();        ws.MaxReceivedMessageSize = 65535000;        ws.Security.Mode = SecurityMode.None;        bindinginstance = ws;      }      else if (binding.ToLower() == "wshttpbinding")      {        WSHttpBinding ws = new WSHttpBinding(SecurityMode.None);        ws.MaxReceivedMessageSize = 65535000;        ws.Security.Message.ClientCredentialType = System.ServiceModel.MessageCredentialType.Windows;        ws.Security.Transport.ClientCredentialType = System.ServiceModel.HttpClientCredentialType.Windows;        bindinginstance = ws;      }      return bindinginstance;     }    #endregion  }

第二種調用方式

public class WCFInvoke  {    /// <summary>    /// 你需要調用的服務契約    /// </summary>    /// <typeparam name="T"></typeparam>    /// <param name="func"></param>    /// <returns></returns>    public static T Invoke<T>(Func<IDoubleService, T> func)    {      IServiceInvoker serviceInvoker=new WCFServiceInvoker();      return serviceInvoker.InvokeService(func);    }  }public interface IServiceInvoker  {    void InvokeService<T>(Action<T> invokeHandler) where T : class;    TReslt InvokeService<T, TReslt>(Func<T, TReslt> invokeHandler) where T : class;  } public class WCFServiceInvoker:IServiceInvoker  {    private static readonly ChannelFactoryManager FactoryManager = new ChannelFactoryManager();     private static readonly ClientSection ClientSection =      ConfigurationManager.GetSection("system.serviceModel/client") as ClientSection;      public void InvokeService<T>(Action<T> invokeHandler) where T : class    {      KeyValuePair<string, string> endpointNameAddressPair = GetEndpointNameAddressPair(typeof(T));      var arg = FactoryManager.CreateChannel<T>(endpointNameAddressPair.Key, endpointNameAddressPair.Value);      var obj2 = (ICommunicationObject)arg;      try      {        invokeHandler(arg);      }      finally      {        try        {          if (obj2.State != CommunicationState.Faulted)          {            obj2.Close();          }        }        catch        {          obj2.Abort();        }      }    }      public TReslt InvokeService<T, TReslt>(Func<T, TReslt> invokeHandler) where T : class    {      KeyValuePair<string, string> endpointNameAddressPair = GetEndpointNameAddressPair(typeof(T));      var arg = FactoryManager.CreateChannel<T>(endpointNameAddressPair.Key, endpointNameAddressPair.Value);      var obj2 = (ICommunicationObject)arg;      try      {        return invokeHandler(arg);      }      finally      {        try        {          if (obj2.State != CommunicationState.Closed || obj2.State != CommunicationState.Faulted)          {            obj2.Close();          }        }        catch        {          obj2.Abort();        }      }    }     private KeyValuePair<string, string> GetEndpointNameAddressPair(Type serviceContractType)    {      var configException =        new ConfigurationErrorsException(          string.Format(            "No client endpoint found for type {0}. Please add the section <client><endpoint name=/"myservice/" address=/"http://address//" binding=/"basicHttpBinding/" contract=/"{0}/"/></client> in the config file.",            serviceContractType));      if (((ClientSection == null) || (ClientSection.Endpoints == null)) || (ClientSection.Endpoints.Count < 1))      {        throw configException;      }      foreach (ChannelEndpointElement element in ClientSection.Endpoints)      {        if (element.Contract == serviceContractType.ToString())        {          return new KeyValuePair<string, string>(element.Name, element.Address.AbsoluteUri);        }      }      throw configException;    }  }
public class ChannelFactoryManager : IDisposable  {    private static readonly Dictionary<Type, ChannelFactory> Factories = new Dictionary<Type, ChannelFactory>();    private static readonly object SyncRoot = new object();     public void Dispose()    {      Dispose(true);    }     public virtual T CreateChannel<T>() where T : class    {      return CreateChannel<T>("*", null);    }     public virtual T CreateChannel<T>(string endpointConfigurationName) where T : class    {      return CreateChannel<T>(endpointConfigurationName, null);    }     public virtual T CreateChannel<T>(string endpointConfigurationName, string endpointAddress) where T : class    {      T local = GetFactory<T>(endpointConfigurationName, endpointAddress).CreateChannel();      ((IClientChannel)local).Faulted += ChannelFaulted;      return local;    }     protected virtual ChannelFactory<T> GetFactory<T>(string endpointConfigurationName, string endpointAddress)      where T : class    {      lock (SyncRoot)      {        ChannelFactory factory;        if (!Factories.TryGetValue(typeof(T), out factory))        {          factory = CreateFactoryInstance<T>(endpointConfigurationName, endpointAddress);          Factories.Add(typeof(T), factory);        }        return (factory as ChannelFactory<T>);      }    }     private ChannelFactory CreateFactoryInstance<T>(string endpointConfigurationName, string endpointAddress)    {      ChannelFactory factory = null;      factory = !string.IsNullOrEmpty(endpointAddress) ? new ChannelFactory<T>(endpointConfigurationName, new EndpointAddress(endpointAddress)) : new ChannelFactory<T>(endpointConfigurationName);       factory.Faulted += FactoryFaulted;      factory.Open();      return factory;    }     private void ChannelFaulted(object sender, EventArgs e)    {      var channel = (IClientChannel)sender;      try      {        channel.Close();      }      catch      {        channel.Abort();      }    }     private void FactoryFaulted(object sender, EventArgs args)    {      var factory = (ChannelFactory)sender;      try      {        factory.Close();      }      catch      {        factory.Abort();      }      Type[] genericArguments = factory.GetType().GetGenericArguments();      if ((genericArguments.Length == 1))      {        Type key = genericArguments[0];        if (Factories.ContainsKey(key))        {          Factories.Remove(key);        }      }    }     protected virtual void Dispose(bool disposing)    {      if (disposing)      {        lock (SyncRoot)        {          foreach (Type type in Factories.Keys)          {            ChannelFactory factory = Factories[type];            try            {              factory.Close();            }            catch            {              factory.Abort();            }          }          Factories.Clear();        }      }    }  }

總結

第一種方式比較常見,第二種方式是我參考另外一個項目中的寫法,其中的有一些細節我還沒有搞明白,實現了這個功能后還需要再看看這部分代碼,再消化消化。以上就是這篇文章的全部內容,希望能給大家帶來一定的幫助,如果有疑問大家可以留言交流。


注:相關教程知識閱讀請移步到c#教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 枝江市| 九龙城区| 普定县| 闽清县| 涞水县| 塔河县| 平安县| 平邑县| 仲巴县| 通渭县| 怀安县| 顺义区| 濉溪县| 沁阳市| 扎鲁特旗| 鄱阳县| 伽师县| 平舆县| 如皋市| 冕宁县| 房产| 西丰县| 临沂市| 柘荣县| 嘉鱼县| 崇阳县| 洪泽县| 敦煌市| 内江市| 安阳县| 龙山县| 东平县| 青河县| 濮阳县| 浪卡子县| 镇雄县| 武山县| 茌平县| 黄骅市| 阿巴嘎旗| 桑日县|