消息队列

摘要： 随着数字化焊接机器人进入工厂,采用传统人工监督的方式逐渐不能满足对设备的监控管理需求。一些采用“多机器人厂商、中小生产规模”为生产模式的企业,需要一个低成本、高适配性的平台,统一管理现场各种焊接机器人。针对上述需求设计了机器人管控系统,系统可分为通信模块和设备管控模块。其中,通信模块采用C/S架构开发,通过Netty框架搭建NIO服务器接收实时数据,开发的基础通信框架能够适配多种通信协议,接入不同品牌的机器人;设备管控模块采用B/S架构开发,基于Spring MVC框架实现,通过统一的平台对各个品牌机器人进行管理、监控和维护,以及历史数据的展示等。经现场运行验证,该系统能实现不同品牌机器人的统一监管,并且能够长时间稳定运行。

摘要： 随着接入网络设备的多样化,需要找到一个能够跨越不同网络设备之间的通信协议和适合它们之间进行数据交换的通信模型。MQTT协议作为一个量级的消息传输协议,具有低功耗、节省流量和可扩展性强的特点。由于其特有的发布/订阅消息传输模式,能够满足跨多个不同操作系统端设备之间进行互联互通。基于MQTT协议建立一个服务器中间消息队列是在传统信息管理系统三层模型以外添加一个既独立于MQTT消息代理服务器,又不与三层之间进行耦合的消息数据封装、处理、传输模式层。该消息队列即可以通过多线程进行操作,同时也具备异常客户端的消息再处理流程。

摘要： 对变电站辅助监控平台系统进行了探究,针对环境监测、消防火灾、安防门禁、动力照明及视频监控等辅助系统的智能融合程度不高等现状,提出了一种基于消息队列的变电站智能联动技术,给出了辅助监控系统的智能联动框架及其实现方案,解决了辅助监控子系统各自孤立、无法融合联动智能告警等问题,可以保证变电站无人值守、安全运行。

摘要： 随着互联网技术发展和硬件算力的增强,基于深度学习的人工智能算法在实际应用中有着长足发展,更多的人工智能算法被应用在各类产品中。但这些人工智能模型具有庞大的参数规模,且对算力具有强依赖性,如何在不影响用户体验的情况下,提升深度学习算法能力成为研究重点。本文针对目前主流的请求方式进行分析,提出了结合异步的分布式消息队列图像解析系统,这对人工智能算法在云服务中的应用具有指导意义与参考价值。

摘要： 现代化数据中心机房是一项复杂、庞大的信息化基础设施,机房综合运维系统作为机房运维管理不可或缺的工具,承担着机房动力环境、信息化软硬件设备等设施实时运行状态的监测。因机房设备种类多、数量大、设备异构等特点,给运维系统的并发处理能力、可靠性带来了挑战。研究了Redis消息队列机制,将Redis作为消息队列中间件应用在机房综合运维系统中,提升了机房运维系统的并发能力、可靠性。

摘要： 随着信息技术的飞速发展,云计算、大数据时代的到来,应用系统规模和复杂度不断提高,针对各种高并发访问、海量数据处理等需求下优化系统架构的目标,对分布式消息中间件技术应用进行研究分析,首先概述了分布式消息中间件的概念、核心模型、协议,然后对分布式消息中间件技术发展以及RabbitMQ、RocketMQ、Kafka、Pulsar等流行开源分布式消息中间件特点进行阐述,分析应用场景,最后对技术选型与应用进行分析并归纳提出意见,建议从多技术维度、经济性等方面选择适合需求的分布式消息中间件技术来构建高效信息系统。

摘要： 当前用电信息采集系统的采集前置部分在海量终端的接入和通信、海量高频数据的采集和入库等方面存在明显的技术瓶颈,任务处理灵活性不高、并发处理能力不足、扩展性较弱,难以满足新形势下各类业务日益增长的多元化需求。针对这些问题,提出了一套解决采集前置性能瓶颈的方案,涵盖通信任务分级管理、采集任务并行执行、高并发通信处理、规约动态扩展及适配、采集数据入库并行处理等多个方面。在国网某省级电力公司用电信息采集主站提升改造项目中的工程应用表明,前置性能明显提升。

