基于发布/订阅的消息队列在工作流引擎中的应用研究

不论在工作流基本模型中还是在工作流管理系统中,工作流引擎都起着非常重要的作用。对于工作流管理系统,工作流引擎是任务管理器,在不同的使用者和执行者之间传递消息,因此一个好的消息传递机制,能够有效地提高工作流引擎的工作效率,从而提高工作流系统的效率。本文提出一种基于发布/订阅的消息队列机制,对于提高工作流引擎消息传递的效率有很大帮助。     

发布/订阅系统中的原子订阅管理和匹配

如何有效地管理原子订阅并将事件与原子订阅高效地匹配,是发布/订阅系统需要关注的关键问题.首先将原子订阅组织成为一个覆盖森林,然后在这个结构上执行原子订阅的匹配,同时使用谓词的多级索引结构为原子订阅匹配提供支持.此方法已在基于内容的发布/订阅系统OncePubSub上实现.给出了用于验证算法性能和开销的实验.实验结果表明,上述方法具有良好的匹配性能和可伸缩性.     

基于CPN的发布/订阅系统的建模及分析

提出了一种基于着色Petri网(CPN)的pub/sub系统协议分析方法.基于一种结构化P2P网络上的pub/sub系统协议,用着色Petri网对事件发布的消息处理进行建模和描述,并利用CPN tools对模型进行模拟仿真,通过对模型的可达图进行分析,表明了协议具有活性、可达性和有界性,验证了协议的可用性.     

大规模动态发布/订阅系统中的重配置管理

重配置特性使得发布/订阅P/S(Publish/Subscribe)系统适应高度动态的环境,现有的P/S系统通常不能动态地改变既定的操作,适应影响事件代理框架的拓扑结构的变化。提出了一种大规模动态P/S系统中重配置管理的新途径——RS3DS(reconfigurable sparse 3dimensional space)模型。基于RS3DS中代理拆分和合并过程,分析了RS3DS中订阅表的重配置策略。结果表明RS3DS具有低的重配置开销和高的事件交付率。     

QoS中间件中实时发布/订阅服务集成评估

支持QoS的中间件技术在构造分布式实时嵌入式系统中得到了广泛应用,已成为支持实时发布/订阅服务的关键技术.评估并分析了QoS中间件中3种集成实时发布/订阅服务方法.重点研究了容器管理方式的性能,并与面向对象的实时发布/订阅服务比较.研究结果表明,容器管理方式中,CIAO中间件的等待时间稍长,有可预测性,适用于DRE系统.     

基于XML和发布/订阅机制的主动服务系统

主动服务可以将"适合"的信息在"适当"的时间以"适当"的方式传递到"适当"的人手里,从而提高管理决策的准确性和及时性,目前的主动服务系统多为发布/订阅型.结合XML和发布/订阅模型提出一个主动服务系统框架,并对其中的消息格式和消息代理进行了详细设计.     

基于事件发布/订阅模式的协同感知框架

针对协同系统中感知问题.设计并实现了一个基于事件发布,订阅感知模式的协同感知框架.框架进一步规范了协同感知行为,增强了时感知行为的定义和控制,可为研制协同应用系统和扩展已有协同系统的感知功能提供帮助.框架设计的思想在对一个协同编辑系统的进行感知功能扩展应用中得到了验证.     

云发布/订阅服务中的订阅持久化机制

发布/订阅服务让用户提交订阅来表达其所关心的事件,并能在检测到这些事件发生时,及时发送事件通知给感兴趣的用户。依托云平台构建的发布/订阅服务旨在提高其吞吐量和可伸缩性,特别是提高在面对大规模订阅/事件时的事件检测性能。为了保证订阅的可用性,并加快负载均衡的速度,为云上的发布/订阅服务设计、实现了订阅的持久化机制。为了评估订阅持久化机制,进行了一系列对比实验,实验数据表明订阅持久化机制能加快负载转移,从而加快代理达到负载均衡。     

发布/订阅模式测控消息中间件系统设计

针对传统基于消息队列或共享内存模式的测控(TT&C)消息中间件(MOM)紧耦合、可扩展能力有限的问题,结合目前测控计算机系统信息交换特点,提出了功能分布式结构的发布/订阅(Pub/Sub)模式测控消息中间件系统。取消了集中的发布/订阅服务器,将其功能嵌入到功能分布的处理机单元中,设计了主题全局注册、订阅全局广播和事件本地过滤的工作模式;并通过可靠多播协议实现其传输可靠性,通过软双工模式下的虚拟IP机制和加速推拉心跳检测机制实现其节点可靠性。实验表明此测控消息中间件系统的发布/订阅平均响应时间控制在100 ms之内,多播协议丢包率控制在0.86×10^-7左右,双工切换延时达到56 ms,满足测控应用的强实时性和高可靠性要求。     

