TerryLee技术专栏>WCF后传>正文 WCF后传系列(3):深入WCF寻址Part 3—消息过滤引擎

简介:

概述

通过前面两篇的介绍,对Web服务寻址规范以及在WCF开发中终结点地址有了深入的认识。本文我们继续深入WCF寻址第三部分内容,当消息传入时,如何来确定匹配的终结点,就是我们本文要讲到的消息筛选引擎。在WCF中,消息筛选器引擎包括两个重要的组成部分:筛选器和筛选器表。

认识消息筛选器

在WCF中当有消息传入时,它使用消息筛选器来确定匹配的终结点,每个终结点实际上关联着两个筛选器:一个地址筛选器和一个契约筛选器。地址筛选器确定传入消息是否匹配终结点的“To”地址和任何必需的地址报头,而契约筛选器则确定它是否匹配终结点的契约,两个筛选器都被调度程序用来确定目标终结点。
在WCF中,所有的消息筛选器都继承于MessageFilter抽象基类,系统内置了几种的消息筛选器,如图1所示:
TerryLee_WCF_06  
图1
EndpointAddressMessageFilter :作为默认的地址筛选器,它会将SOAP消息中的“To”地址与终结点地址进行比较,预期它们完全匹配,也会传入消息中获得的寻址报头和终结点要求的一组寻址报头进行比较,要使最终匹配的结果返回true,必须满足以下两个条件:
1. 筛选器的地址统一资源标识符 (URI) 必须与消息 To 标头中的统一资源标识符相同。
2. 筛选器地址中的每个终结点参数都必须在消息中找到一个与之匹配的标头。
ActionMessageFilter :作为默认的契约筛选器,它根据传入的SAOP消息中“Action”值和契约上的操作进行比较,确定是否匹配匹配。该筛选器在初始化时将包含一个操作字符串列表,如果筛选器的列表中的任一操作与消息或消息缓冲区中的 Action 标头匹配,则 Match 方法返回 true。 如果该列表为空,则将该筛选器视为全匹配型筛选器,任何消息或消息缓冲区都与该筛选器匹配,并且 Match 返回 true。 如果筛选器列表中没有任何操作与消息或消息缓冲区中的 Action 标头匹配,则 Match 返回 false。 如果消息中不存在任何操作且筛选器的列表非空,则 Match 返回 false。
PrefixEndpointAddressMessageFilter :此筛选器与 EndpointAddressMessageFilter 执行相同的查询,不同的是测试消息是否与终结点地址相匹配是由“最长前缀匹配”完成的。这表示筛选器中指定的 URI 不需要与消息的 URI 完全匹配,不过必须作为前缀包含在该 URI 中。例如,如果筛选器指定地址“[url]http://www.foo.com[/url]”,并且消息是发送给“[url]http://www.foo.com/customerA[/url]”,则将满足筛选器查询条件的 URI 部分,但是筛选器查询的报头部分仍需要完成。
MatchAllMessageFilter :该筛选器将导致所有消息都匹配给定终结点,看一下它的Match方法实现,除非消息为空,否则就返回True:
[DataContract]
public class MatchAllMessageFilter : MessageFilter
{
    public override bool Match(Message message)
    {
        if (message == null)
        {
            throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("message");
        }
        return true;
    }
}
MatchNoneMessageFilter :该筛选器将导致所有消息都不匹配,看一下它的Match方法实现,除非消息为空,否则就返回False:
[DataContract]
public class MatchNoneMessageFilter : MessageFilter
{
    public override bool Match(Message message)
    {
        if (message == null)
        {
            throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("message");
        }
        return false;
    }
}
XpathMessageFilter :使用 XPath 1.0 表达式来指定匹配的条件。
除此之外,我们可以自定义自己的消息筛选器,在本系列的后面将会讲到。

筛选器工作原理

