基于发布订阅机制的实时消息系统设计与实现

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

云环境下实时消息推送服务构建研究

随着移动互联网技术的发展,各类消息纵横交错,人们在获取关联信息时常感到无从选择。传统的消息获取,用户需要主动拉取网络存储的消息,此种方式获取消息的效率极其低下,会产生众多与用户无关的消息。消息推送需要用户不停地拉取刷新,属于被动推送。随着云技术的发展,消息推送技术逐步转变为云推送,告别了单一服务器推送的模式。对现有各类消息推送技术进行研究和分析,针对传统基于主题订阅模式的消息推送服务只能对应单一移动端通信的不足,提出了云实验环境下实现实时消息推送服务的构建方案,设计了消息推送服务(PushWeb)的运行框架,运用H5技术中的WebSocket技术实现了管理平台和移动客户端应用程序,并将其部署在阿里云中,经测试在良好的网络环境下能够将消息实时准确地推送至移动端。

交换以太网中实时消息截止期划分算法研究

为解决交换式以太网中实时消息在发送及接收链路上的截止期划分问题,首先给出了非抢占式EDF调度算法的可调度性分析方法,并分析了消息的提前释放对非抢占式EDF调度算法可调度性的影响,在此基础上提出了新的截止期划分算法(MDPS)。算法通过计算可满足调度条件时消息在发送链路及接收链路截止期应该划分的下限,并结合截止期的松驰量实现实时消息在发送及接收链路上的截止期划分。算法实验比较和分析表明,该算法在提高网络聚合带宽、减小消息的错失率方面明显优于现有的ADPS算法。

基于SCO Unix Ware的实时消息队列设计与实现

实时消息队列作为一种IPC是在POSIX.1中定义的.但SCOUnixWare的最新版本7.1.3并不支持.结合实际开发的需要,提出了一种基于存储映射I/O和SystemV消息队列在用户级实现实时消息队列的方法,并在SCOUnixWare7.1.3上实现.结果表明,该方法是非常有效的,它能够在用户级提供一种高效的进程间实时通信机制.

基于实时服务质量的测控网络实时消息分析研究

根据分布式测控网络系统实时通信的特点及实时性的内在要求,提出了实时服务质量的概念及指标体系,建立了抽象的实时服务质量数学函数,并用实时服务质量具体指标对实时消息进行约束。实时服务质量对测控网络实例的实时分析表明:实时服务质量概念及指标体系对分布式测控网络这一类实时系统的分析与实现具有指导意义。

分布式实时消息通信的设计与实现

讨论了在ＵＮＩＸ 原有的消息队列机制基础上设计和实现分布式实时消息通信机制的方法．该机制提供透明的消息通信接口，支持带时间期限约束的实时消息请求．用户在系统调用的参数中可以给定消息请求的时间期限，对于多个远程消息请求，系统能按紧迫程度排队，以保证实时性．系统还可以定时检测消息请求的期限，对能否在期限内完成进行预测并反馈给相应进程．

主从结构交换式以太网中实时消息调度研究

为使交换式以太网能满足实时通信的要求,针对FTT-SE网络调度模型,提出了一种同时适用于周期性和非周期性实时消息的链路可调度性判定方法。在证明了消息链路调度优化问题MLSOP为NP-complete的同时,针对周期性实时消息的链路调度优化给出了启发式算法LSHA。最后,对于周期性和非周期性实时消息分别设计了基于EDF的调度算法。仿真实验表明,在提高网络链路带宽利用率和减小消息平均延时方面,该算法均较FTT-SE有明显的优势。

交换式以太网实时消息可调度性分析

针对交换式以太网不能满足工业数据通信的实时性要求问题,首先提出了一种改进的,在站点和交换机端均使用EDF算法的消息调度模型,并由源站点和目标站点以分布式方式对实时消息在链路的可调度性进行判定,从而简化了交换机的设计.另外,为保证实时消息在交换式以太网传输的实时性,分别给出了实时消息在发送和接收链路的可调度性判定条件,并进行了相应的理论证明.

Web应用中的实时消息交互技术

本文主要介绍了Web实时消息交互技术,以及目前在Web应用中进行实时消息交互的一些主流技术。

实时消息服务能力提升方法研究

目前实时消息的服务能力业务种类增加,业务量大幅提升,对各相关系统的要求不断提高。在系统硬件有限的情况下,一旦短时业务量峰值超负荷或者某业务节点异常,容易引发雪崩效应,导致业务流程整体不可用且难以恢复。经过研究分析,我们提出了一系列方法来提升实时消息服务能力和恢复:各系统接口具备消息队列蓄水能力;增加超时消息预判和下游截断功能;对关键系统设置复制库等。这方法在很大程度上提升消息服务能力,减少了异常状况的影响,便于快速维护,快速定位问题,同时避免影响用户感知和对周边系统造成压力。

一种分布式架构下的实时消息同步机制的设计与实现

由于笔者工作中经常面临如何快速、准确的实现多终端之间基于Client/Server架构下实施消息同步的问题。于是,通过引用数据库中的Service Broker技术和WCF消息框架,开发并实现了一套分布式架构下的实时消息同步中间件。本文以此为契机,介绍了这种分布式架构下的实时消息同步机制的设计与实现方法。本文先对这种消息同步机制的架构进行了介绍,给出了其实现框架,进而介绍了如何在此框架下有效的构建消息传递的机制,并对其性能进行了分析。本套解决方案已经成功应用在空中交通管制专业中,实现了面向空中交通管制的消息实施传递,并对其他行业有轻量级实时消息传递需求的应用有一定参考作用。