用PTA模型形式化分析基于Gossip 协议的发布/订阅系统

在研究传统的发布／订阅消息中间件系统的基础之上,结合Gossip协议的特点来研究发布／订阅消息中间件,最后运用形式化方法,通过PRISM仿真工具,对仿真的模型进行形式化分析．实验结果表明,发布／订阅消息中间件系统的实时性受消息产生速度的影响,在各个订阅者订阅相同消息和不同消息两种情况之下网络特性展现不同的变化,但最终都是随着消息产生速度的增加而减小．可靠性随着消息产生速度的增加而减小,并且订阅者的接收缓存越大可靠性越高,但增幅率会越来越小．该实验模型和实验方法对于发布／订阅消息中间件系统的研究,以及在现实环境中配置系统的相关参数有一定的帮助．     

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

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

使用发布订阅中间件支持移动计算

提出了一个扩展发布订阅中间件以支持移动计算的新协议．该协议针对移动计算的需求，由老的事件代理暂存客户移动期间到达的消息，客户在连接到新的事件代理后，消息被自动有序发送给客户，保证了移动透明性．此外协议采用同步算法和消息合并操作防止了消息丢失和重复．移动客户可以在不同的地域与不同的事件代理节点连接和可靠接收消息．实验表明谈协议完全满足移动应用的要求，保证了应用的透明性、消息完整性和有序性．     

基于发布/订阅的推模式服务调用

针对面向服务结构中传统服务调用带来的不必要的网络负载、较长的响应时间和服务提供端的瓶颈问题,结合发布／订阅模型提出一种推模式服务调用方法,并将其与传统的拉模式相比较,通过分析和实验表明该方法在通信量、响应时间等方面具有较强的优势．     

发布订阅系统中的隐私保护研究综述

发布订阅系统因其去耦合和异步的特性被广泛用于大规模的信息传输系统中,然而随着云计算和大数据的飞速发展,发布订阅系统的应用环境已经从封闭的可信计算环境转变为开放的不可信计算环境,隐私保护问题开始凸显.因此,总结目前发布订阅系统在隐私保护方面取得的研究成果、存在的问题以及可能的研究趋势具有重要意义.本文首先介绍了发布订阅系统模型,发布订阅系统中的隐私性定义,威胁模型等.然后介绍了发布订阅系统中实现机密性保护和匿名性保护的研究现状与进展.接着根据发布订阅系统隐私保护技术方法存在的不足展望了未来的研究方向,最后给出了本文的总结.     

内容发布订阅系统中事件可靠传递的研究

本文提出了一个两层的可靠性模型：可靠P／S协议层（RPsL）和可靠流传输层（RSTL）。RPSL理解发布／订阅的消息格式,提供尽力传递、事件丢失检测与恢复、有确认传递等多种可靠;PSTL不理解发布／订阅的消息格式,通过链路速率自适应、断点续传等机制保证事件传递的可靠。     

基于本体的发布/订阅系统的数据模型和匹配算法

现有的发布/订阅系统不能根据事件的语义来进行事件与订阅的匹配,且不能支持具有复杂结构(如图状结构)的事件.将语义Web技术引入发布/订阅系统中,提出一种基于本体的发布/订阅系统.该系统采用本体来表示事件的概念模型,采用RDF图来表示事件,采用图模式来表示订阅条件.它能较好地解决现有的发布/订阅系统的上述问题.实验结果表明,该系统具有较高的订阅匹配效率.     

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

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

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

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

内容发布订阅中非精确的事件转发算法

基于Bloom Filter技术提出了一种非精确事件转发算法——FBBF算法,该算法以增加事件消息大小和网络通信开销为代价,提高了中间代理转发事件消息时的速度。FBBF算法的时间开销与系统的订阅规模无关,具有较好的扩展性,可以高效地应用于大规模的发布订阅系统。     

基于DDS的发布/订阅中间件设计

基于OMG组织颁布的实时系统中数据分发服务最新标准设计了一个新的发布/订阅中间件,实现了分布式环境中以数据为中心的数据实时传输,解决了分布式实时系统中服务质量约束和单点失效等问题。提出一种全局数据空间管理策略,解决了通信节点动态增删问题。该模型与CORBA规范和其他发布/订阅模型相比,具有较好的灵活性、实时性、可扩展性和可靠性。