内容发布订阅服务网络中的路由策略

发布/订阅系统为分布式网络中系统间的异步通讯提供了便捷的途径,事件的路由策略是基于内容发布/订阅系统的关键问题之一。文章提出了应用于内容发布/订阅服务网络中的改良后的层次形拓扑结构及先合后分的路由策略,提高了基于内容发布/订阅系统的可扩展性和传输效率。     

可配置可扩展发布订阅系统的研究及其实现

分析了当前发布订阅系统的主要类型和存在的问题.基于发布订阅系统的主要设计模型,采用分层与插件相结合的动态体系结构设计方法,设计和实现了可配置和可扩展的发布订阅系统ACT-PS(ACT-Publish/Subscribe System),支持基于应用需求的配置和扩展.在具体的电子政务数据交换系统当中的配置运行表明,ACT-PS系统为通过可配置和可扩展的方式建立发布订阅系统提供了新的途径.     

支持语义等价的自动化订阅分解方法

传统的发布/订阅系统不能自动完成原子订阅到语义等价的复合订阅转换,降低了系统的可用性和订阅匹配能力。针对该问题,提出支持语义等价的自动化订阅分解模型,给出相应的基于XChangeEQ的订阅分解算法,将原子订阅分解成语义上等价的复合订阅。应用案例表明,该算法可为订阅者提供基于复合事件的订阅结果,提高了原发布/订阅系统的可用性和表达能力。     

内容发布订阅系统的组播路由

基于内容的发布订阅系统多数采用泛洪和匹配优先的路由算法。本文提出了基于事件空间划分的发布订阅系统的实现方法,采用组播的方式实现了目标代理到多个订阅者之间的通知路由算法。与采用贪婪路由思想的单播路由算法相比较,该算法提高了在通知路由阶段的发布订阅系统的路由效率。算法对解决基于内容的发布订阅系统中相关的路由问题具有重要的作用和意义。最后给出了算法的仿真实验。     

发布/订阅系统及其在分布虚拟环境中的应用

文章首先通过讨论发布/订阅系统和分布式虚拟环境各自的特点,提出在开发分布式虚拟环境时引入发布/订阅系统。结合分布式虚拟环境的要求设计了一个发布/订阅系统。详细描述了系统的原理和基本结构,及主要实现机制。实现了一个基于双层服务器结构的分布式虚拟开发环境。简单介绍了各层服务器的功能。通过引入共享组使各节点属性可以清晰地结构存储在服务器上。并论述了将订阅/发布系统应用在分布式虚拟开发环境NSVRT中的具体方案。结果表明该系统在NSVRT的应用,简化了开发分布式虚拟环境的工作,同时满足了分布式虚拟环境开发的实时性要求,最后提出今后的工作重点。     

基于内容的发布订阅系统综述

随着信息技术的不断发展,针对如何能够实现发布/订阅系统(Pubish/Subscribe系统)最大限度的应用,是我们当前应对的一个重要挑战。结合发布/订阅自身(异步、多点通信等)的特点,首先概述了发布/订阅系统的概念及分类,提出了当前的研究热点即基于内容的发布/订阅系统,并总结了发布/订阅系统当前国内外的研究现状,最后指出要想提高发布订阅系统的匹配速度必须完善现有的匹配算法。     

基于MapReduce的语义发布/订阅系统

为了提高已有的语义发布/订阅系统中事件与订阅匹配的时间效率,提出了基于MapReduce[1]的语义发布/订阅系统[2]。对语义发布/订阅系统的处理流程进行了认知与分解,指出订阅与事件的匹配时间效率是系统必须要解决的问题,在语义发布/订阅模型的基础上设计了新的匹配模块。对过去已完成的匹配方案进行了分解,采用基于MapReduce的并行处理技术[3]对事件与订阅的匹配进行并行处理,从而提高系统的时间效率。该系统通过加入多台具有相同处理能力的处理机,搭建了一个能够并行处理的运行环境,验证了该系统的准确性和有效性。     

基于主题模型的位置感知订阅发布系统

随着移动互联网的迅速发展和智能手机的普及,基于位置感知的订阅发布系统在工业界和学术界引起了广泛重视。现有系统主要处理海量空间数据下订阅与事件的查询匹配问题,其匹配模型主要是基于空间关键字之间的相似性,鲜有研究考虑语义相关性。为了探索并实现订阅发布系统在语义上的查询与匹配,提出了一种基于主题模型的位置感知订阅发布系统。 首先, 该系统利用主题模型对订阅发布系统中的关键字进行主题映射。然后,设计了一种两步分区索引结构RPTM-trees,并使用该索引结构为订阅的主题集合和空间信息建立索引。RPTM-trees根据主题集合的主题个数及关键主题对订阅进行两步分区索引,使其对订阅的分区能力更强,从而显著提升查询匹配的效率。最后,在高流速的事件流、千万级订阅数据集上进行了实验,实验结果表明所提方案是稳定和高效的。     

基于主题的DDS系统的扩展性设计与实现

基于主题的发布订阅系统存在着表达能力较弱的缺点,订阅者没有办法很好的描述自己对于订阅事件的要求,从而降低了订阅者接收数据的有效性,浪费了系统资源,同时也影响了用户体验.本文提出了一种对基于主题的发布订阅系统(DataDistribution Service,DDS)进行扩展的方法,使其具有一定的基于内容的发布订阅能力.文章在详细分析现有系统问题的基础上,提出采用增加关键字描述的方式来使得订阅者能够更细粒度的描述自己的订阅要求的方法,并分析其可行性.进行整体设计,以尽可能保留原系统优点及体系结构为前提,修改其匹配算法,最终实现了对原系统的扩展,完成了基于内容的发布订阅功能,提升了用户体验.     

