wcf 动态调用

Love The Way You Lie 2022-06-10 01:19 215阅读 0赞

客户端调用wcf ，有时需要动态的调用服务端的WCF中的方法，本方法，反射wcf 的接口，动态调用接口中的方法。

主要为，动态绑定，反射动态调用。

public static object ExecuteMethod<T>(string pUrl, string pMethodName, params object[] pParams)
            {
                EndpointAddress address = new EndpointAddress(pUrl);
                Binding bindinginstance = null;
                NetTcpBinding ws = new NetTcpBinding();
                ws.MaxReceivedMessageSize = 20971520;
                ws.Security.Mode = SecurityMode.None;
                bindinginstance = ws;
                using (ChannelFactory<T> channel = new ChannelFactory<T>(bindinginstance, address))
                {
                    T instance = channel.CreateChannel();
                    using (instance as IDisposable)
                    {
                        try
                        {
                            Type type = typeof(T);
                            MethodInfo mi = type.GetMethod(pMethodName);
                            return mi.Invoke(instance, pParams);
                        }
                        catch (TimeoutException)
                        {
                            (instance as ICommunicationObject).Abort();
                            throw;
                        }
                        catch (CommunicationException)
                        {
                            (instance as ICommunicationObject).Abort();
                            throw;
                        }
                        catch (Exception vErr)
                        {
                            (instance as ICommunicationObject).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);