摘要： 互联网+教育,开展在线教育、在线培训已成为大势所趋。本文结合当前信息技术及多年培训工作经验,构建了由门户网站、央在线教学平台和管理平台组成的在线教育培训平台。该平台提出了一种基于消息队列中间件RabbitMQ的系统架构,并通过设计消息格式、开发数据同步模块、利用ORM、JSON及Supervisor等工具,实现子平台之间数据的快速自动化同步,建立在线教育平台。对其他院校相关系统的设计具有借鉴和参考价值。

摘要： 针对移动智能设备在移动办公等方面遇到的管控难题,基于移动设备管理平台和移动安全门户提出了一种多维一体化的管控方案,实现对智能终端进行统一管理和安全管控.方案通过Openfire(即时通讯框架)传输管控命令,并结合token(令牌)动态验证方式及Redis(远程字典服务)消息队列技术,在管理平台和移动门户之间建立管控命令和安全策略的传输机制,并实现对移动数据进行区域隔离和分片加密存储.方案不仅能精准地发送管控信息,而且能根据管控策略灵活管理移动设备的软硬件能力,同时对移动数据的加密处理也有效降低了移动数据被窃取的风险.

摘要： 本文阐述了我省气象通讯系统基于消息中间件RabbitMQ的气象资料收集和分发技术,讲述了基于RabbitMQ消息中间件的通信传输模式和气象通讯系统2.0版本的技术框架.结果证明,基于RabbitMQ消息中间件的黑龙江省气象标准格式传输方式运行稳定,大大提高了气象数据的传输速率和服务能力.

摘要： 地理信息服务的发展为地理数据、功能的共享提供了新的技术方法，但也给GIS协同操作带来了新的问题。在分析了协同GIS的研究现状的基础上，结合地理信息服务的特征提出了一种基于消息队列的GIS 协同操作方法。首先根据GIS 操作特征对其进行了类型划分、优先级评定，建立了协同环境中GIS 操作的转换机制；构建了操作消息的描述模型，以及队列入队、出队的规则；并以原型系统验证了研究的正确性；最后，对基于地理信息服务协同操作的发展思路和进一步的研究进行了探讨。

摘要： 简要描述了基于消息队列的通信模型在过程控制系统中的应用,介绍了其原理、设计实例、实现技术和应用。

摘要： MSMQ与MQSeries在应用系统中得到了广泛的应用。本研究在.NET环境下为上述两种服务器提供了不同的用户接口，为了能够提供一套统一的用户接口，设计并实现了一个消息队列服务构件.该构件的设计使用了桥接模式，提高了系统的可扩展性。消息队列服务构件的大大降低了程序人员访问以上两种消息队列服务器的复杂度。

摘要： 总结了先进的KeyStoneⅡ多核SOC体系结构特点,指出了IPC的重要性,重点介绍了消息队列这种处理器间通信的常用模块;然后系统介绍了其他重要IPC模块,并指出各自适用场合,使用户可以方便地选择适合具体应用的方法来完成处理器间的通信任务.

摘要： Android使用一种新的进程间通信机制Binder作为系统核心的通信方式.在本文中,对Binder进行了一个全面的性能测试.首先设计Binder和传统的IPC通信方式的对比实验,由于Android的限制,在传统的IPC中选择管道和TCP/IP套接字.通过实验发现Binder适合小数据传输.而传统IPC的传输带宽高很多,而且时延小,更适合大数据的传输.进一步分析Binder实现和获取的数据发现,随着并发数目的增加,Binder性能下降更加明显.从实验可知,Binder驱动使用了全局内核锁来确保Binder的并发安全,但也带来性能损失.接下来采用了基于消息队列的Binder驱动实现替换Android的默认Binder模块来验证全局锁的副作用,进行对比实验得出结论,基于消息队列的无全局锁的Binder性能提升了20％以上.

摘要： 在基于移动CMPP协议，Linux操作系统的基础上，设计了一种能够实现较高性能的移动短信增值业务系统通信解决方案。通过提出多线程处理机制以及数据库，消息队列，日志文件等多级缓存机制，能够有效解决大业务量的短信同时下发易产生的效率低下以及延时等问题。

摘要： 话务网管经过多年的建设,已经成为网络集中监控、集中操作、集中维护的重要工具。其中的告警监控系统作为其三大功能模块中的一个重要支柱,每天都要为数百名用户提供服务,因此建立成熟稳定的备份机制十分重要。作者首先介绍了话务网管告警监控系统最初使用的备份方案,并分析了现有备份方案的不足之处,提出了利用Radware和RealSync分别对消息队列以及数据库进行备份方式改造的方案。

