消息中间件

摘要： 为了提高疾控中心进行大规模数据交换的处理效率,基于线程池与消息中间件技术设计并实现了一个数据交换处理模型,该模型在调用数据接口并记录接口反馈信息的基础上自动构造数据交换任务,使用消息中间件快速保存反馈信息,使用线程池并通过合理设置线程池的参数实现了数据交换任务的并发控制.仿真实验结果表明,相对于传统的数据交换处理方式,该模型在保证数据交换稳定性的同时极大提高了数据交换任务的处理效率.

摘要： 随着工业互联网4.0时代的到来,工业数据和各类设备急剧增长,传统的单节点、单通道网络调试软件已经无法满足需求。基于此,笔者利用网络传输框架、消息中间件等技术,设计一款具有多通道、高并发、低延迟等特点的通信软件。在传输层中,利用消息中间件和数据库存储模型研发了一套适用于工业大数据环境的幂等性架构;在网络层中,利用消息中间件来实现系统多节点的事务。实验结果表明,该软件可以稳定运行。

摘要： 消息中间件是利用可靠高效的消息递送机制帮助分布式系统进行平台数据交互的系统软件。分析了消息中间件的Java消息服务(JMS)标准、消息模式和发展现状,讨论了消息中间件带来的几个优势和应用消息中间件带来的若干问题,并提出了解决方案。以SpringBoot工程中应用ActiveMQ为例,通过编码实现展示了应用ActiveMQ的主要方法。

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

摘要： 针对分布式系统中日志的分散以及异常无法高效排查的问题,提出了一种基于分布式消息中间件和GRU(Gate Recurrent Unit,门控循环单元)的方法对分布式系统的日志进行一个收集以及异常预测。首先使用消息中间件对分布式系统的日志进行预处理和收集。收集之后的日志经过word2vec(word to vector)进行编码后输入设计好的GRU网络中进行一个预测分类,通过对比预测值与实际值来分析系统的异常情况,系统维护人员就可以及时了解整个分布式系统的异常情况。通过实验仿真后也验证了论文提出的方法有着很好的轻量性与准确性。

摘要： 文章针对广域网架构下的多数据副本的数据一致性问题,提出了基于ZeroMQ及增量数据抽取的同步方案,研制了同步软件UltraSync.在中国民航流量管理系统的研制与应用中,UltraSync能高效地同步中心节点数据分布在全国的二级分系统,有效解决了核心数据的分布式存储问题.

摘要： 为提高多普勒天气雷达资料处理效率,基于消息中间件技术、数据缓存等技术,开展了雷达资料处理与组网拼图技术应用研究.采用RabbitM Q消息中间件,实现雷达资料质量控制、网格化处理、数据缓存等实时调度处理.采用多进程技术,实现雷达资料组网拼图和可视化绘制.在此基础上,构建分布式并行业务运行系统,对江西省8部多普勒天气雷达进行组网拼图处理,实时制作时空分辨率分别为6 m in和0.01°的雷达拼图产品.基于消息的雷达拼图技术显著提高了数据处理时效,满足了天气监测预警等精细化气象业务服务需求.

摘要： 有效的信息整合共享是政务业务协同实现的必备条件.文章分析当前政务业务协同的现状以及主要技术,研究并提出一种基于大数据的政务业务协同系统设计,旨在为我国政务业务协同系统建设及数据运营提供参考建议.

摘要： 随着互联网业务规模的扩大以及访问量的增多,应用服务可能因流量过大而产生崩溃.为解决此问题和保证应用服务器接收消息的准确性,本文设计了一种基于Netty的消息中间件.该中间件以Netty网络框架为基础实现异步通信,同时为了提升通信双方的编解码速度及缩减整个通信流程的时间,自定义了一种通信协议.该中间件根据本协议特点设计了消费模型及基于文件系统的存储模型,并在消费者端进行了幂等性处理,以提高中间件的可靠性与准确性.实验表明,相比于不使用中间件或使用其它中间件,该中间件在产业化的智慧宿管平台中应用,有效提高了应用服务的响应速率以及接收消息的准确率,保证了智慧宿管平台的平稳运行.

