基于P2P和XML内容的发布订阅系统

介绍了一种面向大规模分布式应用的发布订阅中间件系统,系统采用一种结合了下推树和自下而上树自动机的XPath订阅快速匹配算法,支持XPath多谓词和分支特性。系统事件代理P2P网络节点之间的事件或订阅消息路由采用了扩展的Chord路由协议和订阅聚合、覆盖等多种优化措施。实验结果表明,系统具有较好的效率和性能,能满足面向大规模分布式应用的要求。     

Subscriber mobility management for a P2P publish/subscribe overlay in mobile tactical networks

P2P (Peer-to-Peer) overlay is a promising distributed computing and communication paradigm that allows for a group of participants to share information and coordinate their resources. Dissemination of information among end users can also be greatly facilitated by the publish/subscribe model. In this paper, we employ the publish/subscribe model in a P2P mobile tactical networking environment. Considering the particular requirements for mobile tactical networks, we investigate the problem of subscriber mobility management and propose a novel proactive handoff approach for improved system responsiveness and reliability. A comprehensive performance evaluation of the proposed mechanism is presented. The obtained results demonstrate significant performance benefits of the proposed scheme.

基于P2P网络的语义发布/订阅系统路由算法研究

在结构化P2P网络基础上构建语义发布/订阅系统是近年来的研究热点。提出一种基于Chord的语义事件路由算法,算法采用基于集结点的路由策略,首先使用保留语义的哈希函数将订阅映射至事件代理集结点;其次根据订阅与事件之间的语义信息,仅发布事件至可能匹配的订阅集结点,采用Chord路由协议构建的订阅生成树分发通知消息;最后过载的集结点通过订阅迁移实现系统负载均衡。仿真实验表明,算法在一定程度上减少了资源消耗,提高了路由效率,达到了负载均衡。     

A scalable publish/subscribe system for large mobile ad hoc networks

Since nodes that compose mobile ad hoc networks (MANETs) does not have any prior knowledge about other nodes in many cases, the publish/subscribe communication paradigm that has the decoupling and asynchrony properties can be useful to share information between nodes. Existing publish/subscribe services for MANETs can be categorized into document flooding (DF), destination-based routing (DBR), and content-based routing (CBR). Although those approaches may work well when the size of network is small, all of them suffer from the performance decline as the size of the network increases. In this paper, we compare those approaches, and then propose a scalable publish/subscribe communication scheme in large MANETs by combining DF and CBR hierarchically. Our approach is to cluster all nodes in networks and to exploit CBR and DF for the intra- and inter-cluster communication, respectively. By using this approach, we can effectively utilize benefits of both approaches. Then, we present performance evaluation results which validate our idea with respect to system performance and scalability.     

Mires: a publish/subscribe middleware for sensor networks

A wireless sensor network (WSN) consists of a large number of small devices with computational power, wireless communication and sensing capability. These networks have been developed for a wide range of applications, such as habitat monitoring, object tracking, precision agriculture, building monitoring and military systems. Meanwhile, middleware systems have also been proposed in to facilitate both the development of these applications and provide common application services. The development of middleware for sensor networks, however, places new challenges on middleware developers due to the low availability of resources and processing capacity of the sensor nodes. In this context, this paper presents the design and implementation of a middleware for WSN named Mires. Mires incorporates characteristics of message-oriented middleware by allowing applications communicate in a publish/subscribe way. In order to illustrate the proposed middleware, we have also developed an environment-monitoring application and a data aggregation service.

主动发布订阅分组拓扑和自配置策略

为了提高主动发布/订阅系统中网络节点间的数据传输性能,加强系统的稳定性,针对主动发布/订阅系统的特性,提出了基于事件代理分组的拓扑模型。该方法的主要思路是采用多级分组的方法,先根据发布事件主题的匹配度,将属于同一匹配阀值区间的节点分为同一组;组内节点再根据事件属性的相似性利用聚类算法划分为不同子组。该自配置策略实现了动态分组的创建,代理节点加入和退出的管理。仿真实验表明,分组拓扑模型能有效减少节点间的平均转发次数及系统的拓扑维护开销,提高系统健壮性。     

发布订阅系统在移动Ad Hoc网络中的三种路由算法

介绍了分布式发布/订阅系统的原型，为Ad Hoc网络中的发布/订阅系统设计了三种基于内容的路由算法，分别说明了它们的运行方式，并进行了仿真与比较。结果表明：基于内容的可靠容错路由算法能够100%保证信息的传输，有容错机制，可靠性较强，但出现了传输延迟；基于内容的路由算法的可靠性不强，适合有线网络中分布式发布订阅系统的信息传输，传输延迟小；基于内容的容错路由算法有容错机制，传输延迟小     

Push selling—Multicast messages to wireless devices based on the publish/subscribe model

Push technology automates the information delivery process by not requiring users to request for the information they need. Wireless has experienced explosive growth in recent years, and “push” will be the predominant wireless service delivery paradigm of the future. A wide variety of services, alerts and messages, such as promotional content, will be delivered to consumers’ phones or PDA. However, to push information to a wireless device can be a challenge because of the problem of intermittent communication links and resource constraints on wireless devices as well as limited bandwidth. This paper explores an efficient multicasting mechanism that “pushes” pre-specified information to groups of wireless devices. The mechanism operates with limited bandwidth and also overcomes the connectivity problem. Based on the above concept, we have designed and implemented a system to multicast sales information via wireless technology. The system is message-oriented and JMS compliant.     

