摘要：基于ApacheKafka消息代理框架使用成本高和基于私有协议导致的兼容性不好等问题,提出了以WebSocket作为通信协议的发布订阅机制实时消息系统的设计方案。以聊天系统为例,使用***实现后端服务,使用Redis的发布订阅机制来构建实时消息系统,同时提出了全局ID、消息令牌等模块的设计思路。首先进行了方案技术选型,具体包括消息传递模型与协议选型、后端框架选型,然后阐述了系统架构设计和主要模块实现,最后进行了系统测试。测试结果表明系统运行稳定,实时连接性能良好。

摘要：事件空间划分技术改变了传统基于内容发布订阅系统的基本交互模式和相关实现策略,形成了主动发布订阅系统.为了建立主动发布订阅系统的完整解决方案,在分析系统基本交互模式的基础上,提出了一个主动发布订阅系统的设计框架ACTPS(Active Publish/subscribe System).分为6个设计模型:事件模型,订阅模型,划分模型,构件模型,路由模型和匹配模型.详细描述了各模型的关键特征及核心实现策略,以及各个模型之间的联系.ACTPS为一般的主动发布订阅系统设计和实现提供了参考模型,并为进一步深入的研究和分析建立了基础.

摘要：基于航管训练系统建于局域网的特点,本文实现了基于非可靠数据传输的发布订阅:订阅者订阅主题,发布者向订阅了该主题的所有进程发送主题的内容。同时,通过以下设计对系统进行了优化:使用检测锁机制减少加锁,设计小报文组成大报文发送减少发送频率,对接收的报文设置时间字段实现节点的动态管理。

摘要：随着科学技术的发展,实时聊天系统、微博以及在一些读写分离的分布式架构等应用越来越多,Redis的发布订阅便可以实现这些功能。针对Redis在分布式系统中作为数据通信中间件的问题,本文主要研究了Redis的发布订阅功能。首先简要介绍了Redis的发布订阅功能和机制,然后在基于Java环境下实现了通过Redis的发布订阅功能进行客户机之间的数据通信。

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

摘要：针对分布式系统应用规模大、范围广、运行环境复杂的特征,分析分布式交互平台在功能和性能上的需求,设计并实现了一个基于发布/订阅机制的实时交互平台NetDDS。采取分层设计的思想,依次从分发服务层、QoS保障层和数据传输层3个方面完成实时交互平台的构建,提供基于发布/订阅机制的数据同步功能、灵活可配置的服务质量保障机制以及基于以太网的多协议数据传输机制,确保了数据传输的实时性、正确性与可靠性。实验结果表明,该交互平台具有较低的消息更新延迟,能满足分布式应用中数据分发对实时性的要求。

摘要：针对雷达信息处理松耦合集成、高效数据传输需求,提出并设计了一种面向DSP与FPGA的发布订阅通信中间件。首先,采用发布订阅机制实现DSP和FPGA之间应用软件间的松耦合数据传输;然后,设计了统一的数据收发接口,屏蔽底层硬件细节差异;最后,设计了高效的数据收发缓存机制,提高异构平台间数据收发效率,应用于雷达信息处理软件设计,实现DSP与FPGA之间发布订阅松耦合通信。

摘要：电网调度自动化系统存在着大量的实时消息,这些消息有前置数据更新消息、告警消息、模型更新消息等,服务器之间通过高效的消息中间件传递消息,而服务器与工作站之间直接采用消息中间具有一定的限制。服务器与工作站之间不仅性能上存在大的差异,网络带宽也会有较大差异。在性能差异比较大的环境下直接使用消息中间件,会降低消息中间件的整体性能。文章给出一种基于发布订阅模式的消息转发服务设计,能够较好地解决性能差异较大工作站与服务器之间的消息通信问题,该方法已应用于实际系统中。

摘要：随着空管系统引入越来越多应用系统,系统间进行信息共享越来越普遍。空管系统间对信息的安全性、完整性、及时性、高效率性的要求一般都比较高,而目前空管主流的信息共享的技术手段都存在缺陷。本文设计了一种基于发布订阅模式的系统间信息共享方案,可同时支持航班数据、监视数据等信息共享,满足了空管系统对信息的要求,对空管系统间共享信息具有良好的参照指导意义。

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