正如在前面所看到的,MessageFilter提供了所有筛选器的基类,筛选器中的Match方法用于确定消息是否满足筛选器的条件。如下面的代码片段中,我们定义两个ActionMessageFilter和EndpointAddressMessageFilter,然后创建一个Message,看看它们最终匹配的结果:
static void Main(string[] args)
{
    // 创建两个ActionMessageFilter实例
    ActionMessageFilter actionFilter1 = new ActionMessageFilter("Add", "Sub");
    ActionMessageFilter actionFilter2 = new ActionMessageFilter("Mul");
    // 创建两个EndpointAddressMessageFilter实例
    EndpointAddressMessageFilter addressFilter1 = new EndpointAddressMessageFilter
    (
        new EndpointAddress("http://localhost:8887/Calculator")
    );
    EndpointAddressMessageFilter addressFilter2 = new EndpointAddressMessageFilter
    (
        new EndpointAddress("http://www.cnblogs.com/terrylee")
    );
    // 创建一个Message,设置Action和To
    Message message = Message.CreateMessage(MessageVersion.Soap12WSAddressing10,
        "myBody");
    message.Headers.Action = "Add";
    message.Headers.To = new Uri("http://localhost:8887/Calculator");
    // 测试匹配结果
    bool actionResult1 = actionFilter1.Match(message);
    bool actionResult2 = actionFilter2.Match(message);
    bool addressResult1 = addressFilter1.Match(message);
    bool addressResult2 = addressFilter2.Match(message);
    // 输出结果
    Console.WriteLine("The result of filter:");
    Console.WriteLine(actionResult1);
    Console.WriteLine(actionResult2);
    Console.WriteLine(addressResult1);
    Console.WriteLine(addressResult2);
    Console.ReadLine();
}
输出结果如图2所示:
TerryLee_WCF_07  
图2
在该示例中,由于我们创建的Message对象,最终的SOAP消息包如下代码所示:
<s:Envelope xmlns:s="[url]http://www.w3.org/2003/05/soap-envelope[/url]"
            xmlns:a="[url]http://www.w3.org/2005/08/addressing[/url]">
  <s:Header>
    <a:To s:mustUnderstand="1">[url]http://localhost:8887/Calculator[/url]</a:To>
    <a:Action s:mustUnderstand="1">Add</a:Action>
  </s:Header>
  <s:Body>
  </s:Body>
</s:Envelope>
所以这里匹配上的是actionFilter1和addressFilter1。注意,一旦构造筛选器,筛选器使用的条件无法更改,因为筛选器表无法检测更改。修改筛选器的条件的唯一方法是构造一个新的筛选器,然后删除现有筛选器。

消息筛选器表

消息筛选器表用于存储键-值对,其中筛选器为键,而与筛选器关联的数据为值。筛选器数据可用于指示当消息与筛选器匹配时要采取的操作,筛选器数据的类型是筛选器表类的泛型参数。 筛选器数据可以包含路由规则、会话安全状态、通道上的侦听器等等。所有的消息筛选器都存储在实现了IMessageFilterTable<TFilterData>的表中,如MessageFilterTable<TFilterData>,在它的内部,又有很多个与具体筛选器类型相关的筛选器表,添加筛选器时,会将其放置在包含此类筛选器的内部筛选器表(如果已存在)中。如果不存在此筛选器表,则调用 CreateFilterTable 以分配一个适当类型的新筛选器表,如图3所示:
TerryLee_WCF_09  
图3
同时在添加筛选器时,筛选器表会给每个筛选器设置一个默认的优先级。

设置服务的消息筛选器