基于内容的发布订阅系统的一种快速匹配算法

目前基于内容的发布/订阅系统得到了广泛的应用,而事件和订阅的匹配算法是其中的一个关键问题。提出了一种高效的匹配算法,首先根据谓词类型和名称的不同建立若干订阅树,建立一个索引结构管理这些树。匹配时,根据事件的类型和名称在对应的树中进行搜索。实验证明该算法具有较好的匹配性能。     

基于内容的发布/订阅系统的元数据索引和过滤

面向元数据流,提出有效评测用户订阅的方法.设计了索引结构对订阅进行分组索引,消除了一个订阅因为包含多个谓词而造成的多次索引、计数和比较;设计了新的基于分组的过滤算法,该算法通过缓存谓词匹配结果使得谓词匹配结果得以在订阅过滤过程中传播,取得了很高的过滤性能.实验结果表明,该系统可以有效地处理达上百万订阅的负载量,实验中引进提取词干和消除停用词,极大提高系统的查全率和精度.     

A mobile crowd sensing ecosystem enabled by CUPUS: Cloud-based publish/subscribe middleware for the Internet of Things

Mobile crowd sensing (MCS) is a novel class of mobile Internet of Things (IoT) applications for community sensing where sensors and mobile devices jointly collect and share data of interest to observe phenomena over a large geographic area. The inherent device mobility and high sensing frequency has the capacity to produce dense and rich spatiotemporal information about our environment, but also creates new challenges due to device dynamicity and energy constraints, as well as large volumes of generated raw sensor data which need to be processed and analyzed to extract useful information for end users. The paper presents an ecosystem for mobile crowd sensing which relies on the CloUd-based PUblish/Subscribe middleware (CUPUS) to acquire sensor data from mobile devices in a flexible and energy-efficient manner and to perform near real-time processing of Big Data streams. CUPUS has unique features compared to other MCS platforms: It enables management of mobile sensor resources within the cloud, supports filtering and aggregation of sensor data on mobile devices prior to its transmission into the cloud based on global data requirements, and can push information of interest from the cloud to user devices in near real-time. We present our experience with implementation and deployment of an MCS application for air quality monitoring built on top of the CUPUS middleware. Our experimental evaluation shows that CUPUS offers scalable processing performance, both on mobile devices and within the cloud, while its data propagation delay is mainly affected by transmission delay on wireless links.     

基于ECA的信息发布/订阅机制研究

分布式的监控环境中,基于发布/订阅的push模式能及时地反映用户关注的最新信息,很好地满足松散通信的需要.但当订阅条件关联多条数据信息时,传统的订阅描述方法和匹配算法难以满足要求.提出了基于ECA(event-condition-action)的信息发布/订阅机制,利用ECA规则描述复杂的订阅条件,并初步研究了匹配方法.介绍了在卫星测试中该机制的设计实现及应用.     

ATC系统中发布订阅系统的设计与实现

针对空中交通管制系统构建于局域网网络环境的特点以及对通信可靠性、实时性和高吞吐量的需求,设计并实现基于主题的发布订阅系统。该系统具有软硬件平台无关性、高效可靠、多对多通信等特点,为空中交通管制系统中子系统间提供松散耦合的、灵活的通信机制。通过采用基于事件驱动线程模型的多线程系统架构,为每个线程保存独立主题订阅表,定期进行负载均衡等优化措施,满足空中交通管理系统对发布订阅系统的需求。     

内容发布订阅系统中的动态负载均衡

复杂广域网络应用带来了内容发布订阅系统动态负载失衡问题。提出了一种动态负载均衡框架解决该问题。采用周期性交换和计算负载的方法实现了负载探测,采用代理复制和区域重构的方法解决了负载迁移问题,设计了负载协商状态机用于协商代理之间的负载迁移,采用转移加入和动态自适应两种方法进行负载均衡决策。实验结果表明,该负载均衡框架能够有效解决内容发布订阅系统的动态负载失衡问题,将负载均衡效率提高了50%。     

The study of the publish/subscribe system architecture basing on SOA

As one of the new development component model, SOA （service oriented architecture） has produced a profound influence to the future software design patterns. In this article we introduce the technical reference architecture, elaborate the key technology of SOA, analysis the problems of the publish/subscribe system basing on the traditional architecture, solve the tightly coupled relationship of the communication between the parties, overcome the poor adaptability of the changes in the operational deficiencies, and shield the complexity of the technical background.     

结构化P2P网络上可靠的基于内容路由协议

在结构化P2P网络上构建基于内容的发布/订阅系统,可以很好地支持大规模、高度动态的分布式应用.然而,现有的基于内容的路由协议在P2P网络上只能提供弱的可靠性保证.根据结构化P2P网络的路由协议的特点,设计了一种新型的基于内容的路由协议--基于编码区间的路由(identifier range based routing,简称IRBR)协议.IRBR协议具有良好的容错性,只要事件的发布者与订阅者之间在P2P网络中是可达的,则订阅者一定能够收到它所订阅的事件,且只收到一次.同时,该协议也比现有的协议具有更高的事件路由效率.在Pastry上开发了一个原型系统,模拟实验表明了该协议的效率和容错性.