基于发布订阅模式的数据集成中间件系统设计实现

随着企业信息化的发展,对数据集成系统提出了大规模、动态改变和按需集成数据的需求.针对该应用需求,本文借鉴发布/订阅技术的思想,提出了一种基于发布/订阅的数据集成框架,并设计和实现了基于发布/订阅的数据集成系统.该系统由两部分构成:具有发布订阅功能的数据集成服务器和代理服务器.该方案提供了一种松散耦合的柔性化集成方式,系统应用表明它能适用于大规模的数据集成.     

对数据发布服务标准基本要素的研究

为了更好地解决以数据交换为目的的分布实时系统"在正确的时间、正确的位置获取正确的数据"的需求,OMG组织于2004年12月发布了国际上第一个基于发布-订阅模型的、以数据为中心的实时系统数据发布服务标准DDS(Data Distribution Service).对DDS标准进行深入研究,分离创建服务的基本要素,详细剖析DDS的基本通信模型--发布-订阅模型,讨论基于该模型的两种数据交互方式,最后分别阐述标准定义的各实体的角色、功能以及它们之间的联系.     

使用Gossip算法实现可靠的基于内容的发布订阅系统

分布式基于内容的发布订阅系统正受到日益广泛的重视，然而大多数研究都忽略了可靠性保证，这限制了该系统在动态和不可靠场合下的应用．本文首先介绍了基于内容的发布订阅系统和gossip算法，然后提出了一个轻量级的称为PReliability的协议，它通过引入gossip算法保证事件传输的可靠性．仿真实验表明该协议适合于大规模、可靠性低的环境，具有很强的扩展性和健壮性，并且具有简单、易于实现的优势．     

面向服务的数据分发机制的研究与实现

在分布式环境中,分布式节点间存在多种形式的数据交换,为了实现数据的灵活可靠交换,需要一种通用的通讯机制作为数据交换应用的基础设施。同时,对象管理组织提出的数据分发服务(DDS)框架,其核心是以数据为中心的发布/订阅模式,能很好地解决分布式环境中的数据交换和分发问题。本文首先介绍数据分发服务的相关理论及其优点;然后介绍一种支持多数据包及文件传输的通讯机制作为上层应用的基础设施和该通讯机制的服务调度机制;最后依据DDS框架,结合以服务为中心、以交易码驱动的架构,设计并实现一种以数据为中心的发布/订阅模式。     

EScribe:一种动态路由的Topic发布订阅系统

Scribe是一种经典的基于Topic的发布订阅系统,它通过分布式组播树将Event分发给订阅者.Scribe需要定期维护组播树,因此造成了大量冗余的Event传递和高昂的维护代价.提出一种基于Scribe的增强型Topic发布订阅系统,简称EScribe.EScribe利用布隆过滤器存储Pastry叶子节点的订阅信息,动态地调整下一跳路由.节点维护子树的间隔时间随着节点在组播树中的层次增大而加长.实验结果表明,EScribe大幅减小了冗余Event传递的数量和组播树规模,也明显减小了Event分发和组播树维护的代价.     

Disseminating information to mobile clients using publish-subscribe

Providing an up-to-date view on dynamically changing data presents difficulties. While several different data-dissemination platforms address the problem, client mobility is still a major challenge. Volatile wireless connections and resource limitations void the attempt to apply the same mechanisms that work in fixed-wired networks. The Rebeca publish-subscribe middleware implementation introduces several concepts for accommodating client mobility in publish-subscribe systems. We present experimental results that show how intelligent filtering mechanisms can save network bandwidth inside the infrastructure and at mobile clients while preserving the accuracy of client notifications.     

大规模发布／订阅系统中的服务质量

发布/订阅系统已经获得广泛的关注,但在该领域仍然缺少意义明确的度量准则.全面地提出了相关的服务质量度量及其在发布/订阅系统中的语义,通过扩展系统操作,给出了带QoS约束条件的路由算法的一般准则,为进一步研究发布/订阅系统提供了坚实的基础.     

一种大规模网络上的服务组合流程搜索方法

集中式的自动服务组合和非平凡服务发现能够根据给定的、具有特定输入输出的请求搜索出一系列满足要求的服务组合,是当前服务计算领域的研究热点.针对集中式结构带来的性能瓶颈和单点故障问题,提出了一种利用基于内容的分布式发布订阅技术实现大规模网络环境下的无中心自动服务组合方法,称之为流程搜索.基于内容的分布式发布订阅系统能够根据发布消息和订阅消息之间的内容匹配关系,将发布者提供的消息通过一系列中介节点转发给感兴趣的订阅者. 它可以为服务接口之间的可互操作性判定以及查询路由提供支持.将服务模型映射为发布订阅的消息模型,并利用基于内容的路由设计形成分布式环境下的搜索算法,并基于PADRES系统开发了一个PreSee原型系统.模拟实验显示,无中心控制的方法相对于集中式的架构而言,可以有效降低系统延迟,提高整个系统的效率.     

Ad Hoc网络下的发布/订阅系统路由协议

发布/订阅系统为分布式网络中系统间的异步通讯提供了便捷的途径,事件的路由策略是基于内容的发布/订阅系统的关键问题之一。文章采用目的地动态更新与划分、逆向最短路径转发等策略,提出一种有环图下支持订阅覆盖的路由算法;通过引入订阅挂起、激活操作,以及与订阅对应的事件缓存方法,设计了一种新型的拓扑重构算法;通过引入网络分簇技术、拓扑重构算法、客户路由切换算法,设计了一种新型的面向移动Ad Hoc网络的发布/订阅系统路由协议,提高了系统的扩展性。