Csharp/C#教程：总结C#动态调用WCF接口的两种方法分享

如何使用

1、第一种方式比较简单，而且也是大家喜欢的，因为不需要任何配置文件就可解决，只需知道服务契约接口和服务地址就可以调用。

2、使用Invoke的方式，但是需要在调用客户端配置WCF，配置后在Invoke类里封装服务契约接口即可。

客户端调用DEMO

//第一种方式 stringurl="https://localhost:3000/DoubleService.svc"; IDoubleServiceproxy=WcfInvokeFactory.CreateServiceByUrl<IDoubleService>(url); intresult=proxy.Add(1,3); //第二种方式<br><br>intresult1=WCFInvoke.Invoke(t=>t.Add(1,3));<br><br> <system.serviceModel> <behaviors> <endpointBehaviors> <behaviorname="NewBehavior"> <dataContractSerializermaxItemsInObjectGraph="65536000"/> </behavior> </endpointBehaviors> </behaviors> <bindings> <basicHttpBinding> <bindingname="BasicHttpBinding_IDoubleService" closeTimeout="01:00:00" openTimeout="01:00:00" sendTimeout="01:00:00" receiveTimeout="01:00:00" maxBufferSize="2147483647" maxBufferPoolSize="524288" maxReceivedMessageSize="2147483647"> <readerQuotasmaxDepth="128"maxStringContentLength="2147483647"maxArrayLength="16384"maxBytesPerRead="4096"maxNameTableCharCount="16384"/> </binding> </basicHttpBinding> <netMsmqBinding> <bindingname="NetMsmqBinding_IAsyncSender"> <securitymode="None"/> </binding> </netMsmqBinding> </bindings> <client> <endpointaddress="https://localhost:3000/DoubleService.svc" binding="basicHttpBinding" bindingConfiguration="BasicHttpBinding_IDoubleService" contract="DoubleStone.WebHost.IDoubleService" name="BasicHttpBinding_IDoubleService"/> </client> </system.serviceModel>

第一种调用方式

