知識手冊之談WCF行為擴(kuò)展
WCF行為擴(kuò)展有很多值得學(xué)習(xí)的地方,大家可以上網(wǎng)收收資料了解一下,本人比較熱愛WCF這門技術(shù),我先給大家總結(jié)點(diǎn)關(guān)于WCF行為擴(kuò)展的知識。WCF以其靈活的可擴(kuò)展架構(gòu)為開發(fā)者提供了方便,其中WCF行為擴(kuò)展或許是應(yīng)用中最為常見的。自定義對行為的擴(kuò)展并不復(fù)雜,但仍有許多細(xì)節(jié)需要注意。
#T#在服務(wù)端,一般是對DispatchRuntime和DispatchOperation進(jìn)行擴(kuò)展,擴(kuò)展點(diǎn)包括了對參數(shù)和消息的檢查,以及操作調(diào)用程序,它們對應(yīng)的接口分別為IParameterInspector,IDispatchMessageInspector以及 IOperationInvoker。而在客戶端,則是對ClientRuntime和ClientOperation進(jìn)行擴(kuò)展,擴(kuò)展點(diǎn)包括對參數(shù)和消息的檢查,對應(yīng)的接口分別為IParameterInspector和IClientMessageInspector。這些接口類型均被定義在 System.ServiceModel.Dispatcher命名空間下,其中IParameterInspector接口可以同時作用在服務(wù)端和客戶端。
對這些接口的實(shí)現(xiàn),有點(diǎn)類似于AOP的實(shí)現(xiàn),可以對方法調(diào)用前和調(diào)用后注入一些額外的邏輯,所以通常會將這些擴(kuò)展稱為偵聽器。例如IParameterInspector接口,就定義了如下方法:
- void AfterCall(string operationName, object[] outputs, object returnValue, object correlationState);
- object BeforeCall(string operationName, object[] inputs);
在調(diào)用服務(wù)對象的目標(biāo)方法前,會調(diào)用BeforeCall方法,而在調(diào)用后則會調(diào)用AfterCall方法。例如我們可在方法調(diào)用前檢驗(yàn)計(jì)算方法的參數(shù)是否小于0,如果小于0則拋出異常:
- public class CalculatorParameterInspector:IParameterInspector
- {
- public void BeforeCall(string operationName, object[] inputs)
- {
- int x = inputs[0] as int;
- int y = inputs[1] as int;
- if (x <0 || y < 0)
- {
- throw new FaultException("The number can not be less than zero.");
- }
- return null;
- }
- public void AfterCall(string operationName, object[] outputs, object returnValue, object correlationState)
- {
- //empty;
- }
- }
對消息的檢查區(qū)分了服務(wù)端和客戶端,接口方法根據(jù)消息傳遞的順序剛好相反[注]。我們可以通過接口方法對消息進(jìn)行處理,例如打印消息的Header:
- public class PrintMessageInterceptor : IDispatchMessageInspector
- {
- #region IDispatchMessageInspector Members
- public object AfterReceiveRequest(ref System.ServiceModel.Channels.Message request, IClientChannel channel, InstanceContext instanceContext)
- {
- MessageBuffer buffer = request.CreateBufferedCopy(Int32.MaxValue);
- request = buffer.CreateMessage();
- Console.WriteLine("After Receive Request:");
- foreach (MessageHeader header in request.Headers)
- {
- Console.WriteLine(header);
- }
- Console.WriteLine(new string('*', 20));
- return null;
- }
- public void BeforeSendReply(ref System.ServiceModel.Channels.Message reply, object correlationState)
- {
- MessageBuffer buffer = reply.CreateBufferedCopy(Int32.MaxValue);
- reply = buffer.CreateMessage();
- Console.WriteLine("Before Send Request:");
- foreach (MessageHeader header in reply.Headers)
- {
- Console.WriteLine(header);
- }
- Console.WriteLine(new string('*', 20));
- }
- #endregion