面向内容发布订阅系统的向量订阅与共享机制

在分析典型索引结构和树型结构匹配算法变更特性、匹配效率的基础上,以匹配效率高的匹配树算法为基础,扩展其订阅结构为向量结构,提出了向量变更算法。基于向量间的关联关系,提出了向量共享算法,从而有效降低订阅变更对匹配树重构的影响,提高了订阅处理效率。理论分析和实验表明,与已有订阅变更方式相比,该方法能够在满足频繁订阅变更的同时提供高效的事件匹配,满足相关应用的要求。

面向内容发布订阅系统的混合事件匹配算法

当前的事件匹配算法不能在高效匹配的同时满足频繁订阅变更的要求.在结合已有谓词索引算法和覆盖网络算法的基础上,融合谓词索引结构的易变更和覆盖网络的高效匹配特点,提出一种混合的事件匹配算法.算法将部分订阅覆盖关系从覆盖网络中剥离,以同谓偏序的形式引入到谓词索引结构中去,达到高效匹配的同时保留了谓词索引的易变更结构.实验表明,与同类算法相比该算法能够在频繁订阅情况下提供高效的匹配,从而满足相关应用的需求.

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

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

内容发布订阅中支持订阅覆盖的事件丢失检测和恢复算法研究

基于内容的“发布／订阅”系统通过考虑订阅问的覆盖关系，使得某些订阅不需要转发给所有代理，从而可以减少中间代理的路由表大小，但是由于链路失效、拓扑重配置等原因，某些订阅者可能收不到事件消息，已有事件丢失检测算法都假设每个订阅必须转发给了所有代理，无法支持订阅覆盖的路由，本文提出了一种支持订阅覆盖的概率事件丢失检测和恢复算法，并通过模拟验证了该算法的有效性．

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

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

内容"发布/订阅"中支持订阅覆盖的事件丢失检测机制与恢复算法研究

基于内容的"发布/订阅"为应用提供了松耦合通信能力,得到了广泛应用,但是分布式"发布/订阅"系统通常不提供应用需要的可靠性保证,某些节点可能因为链路失效、拓扑重配置等原因而收不到其它节点发布的事件消息,已有研究成果假设所有的订阅都转发给了所有代理,没有考虑订阅只需转发给部分代理的情况(如支持订阅覆盖).提出一种支持订阅覆盖的概率事件丢失检测机制和事件恢复算法,并通过模拟来验证了该算法的有效性.

基于内容的发布订阅中支持订阅者移动的事件迁移算法研究

对使用持久订阅的订阅者发生漫游后需要进行事件迁移的问题,分析了已有研究提出的同步算法的有效性,以及迁移算法对路由算法的依赖,提出了两种改进方法:预转移与预恢复.预转移方法通过提前将事件转发到新代理来提高事件恢复的速度.预恢复方法通过利用事件迁移算法的同步过程来从新代理和其邻居代理上恢复需要迁移的事件.

基于MQTT的物联网系统消息发布/订阅方法研究

针对MQTT协议在物联网系统发布/订阅方法中会造成很多无用消息的推送,增加服务器的负载和通信带宽的问题,结合基于内容的发布订阅中根据事件内容来指定订阅条件的思想,将基于内容进行发布的消息给予特定的主题,将基于内容的订阅作为约束条件,而订阅方去订阅约束条件所对应主题的消息。消息过滤器接收到发布方消息后通过约束条件进行消息过滤,过滤后的消息根据其对应的主题进行消息发布。订阅方可以根据自己的需求表达订阅信息,避免无用消息的推送,使通信更加灵活高效。

大规模事件数据处理的覆盖检测优化算法

内容发布?订阅系统是一种在时间、空间和控制流上完全解耦的分布式事件系统,能够依赖消息的内容来进行事件匹配和路由,支持大规模事件数据的高效处理和分发.在基于内容的路由中,覆盖优化是一种典型的路由优化算法,它有效地避免网络中冗余的订阅,减少路由表存储、网络通信和事件匹配开销.然而,即使对于中等大小的负载,其中核心的覆盖关系检测算法都可能非常耗时并对优化后系统的效率产生负面影响.针对大数据环境下大规模订阅带来的对检测效率的挑战,提出了一种新的、基于匹配树的高效覆盖关系检测算法.实验显示,提出的方法显著地提高了订阅关系检测和维护的效率.