面向大规模数据集成消息中间件系统设计实现

在分布式网络环境中,构造基于消息通信中间件的数据传输系统,能有效地满足数据传输的可靠性、安全性和异步性等企业级需求.然而,随着企业经营规模的扩大,对数据传输系统提出了参与方多、交互数据量大等新的需求,现有的基于点对点(PTP)和发布/订阅(pub/Sub)通信模式的消息中间件难以很好的支持这些新的需求.根据大规模数据传输系统的新特点,结合 PTP 和 Pub/Sub 通信模式,提出了一种基于点对点的发布/订阅消息中间件通信模型(PBPS),并在消息中间件ISMQ基础上提供了实现.实际应用表明,该方法能够有效满足大规模数据传输的要求.     

基于发布／订阅通信的动态数据集成模型

提供灵活、动态、一致和开放的数据集成模型对于通过集成异构信息资源，实现大规模企业信息系统至巷尊要。本文以中介模型为基础，提出了一种基于发布／订阅通信的动态数据集成模型，与相关工作相比，该模型的显著特点在于通过发布／订阅机制支持信息资源的动态可插拔、支持分布的信息检索、提供了动态可配置框架、集成节点具有对等性。     

一种基于消息中间件的PKI系统应用集成方案

针对分布式环境下为大规模的证书用户提供及时、多样的证书服务所产生的对PKI系统中各实体的组织与管理等问题,提出一种PKI系统的应用集成方案.该方案以AMQP消息中间件作为集成方式,运用面向服务思想对各实体进行管理,采用异步的发布/订阅方式实现消息的传输,能够为PKI系统提供一个高效、稳定、且扩展性强的集成与通信平台.通过实验表明该应用集成方案能够在不对PKI系统性能造成较大的影响下,提高PKI系统在处理大规模证书服务时的整体性能.     

面向电子政务的发布订阅中间件设计与实现

目前紧耦合通信模式已经不能满足大规模电子政务应用发展的需求,迫切需要一种新的松耦合信息交互基础设施,而发布订阅中间件是解决该问题的有效技术。基于客户/网络体系结构,提出一种发布订阅中间件系统Xinfo,设计其总体框架和关键组成部分,给出面向代理网络的消息路由算法。实际部署测试结果表明,Xinfo系统能够解决大规模电子政务系统间的松耦合信息交互问题。     

飞行器测控系统数据分发服务研究

针对飞行器测控系统多任务和高实时性的要求,提出了一种基于DDS(数据分发服务)规范的数据分发服务模型.它以发布/订阅模型为基础,支持通过设置和调整服务参数,实现不同的数据需求和传输方式;同时在模型中引入了一种基于兴趣过滤的数据订阅方法,支持订阅者更细粒度地表达订阅兴趣,以提升通信效率.试验结果表明,该模型在任务和负载数量增加时仍具有较好的时延控制能力,可满足测控系统多任务、高实时性等任务需求,并具有良好的扩展性.     

基于发布/订阅技术的数据抽取

随着信息技术的发展和企业管理水平的提高,企业信息系统整合的需求越来越强烈.数据中心正是企业数据整合,建立科学决策的基础.在数据中心的建立过程中,数据抽取是必不可少的,最重要的环节.基于发布/订阅的抽取方法可以降低数据源和数据中心的耦合度,使系统具有较高灵活性、动态性,可以满足时时和大规模数据抽取的需要.     

支持发布订阅的Web服务应用集成框架

提出面向web服务的应用集成框架,该框架提供支持"发布/订阅"模式的web服务集成总线,探讨服务总线的设计与实现,并给出一个应用案例.     

基于主动数据库分布式SCADA设计与实现

传统模式无法满足SCADA系统对主动数据服务的要求,针对SCADA系统的数据实时性、准确性需求,结合主动数据库技术,提出了基于主动数据库的分布式SCADA系统结构.同时针对SCADA系统与其他异构系统之间的集成和数据交互问题,将基于发布/订阅的消息模式引入系统中,从而降低与其他系统之间的依赖性,增强系统的可扩展性,并给出了主动数据库模型和实时消防监测报警系统的具体应用实例.     

一种基于发布/订阅机制的数据集成方法

数据集成包括数据的抽取、转换、加载三个过程。针对当前大多数据集成工具适应性差、源数据端和目的数据端的耦合度太紧和数据不易自动更新的问题,基于发布/订阅机制的消息代理模式提出了一种新型的数据集成体系结构,把数据集成划分为源数据处理(抽取转换)和目的数据处理(过滤加载)两个过程,不仅实现了数据的可靠异步传输,而且降低了源数据端和目的数据端的耦合度,增加了数据集成的灵活性,并使数据的抽取转换和过滤加载独立、并行执行。实验结果也证明了提出的数据集成方法有效地提高了数据集成的效率。     

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

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