摘要： 随着软件无线电、软件化卫星等技术的发展,中间件作为软件平台支撑技术得到广泛的研究.当前中间件主要包含面向对象的组件型和消息中间件,但是大部分中间件,如Kafka、RocketMQ等均面向个人计算机平台应用,无法适配到嵌入式平台上.同时其设计过多关注高并发和高性能,无法满足军用电子系统实时性、高可靠等方面的要求.为了满足此类应用,对象管理组织提出了以数据为中心的发布/订阅通信模式为其提供数据分发服务,并发布了相关规范.通过将轻量化的极端资源受限环境数据分发服务(Extreme Resource Constrained Environment Data Distribution Service,XRCE-DDS)中间件部署到CPU、FPGA和DSP等嵌入式处理器上,实现了在嵌入式异构平台中基于数据分发服务中间件的不同主题数据的发布/订阅.

摘要： 为了解决气象数据共享和业务集成中存在的问题,提升业务系统在数据处理、预报加工、产品发布流程中的数据流动效率问题.宁波气象部门采用Java,C#,Delphi等编程语言开发了基于消息中间件技术的气象信息总线.该总线在数据共享方面能确保数据资源的统一更新,在业务集成方面能有效解耦业务系统中的各种应用,提高各业务平台的信息交互和功能复用水平.消息中问件是一种独立的系统软件或服务程序，分布式应用系统借助这种软件在不同的技术之间共享资源，管理计算资源和网络通讯。ActiveMQ是消息中问件的一个跨平台实现。ActiveMQ是一个基于Apache2.0协议开源的高性能JMS实现产品，也是一个经验证成熟而又功能丰富的最佳开源消息服务(JMS)引擎。本文介绍了消息中间件技术和ActiveMQ特性,详细阐述了架构设计、消息格式标准、消息队列使用等关键技术,并以该技术在业务中的应用为例展示了气象信息总线在业务集成领域的优势.

摘要： 本文首先分析流域坝安全监测系统中当前几种主要的数据传输方式,包括基于Socket的传输、基于二进制和基于XML的远程过程调用的传输,对比了各种数据传输方式的优缺点和适合应用的环境,详细介绍了消息中间件技术的特点,消息中间件可以在分布环境下扩展进程间的通信，并支持多通信协议、语言、应用程序、硬件和软件平台。以乌江流域为例说明了消息中间件在流域坝安全监测数据传输中的应用.乌江集控监测数据集成系统，数据同步程序使用了消息中间件进行传输，保证程序不异常退出、保证网络中断恢复后能将未传完的数据传到服务器中。系统至投运以来运行状况良好，各厂站的数据能正常传输到集控中心。

摘要： 本文通过分析区域妇幼保健业务管理的和信息集成的复杂性,提出采用消息中间件搭建区域妇幼保健信息系统底层数据交换平台的系统设计方法,借助Apusic消息中间件解决区域网络环境下异构信息系统集成的难题,并总结了该套设计方案在试点地区的应用效果.

摘要： 本文通过分析区域妇幼保健业务管理的和信息集成的复杂性,提出采用消息中间件搭建区域妇幼保健信息系统底层数据交换平台的系统设计方法,借助Apusic消息中间件解决区域网络环境下异构信息系统集成的难题,并总结了该套设计方案在试点地区的应用效果.

摘要： 云平台需要可靠、即时的通讯服务以及安全、持久的信息传输服务.因此,消息中间件,即与平台无关的信息管理系统的应用就显得更为必要.而一般的消息中间件并不能完全满足云平台的需求,所以需要建立一个面向云平台的消息中间件.本文针对消息中间件系统实际应用中的消息通讯需求，设计与实现了面向云计算虚拟化的消息中间件系统。在路由负载模块提出了一种负载均衡的算法，解决了负载均衡的问题，提高了集群的利用率。

摘要： 本文针对证券行业IT系统的日常巡检和运维工作耗费大量人力进行重复操作,提出了自动识别各个应用系统的进程运行状态并及时反馈的方案.设计并实现了基于消息中间件的监控系统,Agent能调用监控脚本程序及时采集并反馈交易所报盘程序、恒生AR、恒生AS等各种程序的状态、日志、按钮等关键要素,并通过消息中间件及时传输与处理,实现了对各个系统的运行状态的实时监控.

