客户端调用wcf ,有时需要动态的调用服务端的WCF中的方法,本方法,反射wcf 的接口,动态调用接口中的方法。
主要为,动态绑定,反射动态调用。
publicstaticobjectExecuteMethod<T>(stringpUrl,stringpMethodName,paramsobject[]pParams)
{
EndpointAddressaddress=newEndpointAddress(pUrl);
Bindingbindinginstance=null;
NetTcpBindingws=newNetTcpBinding();
ws.MaxReceivedMessageSize=20971520;
ws.Security.Mode=SecurityMode.None;
bindinginstance=ws;
using(ChannelFactory<T>channel=newChannelFactory<T>(bindinginstance,address))
{
Tinstance=channel.CreateChannel();
using(instanceasIDisposable)
{
try
{
Typetype=typeof(T);
MethodInfomi=type.GetMethod(pMethodName);
returnmi.Invoke(instance,pParams);
}
catch(TimeoutException)
{
(instanceasICommunicationObject).Abort();
throw;
}
catch(CommunicationException)
{
(instanceasICommunicationObject).Abort();
throw;
}
catch(ExceptionvErr)
{
(instanceasICommunicationObject).Abort();
throw;
}
}
}
}
本文使用的是nettcpbinding 绑定方式,可修改。
调用方法使用
ExecuteMethod<IService>("net.tcp://192.168.0.1:8001/mex", "Test", new object[] { "参数" })
动态调用WCF服务,只需要提供*.svc地址,
1:命名空间:
using System.ServiceModel.Channels;
using System.ServiceModel;
2:创建访问类InvokeContext
public class InvokeContext
{
#region Wcf服务工厂
public static T CreateWCFServiceByURL<T>(string url)
{
return CreateWCFServiceByURL<T>(url, "wsHttpBinding");
}
public static T CreateWCFServiceByURL<T>(string url,string bing)
{
if (string.IsNullOrEmpty(url)) throw new NotSupportedException("this url isn`t Null or Empty!");
EndpointAddress address = new EndpointAddress(url);
Binding binding = CreateBinding(bing);
ChannelFactory<T> factory = new ChannelFactory<T>(binding, address);
return factory.CreateChannel();
}
#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.MaxReceivedMessageSize = 65535000;
bindinginstance = ws;
}
else if (binding.ToLower() == "netnamedpipebinding")
{
NetNamedPipeBinding ws = new NetNamedPipeBinding();
ws.MaxReceivedMessageSize = 65535000;
bindinginstance = ws;
}
else if (binding.ToLower() == "netpeertcpbinding")
{
NetPeerTcpBinding ws = new NetPeerTcpBinding();
ws.MaxReceivedMessageSize = 65535000;
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() == "wsdualhttpbinding")
{
WSDualHttpBinding ws = new WSDualHttpBinding();
ws.MaxReceivedMessageSize = 65535000;
bindinginstance = ws;
}
else if (binding.ToLower() == "webhttpbinding")
{
WebHttpBinding ws = new WebHttpBinding();
ws.MaxReceivedMessageSize = 65535000;
bindinginstance = ws;
}
else if (binding.ToLower() == "wsfederationhttpbinding")
{
WSFederationHttpBinding ws = new WSFederationHttpBinding();
ws.MaxReceivedMessageSize = 65535000;
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
}
3.T为调用的接口类型,就是WCF返回的类的实例,由于我的WCF是基于接口的,所以加了一个接品类型判断,调用时直接写:Interface iface = InvokeContext.CreateWCFServiceByURL<Interface>(url);
2009-07-28 10:57 by lome, 3343 阅读,21评论,收藏,编辑
通常我们在程序中需要调用WebService时,都是通过“添加Web引用”,让VS.NET环境来为我们生成服务代理,然后调用对应的Web服务。这样是使工作简单了,但是却和提供Web服务的URL、方法名、参数绑定在一起了,这是VS.NET自动为我们生成Web服务代理的限制。如果哪一天发布Web服务的URL改变了,则我们需要重新让VS.NET生成代理,并重新编译。在某些情况下,这可能是不能忍受的,我们需要动态调用WebService的能力。比如我们可以把Web服务的URL保存在配置文件中,这样,当服务URL改变时,只需要修改配置文件就可以了。
说了这么多,实际上我们要实现这样的功能:
publicstaticobjectInvokeWebService(stringurl,stringmethodname,object[]
args)
其中,url是Web服务的地址,methodname是要调用服务方法名,args是要调用Web服务所需的参数,返回值就是web服务返回的结果了。
要实现这样的功能,你需要这几个方面的技能:反射、CodeDom、编程使用C#编译器、WebService。在了解这些知识后,就可以容易的实现web服务的动态调用了:
#regionInvokeWebService
//动态调用web服务
publicstaticobjectInvokeWebService(stringurl,stringmethodname,object[]
args)
{
returnWebServiceHelper.InvokeWebService(url ,null,methodname ,args) ;
}
publicstaticobjectInvokeWebService(stringurl,stringclassname,stringmethodname,object[]
args)
{
string@namespace="EnterpriseServerBase.WebService.DynamicWebCalling";
if((classname==null)||(classname==""))
{
classname=WebServiceHelper.GetWsClassName(url) ;
}
try
{
//获取WSDL
WebClient wc=newWebClient();
Stream stream=wc.OpenRead(url+"?WSDL");
ServiceDescription sd=ServiceDescription.Read(stream);
ServiceDescriptionImporter sdi=newServiceDescriptionImporter();
sdi.AddServiceDescription(sd,"","");
CodeNamespace cn=newCodeNamespace(@namespace);
//生成客户端代理类代码
CodeCompileUnit ccu=newCodeCompileUnit();
ccu.Namespaces.Add(cn);
sdi.Import(cn ,ccu);
CSharpCodeProvider csc=newCSharpCodeProvider();
ICodeCompiler icc=csc.CreateCompiler();
//设定编译参数
CompilerParameters cplist=newCompilerParameters();
cplist.GenerateExecutable=false;
cplist.GenerateInMemory=true;
cplist.ReferencedAssemblies.Add("System.dll");
cplist.ReferencedAssemblies.Add("System.XML.dll");
cplist.ReferencedAssemblies.Add("System.Web.Services.dll");
cplist.ReferencedAssemblies.Add("System.Data.dll");
//编译代理类
CompilerResults cr=icc.CompileAssemblyFromDom(cplist, ccu);
if(true==cr.Errors.HasErrors)
{
System.Text.StringBuilder sb=newSystem.Text.StringBuilder();
foreach(System.CodeDom.Compiler.CompilerError ceincr.Errors)
{
sb.Append(ce.ToString());
sb.Append(System.Environment.NewLine);
}
thrownewException(sb.ToString());
}
//生成代理实例,并调用方法
System.Reflection.Assembly assembly=cr.CompiledAssembly;
Type t=assembly.GetType(@namespace+"."+classname,true,true);
objectobj=Activator.CreateInstance(t);
System.Reflection.MethodInfo mi=t.GetMethod(methodname);
returnmi.Invoke(obj,args);
}
catch(Exception ex)
{
thrownewException(ex.InnerException.Message,newException(ex.InnerException.StackTrace));
}
}
privatestaticstringGetWsClassName(stringwsUrl)
{
string[] parts=wsUrl.Split('/')
;
string[] pps=parts[parts.Length-1].Split('.')
;
returnpps[0] ;
}
#endregion
上面的注释已经很好的说明了各代码段的功能,下面给个例子看看,这个例子是通过访问http://www.webservicex.net/globalweather.asmx服务来获取各大城市的天气状况。
stringurl="http://www.webservicex.net/globalweather.asmx";
string[] args=newstring[2]
;
args[0]=this.textBox_CityName.Text
;
args[1]="China";
objectresult=WebServiceHelper.InvokeWebService(url ,"GetWeather",args)
;
this.label_Result.Text=result.ToString() ;
上述的例子中,调用web服务使用了两个参数,第一个是城市的名字,第二个是国家的名字,Web服务返回的是XML文档,可以从其中解析出温度、风力等天气情况。
最后说一下,C#虽然仍属于静态语言之列,但是其动态能力也是很强大的,不信,你可以看看Spring.net的AOP实现,这种“无侵入”的AOP实现比通常的.NET声明式AOP实现(一般是通过AOP Attribute)要漂亮的多。
分享到:
相关推荐
JS调用WCF服务实例(WCF服务宿主到控制台),解决Js跨域调用问题 源码实例 wcf宿主到控制台上,并内置js调用服务的源码
wcf,c#调用wcf 服务,包括 服务器端,客服端 简单示例供参考
Eclipse写的java application客户端代码,调用带x509证书加密的WCF Service 具体解决方案情况我的blog http://blog.csdn.net/marvion/archive/2009/03/23/4015785.aspx
Java调用WCF服务实现不同程序间数据传输
使用js+ajax调用WCF服务,博客地址:http://blog.csdn.net/zaijianluoye110/article/details/25364945
由于自己在学习silverlight中调用wcf服务遇到了一些麻烦,走了弯路,现在整理一个非常简要的demo供大家使用!相关说明:http://blog.csdn.net/liushengpiaoxu/archive/2009/02/28/3945454.aspx
VS2010中使用Jquery调用Wcf服务源码
两个解决方案实现WCF远程调用
服务器端用的C# wcf 使用的exe做宿主程序。 android客户端调用的ksoap2-android-assembly-2.5.2-...文章链接:http://blog.csdn.net/long704480904/article/details/8636734 这个是调用web服务的,很有参考价值。
1.文件夹SilverlightFrmWcf : winform程序托管wcf服务Silverlight调用wcf 跨域解决方案 (1)解决方案frmWcfService:winform程序托管wcf服务 (2)Silverlight项目调用wcf解决方案 2.文件夹SilverlightWCFDemo: iis...
Silverlight调用WCF服务引用示例
php调用WCF,返回list〈T〉的结果,传入参数,传入带List的参数
SoapClient调用WCF服务,自己碰到的一些问题,特来分享
资源 java client客户短调用WCF服务代码1 java client客户短调用WCF服务代码2 java client客户短调用WCF服务代码(eclipse需要的jar文件) 具体解决方案情况我的blog ...
使用C#编写的WCF程序例程,详细信息如下: 1、一个DLL(ClassLibrary1) 2、一个服务端(winServer2) 3、一个客户端(client)
此demo是对silverlight调用wcf服务的练习,实现了客户端与服务端进行字符串传递,使用http协议
这个就不用多说了, 自己做的, VS2008。 http://blog.csdn.net/yenange/article/details/29931139
异步编程趋于同步 利用async和await调用wcf服务
WCF服务创建,并调用(调用过程,不需添加服务引用)。 打破传统的添加服务引用的方式,直接通过地址调用。请求和返回结果以JSON的形式来添加
wcf 用代理类的方法动态调用,不用去引用直接使用,使用的方法全在类注释上面。