摘要： 民航气象数据库系统通讯方式依赖于IBM Websphere MQ中间件技术,该系统以网络模式为主要传输方式对气象资料进行传输.随着民航气象资料传输量的迅速增长,MQ中间件技术在民航气象数据库系统中扮演着越来越重要的角色.本文首先介绍了MQ概念、原理,在此基础上,依据银川日常实际工作经验,重点阐述了MQ在民航气象数据库中的应用,并详述了MQ故障排除要点.

摘要： 民航气象数据库系统通讯方式依赖于IBM Websphere MQ中间件技术,该系统以网络模式为主要传输方式对气象资料进行传输.随着民航气象资料传输量的迅速增长,MQ中间件技术在民航气象数据库系统中扮演着越来越重要的角色.本文首先介绍了MQ概念、原理,在此基础上,依据银川日常实际工作经验,重点阐述了MQ在民航气象数据库中的应用,并详述了MQ故障排除要点.

摘要： 民航气象数据库系统通讯方式依赖于IBM Websphere MQ中间件技术,该系统以网络模式为主要传输方式对气象资料进行传输.随着民航气象资料传输量的迅速增长,MQ中间件技术在民航气象数据库系统中扮演着越来越重要的角色.本文首先介绍了MQ概念、原理,在此基础上,依据银川日常实际工作经验,重点阐述了MQ在民航气象数据库中的应用,并详述了MQ故障排除要点.

摘要： 本发明公开一种短消息队列结构、短消息队列调度方法及装置，属于通信技术领域，特别涉及一种短消息队列调度方法，包括：将短消息按照时延需求，划分为第一类型短消息、第二类型短消息、第三类型短消息；按照优先级由高到低的顺序设置队列一、队列二、队列三；等待接收短消息，在接收到短消息时，判断短消息的类型，如果属于第一类型短消息，则将第一类型短消息分派至队列一中；如果属于第二类型短消息，则将第二类型短消息分派至队列二中；如果属于第三类型短消息，则将第三类型短消息分派至队列三中。本发明方法与现有短信分发平台方案相比，本发明采用的队列机制可以适配差异化时延需求的短消息，并提供积压场景下的短消息按需分发能力。

摘要： 本发明提供了一种消息队列容器创建方法、装置及消息队列容器，该方法包括：修改目标对象的应用程序；确定目标对象的配置文件，且配置文件中包括有至少一个参数；通过执行修改后的应用程序并加载配置文件，创建目标对象对应的消息队列容器，其中，创建出的消息队列容器满足所述至少一个参数。对于任一目标对象，基于其应用程序和配置文件，即可创建其对应的消息队列容器，以进行其相关消息处理。这一轻量级消息队列容器可以替代现有的消息队列组件，故无需部署消息队列组件。因此，本方案能够降低资源占用率。

摘要： 本发明公开了消息队列业务数据调度及消息队列的实现方法，着眼于集约运营物联网公共服务行业，如车联网、智能家居、智慧健康等行业，面向物联网客户输出业务应用信息，通过实时采集各种业务运营数据用于解决物联网异构设备数据融合和实时处理问题。本发明是将运营商物联网业务信息进行汇聚，并对物联网业务进行抽取、组合和发布，构建稳定的泛在业务运行支撑环境，为业务使用者提供可扩展的业务应用。该系统从底至上依次包括通信层接入模块、消息队列管理模块、系统服务模块、业务解析模块、用户应用模块。该系统各个模块的物联网业务数据主要来源于物联网数据中心。本发明加快了运营商物联网业务数据交互，实现系统集成。

摘要： 本发明提供了一种消息队列的实现方法和系统。所述方法包括：根据消息队列中触发的操作获取队列标识的位置值，并执行操作；判断获取的位置值是否与队列标识当前对应的位置值相同，若否，则拒绝操作的执行，若是，则接受操作的执行，并更新接受操作的队列标识当前对应的位置值以及队列标识中的指针值。所述系统包括：队列处理装置，用于根据消息队列中触发的操作获取队列标识的位置值；判断装置，用于判断获取的位置值是否与队列标识当前对应的位置值相同，若否，则拒绝所述操作的执行，若是，则通知存储装置；所述存储装置用于接受操作的执行，并更新接受操作的队列标识当前对应的位置值以及所述队列标识中的指针值。采用本发明提高了并发度。