主从交换式以太网中跨多Switch传输消息实时调度研究

针对FTT-SE协议在单Master多交换机的网络扩展结构中存在的消息跨多Switch传输调度问题,给出了消息在每个基本调度周期内到达各交换机输出端口时间的计算方法,提出了单EC内的消息可调度性判定算法,并对算法的可行性进行了证明。在此基础上,设计了基于EDF的消息实时调度算法和准入控制算法。通过确定消息在每个基本调度周期内到达各交换机输出端口时间,所提出的调度算法能针对COTS交换机输出端口的FCFS消息传输机制,实现对单EC内消息传输的精确控制和调度。相对已有的调度算法,仿真实验表明,所提出的算法能更有效地利用网络带宽,提高了主从交换式以太网通信的实时性。

实时富客户端WebGIS框架研究与实现

为解决传统WebGIS应用中存在的实时性不强、用户体验差等问题,基于RTMP协议、Red5开源框架,设计一种实时RIA WebGIS框架。利用数据库触发器实现更新空间数据的即时分发;利用RTMP协议实现客户端与服务器之间地理空间数据高效传输;利用Red5 SharedObject实现更新数据多类型客户端实时推送;利用Flex技术进行客户端空间信息展示。在气象监测预警系统中对该框架的可行性进行验证,为实时RIA WebGIS的开发应用提供新的方法和思路。

集装箱码头短消息实时传送系统简介

随着集装箱运输蓬勃发展，上海港国际航运中心的地位逐步确立。上海港的集装箱吞吐量直线上升，这对港口计算机系统提出了更高的要求：故障信息、管理信息要求实时传送。我公司生产自动化很大程度上依靠公司的计算机系统，所以公司计算机系统的稳定性也日趋重要。

实时WDM网络的全光流量疏导算法(英文)

为解决波分复用(Wavelength Division Multiplexing,WDM)网络中实时性业务流疏导问题,提出一种考虑了网络端对端延迟的疏导算法。建立了WDM网络模型和实时消息模型,用网络演算理论分析了有连续时隙和没有连续时隙分配下实时消息的端对端的最大延迟,并推导出了算法的延迟关键性参数时隙距离。提出的实时性疏导算法不仅考虑了最大利用率时隙优先以提高网络的负载,同时考虑了时隙距离和的关键参数,保证了实时消息的延迟性能。仿真结果表明了该算法的低延迟特性和低阻塞率特性。

一种扩展型实时多数据库系统实现框架

实时多数据库系统提供了一个实时数据集成管理平台,它不仅可以处理传统数据库中的持久性数据,而且可以处理实时系统中的即时数据.首先简介了实时多数据库系统的特征,给出一种扩展型实时多数据库系统RT-Panorama的体系结构,和基于XML的实时数据模型XRTDM作为RT-Panorama的公共数据模型,针对实时多数据库系统的时限要求给出了RT-Panorama中的实时消息处理机制.

FTT调度模型中面向性能优化的消息周期指定算法

针对周期可变的实时消息集,建立柔性时间触发调度模型下消息周期与系统性能的优化模型,并给出解析取整和贪心选择2种消息周期近似最优指定算法。在此基础上,提出结合OptInt与Greed 2种算法的Comb算法。Comb算法通过利用OptInt算法获得较好的初始解,运用Greed算法对初始解进行二次优化,实现OptInt与Greed2种算法的有效组合。理论分析与仿真实验结果表明,Comb算法具有Greed算法步骤简单、算法复杂度低的优点,在保证消息集可调度前提下,能有效地优化系统的整体性能。

交换式以太网中周期性固定优先级消息的可调度性分析

为使交换式以太网能满足工业数据通信的实时性要求,首先提出了一种基于固定优先级调度(FixPriority Scheduling,FPS)的实时消息调度模型,由源站点和消息接纳控制服务器对消息进行可调度性判定.另外,通过将消息集在交换式以太网上的可调度性判定转化为对在接收链路上具有释放抖动消息集的可调度性分析问题,给出了实时消息在发送和接收链路最坏传输完成时间的计算公式,进而提出了消息可调度性判定方法,并对相关结论进行了理论证明.

基于服务调用和消息队列的营配数据集成方法及实现

随着国家电网公司“建设具有中国特色国际领先的能源互联网企业”战略目标的推进,营配调数据贯通质量、调度运行感知能力面临着更高的要求。数据查询、实时数据发布是异构系统数据集成的需求;跨语言、跨平台交互是系统贯通面临的挑战。将面向服务调用的SOAP和REST融合,配合Kafka实时消息流发布订阅用于营配数据集成,可有效解决上述问题。清晰规范的自描述服务定义可减少接口联调时间,不依赖第三方服务框架,便于问题定位,提升稳定性。较低的系统介入程度,可降低改造复杂度。经现场工程测试验证,此方法实际有效地支撑了多省地营配系统贯通业务。

中国电信全网计费资料数据实时同步方案研究

中国电信两级运营机制和属地化运维体制,使得集团层面缺乏全网的用户信息、价格计划、销售品管理等资料类数据,亟需以数据同步的方式将分散在各省的数据实时同步上传到全国中心,为此中国电信企业信息化的计费域采用数据文件与增量消息相结合的方法,从实施方案设计、业务技术难点、关键性能优化等角度进行了工程实践,较好地实现了"基础数据两级系统同步变化,核心主数据集中管理"的初期目标。