摘要： WebLogic作为使用最广的消息中间件,在全球具有广泛的占有率.通过对JVM进行Heap堆内存、Permanent区核心参数设置和监控,实现内存溢出的控制,并基于软件Cacti开发出了针对Weblogic的性能监控软件,有效提升了运维自动化能力。

摘要： 消息中间件RabbitMQ作为AMQP(Advanced Message Queuing Protocol)协议的标准实现,具有消息持久化、事务处理、负载均衡和拥塞控制等良好特性.本文结合禁核试北京国家数据中心地震交互分析软件的需求,采用RabbitMQ异步消息通信机制,设计了交互分析软件的控制调度模块,实现交互分析软件对辅助分析工具和部分自动处理程序的实时调度,扩展了分析手段,为更准确的进行事件分析和判别提供了平台.

摘要： 针对航天互联网的互操作问题,本文通过引入框架概念,结合空间飞行任务操作过程特点,提出了一种面向空间飞行任务操作的MOM+SOA混合框架概念,并且给出了此混合框架在卫星测控中心系统中的应用概念,可以很好地改善中心系统内部、以及中心系统与外部系统间的互操作性与快速响应能力.

摘要： 针对航天互联网的互操作问题,本文通过引入框架概念,结合空间飞行任务操作过程特点,提出了一种面向空间飞行任务操作的MOM+SOA混合框架概念,并且给出了此混合框架在卫星测控中心系统中的应用概念,可以很好地改善中心系统内部、以及中心系统与外部系统间的互操作性与快速响应能力.

摘要： 本申请公开了一种消息中间件的限流方法及消息中间件，所述方法应用于所述消息中间件，所述消息中间件的限流方法，包括：当接收到生产者发送的消息发送请求时，拦截所述消息发送请求；解析出所述消息发送请求中的目标参数；其中，所述目标参数至少包括消息类别管理标识；获取所述消息中间件中的所述消息类别管理标识对应的目标限流器；通过目标限流器为所述消息发送请求获取令牌；其中，所述限流器按照配置的限速参数生成令牌；若获取到令牌，则将所述消息发送请求传递至下一个处理器进行处理；若未获取到令牌，则拒绝所述消息发送请求。

摘要： 本发明涉及一种基于面向数据内容的云消息中间件的数据交换方法和云消息中间件系统。该方法包括：1)在不同的管理机站部署基于云消息中间件的节点，由各个所述节点构成消息传输网络；2)在所述消息传输网络的各节点中部署基于数据内容的流触发器；3)通过所述消息传输网络实现跨IDC的数据交换，并通过所述流触发器实现面向内容的数据交换。本发明可以高效、稳定的进行跨IDC数据交换，同时利用基于内容的流触发器进行数据订阅，能根据数据内容进行按需转发，使消费者可以自主决定数据的流向并细粒度地获得所需的数据，提高了网络传输的质量，减小了网络负担。本发明提供的多种工作模式均能稳定使用，能够支撑起不同的应用场景。

摘要： 本发明提出一种消息中间件及消息传输方法，该消息中间件包括JMS消息服务组件，用于接收上位机发送的消息业务请求，并调用时序接口将消息业务请求添加至消息管理器中的时序队列中；消息管理器，用于管理时序队列，时序队列中包括多个时序，每个时序用于描述一个上位机发送的消息业务请求，消息管理器在消息业务请求对应的消息线程中处理消息业务请求，并根据处理结果生成消息业务请求的响应消息；JMS消息服务组件，还用于调用消息接口对响应消息进行封装，并将封装后的响应消息提供至消息业务请求对应的下位机。通过本发明能够有效提升自动售检票系统的消息传输标准化程度，提升兼容效果和可扩展性。

摘要： 本申请公开了一种消息中间件的限流方法及消息中间件，所述方法应用于所述消息中间件，所述消息中间件的限流方法，包括：当接收到生产者发送的消息发送请求时，拦截所述消息发送请求；解析出所述消息发送请求中的目标参数；其中，所述目标参数至少包括消息类别管理标识；获取所述消息中间件中的所述消息类别管理标识对应的目标限流器；通过目标限流器为所述消息发送请求获取令牌；其中，所述限流器按照配置的限速参数生成令牌；若获取到令牌，则将所述消息发送请求传递至下一个处理器进行处理；若未获取到令牌，则拒绝所述消息发送请求。