摘要： 本发明实施例提供一种消息队列系统以及基于消息队列系统的消息处理方法，消息队列系统包括生产端、消费端以及监听端；消息处理方法包括在生产端和消费端中注册与事件对应的钩子函数；当生产端或消费端对消息的操作符合预设的事件时，触发执行对应的钩子函数，钩子函数记录并发送状态信息至监听端；监听端创建与消息对应的影子消息，并将接收到的状态信息记录在影子消息中，根据影子消息对消息的处理过程进行统计。本发明实施例实现了细粒度且实时的消息处理追踪。

摘要： 本公开实施例公开了消息队列处理方法、装置和消息队列管理系统。消息队列处理方法包括：在消息队列存储节点的虚拟内存中建立用于缓存热消息的第一缓存区和用于缓存冷消息的第二缓存区；根据对消息队列的读取请求，确定所述读取请求所请求的消息的索引值；根据所述索引值确定从所述第一缓存区读取所请求的消息还是位于所述第二缓存区；从所述第一缓存区或所述第二缓存区返回所述读取请求所请求的消息，可以实现对冷热消息数据采用不同缓存区进行缓存，使得冷热消息数据的读缓存进行了物理上的分离，减少了系统大量冷读对于硬盘IO的占用，而且可以通过控制第二缓存区来减少硬盘的冷读访问，防止硬盘读写出现性能瓶颈。

摘要： 本发明公开一种短消息队列结构、短消息队列调度方法及装置，属于通信技术领域，特别涉及一种短消息队列调度方法，包括：将短消息按照时延需求，划分为第一类型短消息、第二类型短消息、第三类型短消息；按照优先级由高到低的顺序设置队列一、队列二、队列三；等待接收短消息，在接收到短消息时，判断短消息的类型，如果属于第一类型短消息，则将第一类型短消息分派至队列一中；如果属于第二类型短消息，则将第二类型短消息分派至队列二中；如果属于第三类型短消息，则将第三类型短消息分派至队列三中。本发明方法与现有短信分发平台方案相比，本发明采用的队列机制可以适配差异化时延需求的短消息，并提供积压场景下的短消息按需分发能力。

摘要： 本发明公开了一种基于消息队列的处理方法和消息队列，涉及计算机技术领域。其中，所述方法包括：对唯一消费者应用的状态进行监测；对消息存储区存储的同一主题下的消息总量进行监测；在监测到所述唯一消费者应用为异常状态，和/或，所述消息总量大于等于预设阈值的情况下，向唯一生产者应用发送暂停生产的通知，以使所述唯一生产者应用暂停消息的生产；其中，所述唯一生产者应用与所述唯一消费者应用隶属于同一主题。通过以上方法，不仅能够满足实际生活中对一对一的发布‑订阅模式的场景需求，而且能够有效解决消息在生产侧或消费侧大量积压的问题，进而有助于提高唯一生产者应用、唯一消费者应用的性能。

摘要： 本发明提供了一种消息队列容器创建方法、装置及消息队列容器，该方法包括：修改目标对象的应用程序；确定目标对象的配置文件，且配置文件中包括有至少一个参数；通过执行修改后的应用程序并加载配置文件，创建目标对象对应的消息队列容器，其中，创建出的消息队列容器满足所述至少一个参数。对于任一目标对象，基于其应用程序和配置文件，即可创建其对应的消息队列容器，以进行其相关消息处理。这一轻量级消息队列容器可以替代现有的消息队列组件，故无需部署消息队列组件。因此，本方案能够降低资源占用率。

摘要： 本发明公开了消息队列业务数据调度及消息队列的实现方法，着眼于集约运营物联网公共服务行业，如车联网、智能家居、智慧健康等行业，面向物联网客户输出业务应用信息，通过实时采集各种业务运营数据用于解决物联网异构设备数据融合和实时处理问题。本发明是将运营商物联网业务信息进行汇聚，并对物联网业务进行抽取、组合和发布，构建稳定的泛在业务运行支撑环境，为业务使用者提供可扩展的业务应用。该系统从底至上依次包括通信层接入模块、消息队列管理模块、系统服务模块、业务解析模块、用户应用模块。该系统各个模块的物联网业务数据主要来源于物联网数据中心。本发明加快了运营商物联网业务数据交互，实现系统集成。