WCF框架处理流程初探

时间：2022-01-11 15:09:00

拜读了大牛蒋金楠的《WCF技术剖析之一：通过一个ASP.NET程序模拟WCF基础架构》，写点心得。

(原文：http://www.cnblogs.com/artech/archive/2009/06/18/1506163.html#!comments)

首先需要理解的是WCF的大致处理流程，设计到了哪些主要的类。下面的图片很好的诠释了处理流程。

WCF框架处理流程初探

代码上，作者在客户端和服务端分别创建了需要用来编码的Encoder和用来序列化/反序列化的DispatchFormatter,实际用到的类是DataContractSerializerOperationFormatter(看名字大概知道它是用来处理datacontract里的operationcontract，即方法的序列化/反序列化)，并且建立了servicecontract的operationname/action name到相应的DispatchFormatter的字典，相当于客户端和服务端的约定。

结合代码一个个来看，首先看服务端：

1.接受request，然后Encoder对象会对request进行读取，解码，得到一个Message对象，Message的MessageHeaders包含一个重要的属性Action,后面会用到。

Message request = encoderFactory.Encoder.ReadMessage(this.Request.InputStream,

                int.MaxValue, "application/soap+xml;charset=utf-8");

2.接下来是反序列化，服务端要知道客户端想使用哪个service，哪个方法，传了什么参数，需要返回什么参数，返回什么结果。这些通过action可以得到，有了action,就能知道客户要调哪个method,要调哪个DispatchFormatter去反序列化。

            string action = request.Headers.Action;

            MethodInfo method = methods[action];

            int outArgsCount = ;

            foreach (var parameter in method.GetParameters())

            {

                if (parameter.IsOut) { outArgsCount++; }

            }

            int inputArgsCount = method.GetParameters().Length - outArgsCount;

            object[] parameters = new object[inputArgsCount];

            try

            {

                dispatchFormatters[action].DeserializeRequest(request, parameters);

            }

            catch

            {

            }

3.DispatcherFormatter反序列化之后，应该是要create相应的service、method,传入parameter,然后invoke.这里action再次用来关联对应的DispatchFormatter和operationInvokers,但是对于serviceInstance,作者固定了是CalculatorService,不知实际情况是不是也来自于Message.

object serviceInstance = Activator.CreateInstance(typeof(CalculatorService));

            object result = operationInvokers[action].Invoke(serviceInstance, parameters, out outArgs);

            Message reply = dispatchFormatters[action].SerializeReply(messageversion, outArgs, result);

4.执行完了operation之后，接下来要返回给客户端了，上一步，operation invoke的时候，把返回值，out parameter都序列化起来，也得到一个Message对象，

这个时候再调用Encoder进行编码，传递给Response.

 this.Response.ClearContent();

 this.Response.ContentEncoding = Encoding.UTF8;

 this.Response.ContentType = "application/soap+xml; charset=utf-8";

 encoderFactory.Encoder.WriteMessage(reply, this.Response.OutputStream);

            this.Response.Flush();

服务端的任务大致是：从request流中Read(解码)出Message对象，Mesage对象包含了丰富的信息，服务端可以找到要请求的service,method,传入参数，要返回的类型，out参数等，然后DispatchFormatter进行反序列化，动态创建和执行，完了返回Message对象，Encoder再进行Write(编码到outputstream)，然后返回。

再来看客户端代码：

客户端同样也会先创建好encoder, DispatchFormatter等，并且把operation name/action name做好字典关联。

1.客户端通过RealProxy的GetTransparentProxy()来返回servicecontract对象(这个不太明白？)

ICalculator calculator = SerivceProxyFactory<ICalculator>.Create(

                MessageVersion.Default,

                new Uri("http://localhost/Artech.WcfFrameworkSimulator/Calculator.aspx"));

 public static T Create(MessageVersion messageVersion,Uri remoteAddress)

        {

             MessageEncoderFactory encoderFactory;

             IDictionary<string, IClientMessageFormatter> clientFormatters;

             IDictionary<string, IDispatchMessageFormatter> dispatchFormatters;

             IDictionary<string, IOperationInvoker> operationInvokers;

             IDictionary<string, MethodInfo> methods;

             Utility.Create<T>(out encoderFactory,out clientFormatters,out dispatchFormatters,out operationInvokers,out methods);

             ServiceRealProxy<T> realProxy = new ServiceRealProxy<T>(messageVersion, remoteAddress, clientFormatters, encoderFactory);

             return (T) realProxy.GetTransparentProxy();

        }

2.然后重写了RealProxy的Invoke方法来模拟wcf框架客户端做的一系列事情，下面这句话重要,当第2句执行时，第1句的methodCall得到调用的operationcontract，后面的都基于此发生。

 IMethodCallMessage methodCall = (IMethodCallMessage)msg;

double result = calculator.Add(, );

3. 得到operationcontractattribute, 序列化消息，添加ws-address报头，编码等。

OperationContractAttribute attribute = (OperationContractAttribute)attributes[];

            string operationName = string.IsNullOrEmpty(attribute.Name) ? methodCall.MethodName : attribute.Name;

            //序列化请求消息

            Message requestMessage = this._messageFormatters[operationName].SerializeRequest(this._messageVersion, methodCall.InArgs);

            //添加必要的WS-Address报头

            EndpointAddress address = new EndpointAddress(this._remoteAddress);

            requestMessage.Headers.MessageId = new UniqueId(Guid.NewGuid());

            requestMessage.Headers.ReplyTo = new EndpointAddress("http://www.w3.org/2005/08/addressing/anonymous");

            address.ApplyTo(requestMessage);

            //对请求消息进行编码，并将编码生成的字节发送通过HttpWebRequest向服务端发送

            HttpWebRequest webRequest = (HttpWebRequest)HttpWebRequest.Create(this._remoteAddress);

            webRequest.Method = "Post";

            webRequest.KeepAlive = true;

            webRequest.ContentType = "application/soap+xml; charset=utf-8";

            ArraySegment<byte> bytes = this._messageEncoderFactory.Encoder.WriteMessage(requestMessage, int.MaxValue, BufferManager.CreateBufferManager(long.MaxValue, int.MaxValue));

            webRequest.ContentLength = bytes.Array.Length;

            webRequest.GetRequestStream().Write(bytes.Array, , bytes.Array.Length);

            webRequest.GetRequestStream().Close();

            WebResponse webResponse = webRequest.GetResponse();

4.再然后是得到服务端的response,解码，反序列化，得到返回值和out/ref参数，最终完成调用。

//对HttpResponse进行解码生成回复消息.

            Message responseMessage = this._messageEncoderFactory.Encoder.ReadMessage(webResponse.GetResponseStream(), int.MaxValue);

            //回复消息进行反列化生成相应的对象，并映射为方法调用的返回值或者ref/out参数

            object[] allArgs = (object[])Array.CreateInstance(typeof(object), methodCall.ArgCount);

            Array.Copy(methodCall.Args, allArgs, methodCall.ArgCount);

            object[] refOutParameters = new object[GetRefOutParameterCount(methodCall.MethodBase)];

            object returnValue = this._messageFormatters[operationName].DeserializeReply(responseMessage, refOutParameters);

            MapRefOutParameter(methodCall.MethodBase, allArgs, refOutParameters);

            //通过ReturnMessage的形式将返回值和ref/out参数返回

            return new ReturnMessage(returnValue, allArgs, allArgs.Length, methodCall.LogicalCallContext, methodCall);

相关文章