publicclassWcfInvokeFactory { #regionWCF服务工厂 publicstaticTCreateServiceByUrl<T>(stringurl) { returnCreateServiceByUrl<T>(url,"basicHttpBinding"); } publicstaticTCreateServiceByUrl<T>(stringurl,stringbing) { try { if(string.IsNullOrEmpty(url))thrownewNotSupportedException("ThisurlisnotNullorEmpty!"); EndpointAddressaddress=newEndpointAddress(url); Bindingbinding=CreateBinding(bing); ChannelFactory<T>factory=newChannelFactory<T>(binding,address); returnfactory.CreateChannel(); } catch(Exceptionex) { thrownewException("创建服务工厂出现异常."); } } #endregion #region创建传输协议 ///<summary> ///创建传输协议 ///</summary> ///<paramname="binding">传输协议名称</param> ///<returns></returns> privatestaticBindingCreateBinding(stringbinding) { Bindingbindinginstance=null; if(binding.ToLower()=="basichttpbinding") { BasicHttpBindingws=newBasicHttpBinding(); ws.MaxBufferSize=2147483647; ws.MaxBufferPoolSize=2147483647; ws.MaxReceivedMessageSize=2147483647; ws.ReaderQuotas.MaxStringContentLength=2147483647; ws.CloseTimeout=newTimeSpan(0,30,0); ws.OpenTimeout=newTimeSpan(0,30,0); ws.ReceiveTimeout=newTimeSpan(0,30,0); ws.SendTimeout=newTimeSpan(0,30,0); bindinginstance=ws; } elseif(binding.ToLower()=="nettcpbinding") { NetTcpBindingws=newNetTcpBinding(); ws.MaxReceivedMessageSize=65535000; ws.Security.Mode=SecurityMode.None; bindinginstance=ws; } elseif(binding.ToLower()=="wshttpbinding") { WSHttpBindingws=newWSHttpBinding(SecurityMode.None); ws.MaxReceivedMessageSize=65535000; ws.Security.Message.ClientCredentialType=System.ServiceModel.MessageCredentialType.Windows; ws.Security.Transport.ClientCredentialType=System.ServiceModel.HttpClientCredentialType.Windows; bindinginstance=ws; } returnbindinginstance; } #endregion }

第二种调用方式

publicclassWCFInvoke { ///<summary> ///你需要调用的服务契约 ///</summary> ///<typeparamname="T"></typeparam> ///<paramname="func"></param> ///<returns></returns> publicstaticTInvoke<T>(Func<IDoubleService,T>func) { IServiceInvokerserviceInvoker=newWCFServiceInvoker(); returnserviceInvoker.InvokeService(func); } } publicinterfaceIServiceInvoker { voidInvokeService<T>(Action<T>invokeHandler)whereT:class; TResltInvokeService<T,TReslt>(Func<T,TReslt>invokeHandler)whereT:class; } publicclassWCFServiceInvoker:IServiceInvoker { privatestaticreadonlyChannelFactoryManagerFactoryManager=newChannelFactoryManager(); privatestaticreadonlyClientSectionClientSection= ConfigurationManager.GetSection("system.serviceModel/client")asClientSection; publicvoidInvokeService<T>(Action<T>invokeHandler)whereT:class { KeyValuePair<string,string>endpointNameAddressPair=GetEndpointNameAddressPair(typeof(T)); vararg=FactoryManager.CreateChannel<T>(endpointNameAddressPair.Key,endpointNameAddressPair.Value); varobj2=(ICommunicationObject)arg; try { invokeHandler(arg); } finally { try { if(obj2.State!=CommunicationState.Faulted) { obj2.Close(); } } catch { obj2.Abort(); } } } publicTResltInvokeService<T,TReslt>(Func<T,TReslt>invokeHandler)whereT:class { KeyValuePair<string,string>endpointNameAddressPair=GetEndpointNameAddressPair(typeof(T)); vararg=FactoryManager.CreateChannel<T>(endpointNameAddressPair.Key,endpointNameAddressPair.Value); varobj2=(ICommunicationObject)arg; try { returninvokeHandler(arg); } finally { try { if(obj2.State!=CommunicationState.Closed||obj2.State!=CommunicationState.Faulted) { obj2.Close(); } } catch { obj2.Abort(); } } } privateKeyValuePair<string,string>GetEndpointNameAddressPair(TypeserviceContractType) { varconfigException= newConfigurationErrorsException( string.Format( "Noclientendpointfoundfortype{0}.Pleaseaddthesection<client><endpointname="myservice"address="https://address/"binding="basicHttpBinding"contract="{0}"/></client>intheconfigfile.", serviceContractType)); if(((ClientSection==null)||(ClientSection.Endpoints==null))||(ClientSection.Endpoints.Count<1)) { throwconfigException; } foreach(ChannelEndpointElementelementinClientSection.Endpoints) { if(element.Contract==serviceContractType.ToString()) { returnnewKeyValuePair<string,string>(element.Name,element.Address.AbsoluteUri); } } throwconfigException; } } publicclassChannelFactoryManager:IDisposable { privatestaticreadonlyDictionary<Type,ChannelFactory>Factories=newDictionary<Type,ChannelFactory>(); privatestaticreadonlyobjectSyncRoot=newobject(); publicvoidDispose() { Dispose(true); } publicvirtualTCreateChannel<T>()whereT:class { returnCreateChannel<T>("*",null); } publicvirtualTCreateChannel<T>(stringendpointConfigurationName)whereT:class { returnCreateChannel<T>(endpointConfigurationName,null); } publicvirtualTCreateChannel<T>(stringendpointConfigurationName,stringendpointAddress)whereT:class { Tlocal=GetFactory<T>(endpointConfigurationName,endpointAddress).CreateChannel(); ((IClientChannel)local).Faulted+=ChannelFaulted; returnlocal; } protectedvirtualChannelFactory<T>GetFactory<T>(stringendpointConfigurationName,stringendpointAddress) whereT:class { lock(SyncRoot) { ChannelFactoryfactory; if(!Factories.TryGetValue(typeof(T),outfactory)) { factory=CreateFactoryInstance<T>(endpointConfigurationName,endpointAddress); Factories.Add(typeof(T),factory); } return(factoryasChannelFactory<T>); } } privateChannelFactoryCreateFactoryInstance<T>(stringendpointConfigurationName,stringendpointAddress) { ChannelFactoryfactory=null; factory=!string.IsNullOrEmpty(endpointAddress)?newChannelFactory<T>(endpointConfigurationName,newEndpointAddress(endpointAddress)):newChannelFactory<T>(endpointConfigurationName); factory.Faulted+=FactoryFaulted; factory.Open(); returnfactory; } privatevoidChannelFaulted(objectsender,EventArgse) { varchannel=(IClientChannel)sender; try { channel.Close(); } catch { channel.Abort(); } } privatevoidFactoryFaulted(objectsender,EventArgsargs) { varfactory=(ChannelFactory)sender; try { factory.Close(); } catch { factory.Abort(); } Type[]genericArguments=factory.GetType().GetGenericArguments(); if((genericArguments.Length==1)) { Typekey=genericArguments[0]; if(Factories.ContainsKey(key)) { Factories.Remove(key); } } } protectedvirtualvoidDispose(booldisposing) { if(disposing) { lock(SyncRoot) { foreach(TypetypeinFactories.Keys) { ChannelFactoryfactory=Factories[type]; try { factory.Close(); } catch { factory.Abort(); } } Factories.Clear(); } } } }

上述就是C#学习教程：总结C#动态调用WCF接口的两种方法分享的全部内容，如果对大家有所用处且需要了解更多关于C#学习教程，希望大家多多关注—计算机技术网(www.ctvol.com)!