我们可以通过ServiceBehavior来指定服务所用的消息筛选器,在ServiceBehavior中有一个AddressFilterMode的属性,它用来指定调度程序用于将传入的消息路由到匹配的终结点,由三个选项:
Exact :指示对传入消息的地址执行精确匹配的筛选器,即使用EndpointAddressMessageFilter。
Prefix :指示对传入消息的地址执行最长前缀匹配的筛选器,即使用PrefixEndpointAddressMessageFilter。
Any :指示与传入消息的任意地址相匹配的筛选器,即使用MatchAllMessageFilter。
如下面的代码,指示使用PrefixEndpointAddressMessageFilter作为地址筛选器:
[ServiceBehavior(AddressFilterMode = AddressFilterMode.Prefix)]
public class CalculatorService : ICalculator
{
    public int Add(int x, int y)
    {
        return x + y;
    }
}
我们可以在Host端输出一下EndpointDispatcher所用的地址筛选器和契约筛选器,如下代码所示:
static void Main(string[] args)
{
    using (ServiceHost calculatorServiceHost =
        new ServiceHost(typeof(CalculatorService)))
    {
        calculatorServiceHost.Opened += delegate
        {
            Console.WriteLine("Service begin to listen via the Address:{0}",
                calculatorServiceHost.BaseAddresses[0].ToString());
        };
        calculatorServiceHost.Open();
        foreach (ChannelDispatcher channelDispatcher in
            calculatorServiceHost.ChannelDispatchers)
        {
            Console.WriteLine(channelDispatcher.BindingName);
            foreach (EndpointDispatcher endpointDispatcher in
                channelDispatcher.Endpoints)
            {
                Console.WriteLine(endpointDispatcher.AddressFilter.ToString());
                Console.WriteLine(endpointDispatcher.ContractFilter.ToString());
            }
            Console.WriteLine("---------------------------");
        }
        Console.Read();
    }
}
输出结果如图4所示:
TerryLee_WCF_08  
图4

结束语

本文详细介绍了WCF中的消息筛选器,这在某些场景下非常有用,可以根据SOAP消息标头中包含的数据将消息发送到不同的地方处理,这在一定程度上可以摆脱WCF的调度模型。WCF寻址相关文章:














本文转自lihuijun51CTO博客,原文链接:http://blog.51cto.com/terrylee/151933  ,如需转载请自行联系原作者
相关文章
|
Oracle 关系型数据库 API
C# LIS检验系统源码,接口技术:RESTful API + Http+WCF
LIS检验系统一种专门用于医院化验室的计算机系统,它致力于提高医院化验室的工作效率和检测准确率。LIS系统由多个子系统组成,包括样本管理系统、质控系统、检验结果管理系统、报告管理系统等。体系结构:Client/Server架构 SaaS模式 客户端:WPF+Windows Forms 服务端:C# +.Net 数据库:Oracle 接口技术:RESTful API + Http+WCF
118 2
|
C#
C#面向服务编程技术WCF从入门到实战演练
一、WCF课程介绍 1.1、Web Service会被WCF取代吗? 对于这个问题阿笨的回答是:两者在功能特性上却是有新旧之分,但是对于特定的系统,适合自己的就是最好的。不能哪一个技术框架和行业标准作比较,任何对于二者的比较都是错误的,因为两者根不不在同一个范畴里。
1405 0
|
安全 C#
WCF技术我们应该如何以正确的方式去学习掌握
一、WCF技术我该如何学习?       阿笨的回答是:作为初学者的我们,那么请跟着阿笨一起玩WCF吧,阿笨将带领大家如何以正确的姿势去掌握WCF技术。由于WCF技术知识点太多了,就纯基础概念性知识都可以单独出一本书来讲解,本次分享课程《C#面向服务编程技术WCF从入门到实战演练》开课之前,阿笨还是希望从没了解过WCF技术的童鞋们提前先了解一下WCF技术,至少要明白WCF技术的ABC三要素分别指的是什么。
1197 0
|
前端开发
WCF更新服务引用报错的原因之一
WCF更新服务引用报错的原因之一
|
C# 数据安全/隐私保护
c#如何创建WCF服务到发布(SqlServer版已经验证)
c#如何创建WCF服务到发布(SqlServer版已经验证)
78 0
|
安全 数据库连接 数据库
WCF服务创建到发布(SqlServer版)
在本示例开始之前,让我们先来了解一下什么是wcf? wcf有哪些特点? wcf是一个面向服务编程的综合分层架构。该架构的项层为服务模型层。 使用户用最少的时间和精力建立自己的软件产品和外界通信的模型。它使得开发者能够建立一个跨平台的安全、可信赖、事务性的解决方案。且能与已有系统兼容写作。 简单概括就是:一组数据通信的应用程序开发接口。
116 0