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

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

一种采用分簇的无线传感器网络中间件

无线传感器网络(WSN)已经开发应用于多种领域,然而WSN应用编程仍是一项困难且容易出错的工作.为了便于应用开发和提供通用服务,提出一种适应WSN特点的中间件TinyWare,它使用发布/订阅的方式实现异步通信,根据用户订阅的主题监测环境,并在事件产生后主动发布消息;采用基于分簇机制的消息通信模型,簇内节点根据不同角色和策略对数据进行网络内处理.TinyWare降低能量消耗,提高系统的自适应能力,可扩展性和鲁棒性.为了验证这一中间件,本文实现了一个环境监测应用实例.     

基于发布/订阅机制的Web服务QoS信息分发模型

QoS感知的Web服务管理和组合的基本问题是如何及时有效地获取Web服务的QOS信息.当前的研究包括基于查询或监视的方法.然而在动态的服务计算环境下,这些方法或多或少存在时效慢、代价高和可扩展性差等问题.提出一个基于发布/订阅机制的Web服务QoS信息分发模型,目标是提供一个在大规模的服务计算环境下可靠、及时地获得Web服务QOS信息的方法.提出一个基于P2P的内容发布/订阅网络,利用专用的集合点和副本机制减少订阅丢失,改善可靠性.利用RP链加快订阅和QoS信息发布.通过支持组合服务的组合QoS订阅,减少通知消息数量,减轻网络负载.仿真实验验证了系统的低成本、有效性和可扩展性.     

基于B+树的发布/订阅并行匹配算法

现有的消息匹配算法不能很好地满足大规模分布式发布/订阅系统中海量数据的有效分发。为此,提出一种高效的发布/订阅并行匹配算法。采用B+树的存储结构,订阅消息按属性-值进行空间划分,建立多级索引订阅属性树,消息匹配采用改进的B+树查询方法,结合计数的思想实现快速消息匹配。实验结果表明,该算法在大规模分布式发布/订阅系统中,消息匹配时间短,订阅匹配树生成迅速,匹配效果更好。     

基于AMQP消息中间件的主动状态证书撤销机制实现

主动状态证书撤销机制是一种新的证书撤销验证机制,如何实现该机制还未见具体的案例。在分析高级消息队列协议(AMQP)的基础上,结合主动状态证书的订阅/发布要求,设计了一种基于AMQP消息中间件的主动状态证书发布与订阅模型。通过实验分析表明,该消息中间件系统应用灵活,系统性能高效、稳定。     

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

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

支持移动客户应用的分布式订阅／通知框架

订阅/通知框架是分布式系统中连接数据源和客户应用的一种常用框架.为了支持客户应用在不同的网络连接节点之间的迁移,实现客户应用移动的透明性,本文对通用的消息发布/订阅/通知框架进行了扩展,在客户应用移动时,自动引发通知订阅消息的重新发送、通过系统产生的Fetch消息的传递和Replay消息的传递,重构移动客户应用通知消息的传递路径,实现系统缓冲消息按照正确时间顺序重新发送给客户应用.同时该框架支持移动客户应用从多个数据源处订阅消息,具有良好的系统可适应性.     

基于Hermes系统的分布式JAVA消息服务系统的研究与设计

Java消息服务(JMS)适合于Internet环境下松耦合的分布式计算.现有的集中式的JMS实现容易出现消息代理的单点失败和过载.分布式的发布/订阅系统提供的接口与JMS的接口不兼容,导致企业应用难以从集中式服务向分布式服务迁移.本文提出基于Hermes的分布式JMS系统模型,在Hermes上创建分布式的消息代理服务,并保留了JMS接口.     

发布/订阅通信模式的实时性能分析与评估

运用成熟的队列理论知识,通过PRISM模型验证工具,对发布/订阅模式的实时性能进行形式化分析。实验结果表明,发布/订阅模式在消息响应时间及消息传输可靠性两方面比传统的通信模式表现出更良好的性能,该实验模型和实验方法对于优化发布/订阅模式及调整实际发布/订阅系统中的参数配置都有一定的帮助。     

