亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > C# > 正文

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

2020-01-24 00:59:13
字體:
來源:轉載
供稿:網友

如何使用

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();        }      }    }  }

總結

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
久久久www成人免费精品张筱雨| 亚洲毛片一区二区| 日韩有码在线播放| 精品中文字幕在线| 欧美在线视频免费| 欧美激情一区二区三区成人| 91亚洲精品一区二区| 亚洲成在人线av| 色婷婷综合成人| 中文字幕一精品亚洲无线一区| 奇米四色中文综合久久| 久久久亚洲国产天美传媒修理工| 精品自在线视频| 日韩在线视频一区| 精品欧美激情精品一区| 日韩少妇与小伙激情| 日韩在线观看av| 亚洲欧洲一区二区三区在线观看| 日韩最新中文字幕电影免费看| 国产日产久久高清欧美一区| 亚洲成avwww人| 夜夜躁日日躁狠狠久久88av| 欧美激情久久久久久| 91地址最新发布| 欧美电影免费观看大全| 欧美三级欧美成人高清www| 精品女同一区二区三区在线播放| 成人女保姆的销魂服务| 久久综合伊人77777蜜臀| 亚洲第一天堂无码专区| 欧美在线激情视频| 一本色道久久88亚洲综合88| 久久免费在线观看| 亚洲国产精品va在线| 欧美亚洲另类视频| 都市激情亚洲色图| 中文国产亚洲喷潮| 国产精品一区二区三区免费视频| 久久久精品2019中文字幕神马| 亚洲自拍偷拍视频| 精品久久久香蕉免费精品视频| 国产精品久久久久9999| 97在线看免费观看视频在线观看| 欧美性xxxx| 亚洲一区二区三区久久| 久久天天躁日日躁| 欧美日韩国产精品专区| 国产精品久久久久久久久久99| 国产欧美日韩中文| 国产精品高潮呻吟久久av无限| 精品国内自产拍在线观看| 国产精品亚洲第一区| 丝袜亚洲另类欧美重口| 高清欧美一区二区三区| 亚洲人成人99网站| 久久99视频免费| 国产有码在线一区二区视频| 久久久精品一区| 国产主播喷水一区二区| 精品亚洲精品福利线在观看| 亚洲国产成人精品电影| 911国产网站尤物在线观看| 色先锋资源久久综合5566| 中文字幕少妇一区二区三区| 国产精品日日做人人爱| 欧洲精品毛片网站| 国产一区二区三区四区福利| 亚洲已满18点击进入在线看片| 色综合亚洲精品激情狠狠| 精品国产一区二区三区久久狼黑人| 国产精品视频网站| 亚洲精品一区中文| 97色在线视频观看| 亚洲精品456在线播放狼人| 青青青国产精品一区二区| 国产精品视频播放| 国产91在线播放九色快色| 中文字幕不卡在线视频极品| 在线国产精品播放| 91精品国产沙发| 精品国内产的精品视频在线观看| 亚洲激情电影中文字幕| 色久欧美在线视频观看| 久久精品青青大伊人av| 91热精品视频| 日韩美女免费线视频| 亚洲在线观看视频| 亚洲jizzjizz日本少妇| 成人午夜两性视频| 成人黄色中文字幕| 亚洲va欧美va在线观看| 国产精品嫩草影院久久久| 91超碰caoporn97人人| 久久精品国产成人精品| 久久精品青青大伊人av| 91精品在线一区| 一本色道久久88综合日韩精品| 国产精品成人一区二区| 国产日韩欧美视频| 亚洲精品自拍视频| 欧美日韩国产麻豆| 欧美激情国产高清| 久久免费视频观看| 青青草精品毛片| 亚洲一区二区精品| 国产成人福利网站| 国产精品老女人精品视频| 国模gogo一区二区大胆私拍| 国产一区二区视频在线观看| 国产精品免费久久久| 精品高清一区二区三区| 视频在线一区二区| 欧美高清视频在线观看| 久久久久久久久91| 91精品免费视频| 91视频免费网站| 欧美精品videosex极品1| 久久精品亚洲热| 国产美女久久久| 亚洲三级 欧美三级| 成人网在线免费看| 色婷婷亚洲mv天堂mv在影片| 国产成人在线精品| 91精品国产综合久久男男| 精品国产一区二区三区在线观看| 亚洲一区二区久久| 国内揄拍国内精品| 久久综合色影院| 国产精品丝袜白浆摸在线| 国模极品一区二区三区| 国产亚洲一区二区精品| 欧美床上激情在线观看| 国产一区二区黄| 色香阁99久久精品久久久| 日韩成人久久久| 中文字幕日韩av| 国产欧美精品一区二区| 蜜臀久久99精品久久久久久宅男| 美女福利视频一区| 欧美精品日韩三级| 日韩中文字幕亚洲| 亚洲黄色av女优在线观看| 国产一区二区三区直播精品电影| 日韩av网站电影| 亚洲国产精品va在线| 国产精品嫩草视频| 九九久久精品一区| 日韩精品在线免费观看视频| 欧美猛男性生活免费| 91高清视频在线免费观看| 伊人男人综合视频网| 欧美成人免费网| 国产精品盗摄久久久| 日韩欧美在线中文字幕| 日本久久91av| 国产+成+人+亚洲欧洲| 日韩在线视频免费观看高清中文| 亚洲自拍另类欧美丝袜| 日韩欧美亚洲范冰冰与中字| 国产一区二区三区欧美| 国产亚洲人成a一在线v站| 久久精品亚洲94久久精品| 欧美激情精品久久久久久黑人| 黄色成人在线播放|