摘要： 本发明涉及一种基于面向数据内容的云消息中间件的数据交换方法和云消息中间件系统。该方法包括：1)在不同的管理机站部署基于云消息中间件的节点，由各个所述节点构成消息传输网络；2)在所述消息传输网络的各节点中部署基于数据内容的流触发器；3)通过所述消息传输网络实现跨IDC的数据交换，并通过所述流触发器实现面向内容的数据交换。本发明可以高效、稳定的进行跨IDC数据交换，同时利用基于内容的流触发器进行数据订阅，能根据数据内容进行按需转发，使消费者可以自主决定数据的流向并细粒度地获得所需的数据，提高了网络传输的质量，减小了网络负担。本发明提供的多种工作模式均能稳定使用，能够支撑起不同的应用场景。

摘要： 本发明公开了一种实现消息一次送达的消息中间件辅助系统及消息传送系统，属于业务传送领域，要解决的技术问题为如何实现消息的一次送达；其结构包括包括：消息发送附加模块，所述消息发送附加模块用于通过注解指定适配器以匹配消息中间件，用于在调用消息中间件的client程序发送消息时生成唯一码并将唯一码注入消息的properties对象中；消息接收附加模块，所述消息接收附加模块用于通过注解指定适配器以匹配消息中间件，用于当与内存型KV数据库连接失败时指定处理逻辑，并用于在调用消息中间件的clinet程序接收消息之前去重唯一码。该系统包括消息中间件、业务系统辅助系统和内存型KV数据库。

摘要： 本发明提供一种基于消息中间件的消息回放方法和装置，该方法为：当接收到消息中间件转发的消息回放指令时，构建消息回放实例，该消息回放指令至少包含指定时间段；创建并启动消费线程；根据消息回放实例和消费线程，从消息存储组件的从节点中，获取消息回放指令所指定的处于指定时间段内的待回放消息，若获取得到待回放消息，重新消费待回放消息。本方案中，在接收到消息回放指令时，利用所构建的消息回放实例和消费线程，从消息中间件的消息存储组件从节点中，获取处于指定时间段内的待回放消息，重新消费所获取到的待回放消息，以实现回放任意时间段内的消息。

摘要： 本发明提供了一种基于消息中间件的消息处理方法、装置及存储介质，消息中间件包括若干网络节点，各网络节点均包括一个消息总线进程模块和均连接至该消息总线进程模块的若干用户进程模块，各网络节点的消息总线进程模块彼此连接，形成一种去中心化部署结构的消息中间件。由此本发明在进行消息处理过程时通过待发送消息携带的目标网络节点和目标用户进程的相关信息判定消息中间件中哪个网络节点是目标网络节点，以及在整个消息发送、接收过程仅通过消息总线进程模块以及若干用户进程模块进行传输，无需经消息服务节点，克服了集中式结构的上述问题，具有高性能、高可靠、低网络流量、低延迟的优点，适合在工业现场监控系统中应用。

摘要： 本发明提供了一种消息中间件系统、邮局系统及消息收发方法，可用于分布式技术领域，该系统包括：安全中心模块，用于在接收到邮局系统的邮局注册请求后，对该邮局系统进行注册，获得该邮局系统的公钥和私钥；信箱管理模块，用于在接收到信箱注册请求后，生成对应的信箱模块；接收生产者发送的信件，基于目标邮局系统的公钥加密所述信件，并写入信箱模块；对信箱模块中的信件进行确认后写入消息队列；从消息队列读取目标邮局系统为当前邮局系统的信件放入信件的目标信箱模块对应的信箱模块；基于当前邮局系统的私钥解密当前信箱模块中的信件，并发送至对应的消费者。本发明可以实现消息收发，可靠性高，性能高，安全性高。

摘要： 本发明公开了一种基于消息中间件背压的消息消费的方法和系统。所述系统包括：注册中心、接入网关和消息处理节点；所述注册中心，用于负责监听消息处理节点运行状态，节点异常时负责故障转移工作触发；所述接入网关，用于通过网关接口发起队列创建工作与发起监听线程创建工作；所述消息处理节点，用于负责消息处理工作以及缓存处理。该方法采用了动态创建队列并主动拉取消息的模式，既能保证当前场景要求，也能起到背压的处理方式，保证了应用容器运行的负载安全。