基于JMS体系结构的消息服务技术的应用研究

根据企业应用程序间进行消息服务的实际需要，深入研究Java消息服务(Java Message Service，JMS)技术，结合其中的“发布／订阅式”和“点对点式”两种消息收发模式，提出了一个基于JMS体系结构的全新的消息服务模型，并针对股票交易系统中的报价“发布／订阅”服务功能的具体实现进行了详细的论述。     

新型配电主站系统消息总线性能分析与测试

消息总线服务为配电主站系统的各个模块提供基于 topic 的消息订阅和发布, 其主体服务采用的是开源软件kafka。针对消息总线的性能,分析了大数据容量、数据处理速率等主要性能指标。设计了一个海量数据处理及速率统计的测试框架,该框架主要采用 Qt/C++ 实现。实际应用证明,该测试框架简单、易操作,很大程度上提高了测试效率。     

基于P2P技术的遥感数据分发策略研究

针对遥感数据分发过程中存在的按需分发难度大、分发自动化程度低、分发速度慢等问题,提出了发布/订阅技术与P2P技术相结合、数据主动推送和数据被动拉取分步进行的分发策略.首先通过订阅分发的方式对用户的需求进行划分,然后针对单个遥感数据较大的问题,对遥感数据进行BT编码,最后主动推送编码数据,利用多个用户(BT客户端)之间的数据共享完成数据的高效快速分发.实验表明,该策略很好地解决了遥感数据分发中存在的问题.     

CORBA通知服务的特性探讨

在揭示CORBA事件服务局限性的基础上，重点剖析通知服务所实现的新特性，包括事件过滤、服务质量、发布与订阅机制等，并比较了CORBA通知服务与消息中间件的异同，同时指出使用通知服务的方法。     

在HLA／DDM中多播组的分配方法

DDM是HLA接口规范中定义的六大服务之一,它允许邦员声明其在路由空间中的分布区域和定购区域,从而达到减少HLA邦员间数据交换量的目的。具体实现方法是数据过滤,其核心问题是如何将邦员中具有相似的公布区域或定购区域的对象聚集到一个多播组中。解决这个问题的传统方法是基于固定网络的方法,但该法存在一定缺陷。本文提出了
三种新的可选方法,并对这些方法的过滤效果和计算开销进行了评估。     

基于移动Agent和主动网络的服务组合与定制

在面向服务的架构中，为了实现根据用户需求，利用已有的服务构件组装新的服务，提出了基于主动网络和移动代理技术的服务定制模型，该模型将定制服务所需的基本服务封装成主动服务包（称为Service Agent，SA），通过SA的不同组合生成用户所需要的服务，并对服务定制过程中涉及的服务描述、服务发布、服务发现与选择、服务组合与定制等关键技术进行了研究，解决了传统网络不能实现服务定制的问题。     

基于内容的订阅方法及其在MQSeries中的实现

介绍了消息中间件中的发布/订阅模式及其优点，分析了传统的基于主题的订阅方法的局限性，通过引入XMI技术总结出在消息中间件中实现基于内容的订阅的方法。并结合消息中间件的代表产品之一IBMMQScrles，阐述了该方法的具体实现。     

内容发布订阅系统的订阅重构算法研究

在内容发布/订阅系统中,针对传统订阅重构算法存在订阅冲突等问题,提出一种适应移动Ad Hoc网络特点的事件重构算法。该算法扩展了订阅转发方法,将订阅重构消息转发范围限制在重构路径上,有效避免了订阅冲突,提高重构效率。实验结果表明,该算法缩短了订阅重构时间,且性能受网络规模影响较小。     

基于信息门户的短信平台的方案选择

为了提升管理水平和日常工作效率,许多部门都建立了信息门户进行内部管理和信息发布.本文对实现短信平台的四种方案进行比较,从而选择适合基于信息门户的短信平台方案,探讨了实现部门级的短信沟通管理的方法.