码迷,mamicode.com
首页 > 其他好文 > 详细

WCF如何通过契约加编码方式调用

时间:2015-10-23 18:46:13      阅读:121      评论:0      收藏:0      [点我收藏+]

标签:

WCF采用基于契约的服务调用方法,通过System.ServiceModel.ChannelFactory<TChannel>直接创建服务代理对象。

创建服务代理

 public static T Create<T>(string endpointName)
        {
            if (string.IsNullOrEmpty(endpointName))
            {
                #region 默认配置,根据类名,赋值endpointName
                #endregion
                throw new ArgumentNullException("endpointName");
            }
            return (T)(new ServiceRealProxy<T>(endpointName).GetTransparentProxy());
        }
  public class ServiceRealProxy<T> : RealProxy
    {
        private readonly string _endpointName;

        public ServiceRealProxy(string endpointName)
            : base(typeof(T))
        {
            if (string.IsNullOrEmpty(endpointName))
            {
                throw new ArgumentNullException("endpointName");
            }
            _endpointName = endpointName;
        }

        public override IMessage Invoke(IMessage msg)
        {
            T channel = ChannelFactoryCreator.Create<T>(this._endpointName).CreateChannel();
            var methodCall = (IMethodCallMessage)msg;
            IMethodReturnMessage methodReturn = null;
            object[] copiedArgs = Array.CreateInstance(typeof(object), methodCall.Args.Length) as object[];
            methodCall.Args.CopyTo(copiedArgs, 0);
            try
            {
                object returnValue = methodCall.MethodBase.Invoke(channel, copiedArgs);
                methodReturn = new ReturnMessage(returnValue, copiedArgs, copiedArgs.Length, methodCall.LogicalCallContext, methodCall);
                var communicationObject = channel as ICommunicationObject;
                if (communicationObject != null) communicationObject.Close();
            }
            catch (Exception ex)
            {
                if (ex.InnerException is CommunicationException || ex.InnerException is TimeoutException)
                {
                    var communicationObject = channel as ICommunicationObject;
                    if (communicationObject != null) communicationObject.Abort();
                }

                methodReturn = ex.InnerException != null ? new ReturnMessage(ex.InnerException, methodCall) : new ReturnMessage(ex, methodCall);
            }

            return methodReturn;
        }
    }

 

WCF如何通过契约加编码方式调用

标签:

原文地址:http://www.cnblogs.com/kingCpp/p/4905247.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!