WCF后续之旅(13): 创建一个简单的WCF SOAP Message拦截、转发工具[上篇]


		WCF是.NET平台下实现SOA的一种手段，SOA的一个重要的特征就基于Message的通信方式。从Messaging的角度讲，WCF可以看成是对Message进行发送、传递、接收、基础的工具。对于一个消息交换的过程，很多人只会关注message的最初的发送端和最终的接收端。实际上在很多情况下，在两者之间还存在很多的中间结点（Intermediary），这些中间结点在可能在实际的应用中发挥中重要的作用。比如，我们可以创建路由器（Router）进行消息的转发，甚至是Load Balance；可以创建一个消息拦截器（Interceptor）获取request或者response message，并进行Audit、Logging和Instrumentation。今天我们就我们的目光转向这些充当着中间人角色的Intermediary上面来。
在本篇文章中，我们将会创建一个message的拦截和转发工具（message interceptor）。它将被置于WCF调用的client和service之间，拦截并转发从client到service的request message，以及service到client的response message，并将request message和response message显示到一个可视化的界面上。我们将讨论这个message interceptor若干种不同的实现方式。
有一点需要明确说明的是，这个工具的创建并非我写作这篇文章的目的，我的目的是通过一个具体的例子让大家以一种直观方式对WCF的Addressing机制有一个深刻的认识。在介绍message interceptor的创建过程中，我会穿插介绍一个WCF的其它相关知识，比如Message Filtering、Operation Selection、Must Understand Validation等等。
一、创建一个简单的WCF应用
由于我们将要创建的message interceptor需要应用到具体的WCF应用中进行工作和检验，我们需要首先创建一个简单的WCF应用。我们创建一个简单的Calculation的例子。这个solution采用我们熟悉的四层结构（Interceptor用于host我们的message intercept service）：
 
1、Contract：Artech.MessageInterceptor.Contracts.ICalculate
 
 
   1: using System.ServiceModel;
   2: namespace Artech.MessageInterceptor.Contracts
   3: {
   4:     [ServiceContract]
   5:     public interface ICalculate
   6:     {
   7:         [OperationContract]
   8:         double Add(double x, double y);
   9:     }
  10: } 
2、Service：Artech.MessageInterceptor.Services.CalculateService 
   1: using Artech.MessageInterceptor.Contracts;
   2: namespace Artech.MessageInterceptor.Services
   3: {
   4:     public class CalculateService : ICalculate
   5:     {
   6:         #region ICalculate Members 
   7:  
   8:         public double Add(double x, double y)
   9:         {
  10:             return x + y;
  11:         } 
  12:  
  13:         #endregion
  14:     }
  15: } 
  16:  
3、Hosting：Artech.MessageInterceptor.Hosting.Program
   1: using System;
   2: using System.ServiceModel;
   3: using Artech.MessageInterceptor.Services;
   4: namespace Artech.MessageInterceptor.Hosting
   5: {
   6:     class Program
   7:     {
   8:         static void Main(string[] args)
   9:         {
  10:             using (ServiceHost host = new ServiceHost(typeof(CalculateService)))
  11:             {
  12:                 host.Opened += delegate
  13:                 {
  14:                     Console.WriteLine("The calculate service has been started up!");
  15:                 };
  16:                 host.Open();
  17:                 Console.Read();
  18:             }
  19:         }
  20:     }
  21: } 
  22:  
Configuration 
   1: <?xml version="1.0" encoding="utf-8" ?>
   2: <configuration>
   3:     <system.serviceModel>
   4:         <bindings>
   5:             <customBinding>
   6:                 <binding name="MyCustomeBinding">
   7:                     <textMessageEncoding />
   8:                     <httpTransport />
   9:                 </binding>
  10:             </customBinding>
  11:         </bindings>
  12:         <services>
  13:             <service name="Artech.MessageInterceptor.Services.CalculateService">
  14:                 <endpoint binding="customBinding" bindingConfiguration="MyCustomeBinding"
  15:                     contract="Artech.MessageInterceptor.Contracts.ICalculate" 
  16:                     address="http://127.0.0.1:9999/calculateservice"/>              
  17:             </service>
  18:         </services>
  19:     <

补充：综合编程 , 其他综合 ,