基于Message Queue技术的医疗信息交换与共享集成平台研究

对目前医院信息系统集成方式进行了分析,简单介绍了IBM Message Queue的技术特点,通过介绍重症监护系统(ICU系统)和HIS系统之间的集成方案,阐述了基于消息机制构建医疗信息交换与共享集成平台的思路和方法。

基于EJB2.0的Message DrivenBean组件设计与实现

描述JMS的体系结构及EJB2MessageDrivenBean的技术原理,并给出了一个例子来讨论如何在EJB2.0和JMS体系结构上设计和实现MDB组件。

Message-Driven Bean在异步消息传输中的应用

讨论了EJB2.0中Message-Driven Bean的一些新特性和运行机制,通过实例讲述了在构建异步消息传输中Message-Driven Bean的应用,并讨论了它的优势、缺陷,以及与Session Bean的比较。

基于虚拟网关的交通基础设施监测点位数据接入方法

针对交通基础设施点位监测数据来源多样、结构各异、协议不一的特点,分析具体接入需求,提出一种基于Netty架构的交通基础设施监测点位数据接入虚拟网关。阐述网关接入监测点位的配置方法及集群分配策略,定义超文本传输协议(HTTP)、传输控制协议(TCP)、用户数据报协议(UDP)下的数据传输格式,设计一种数据传输消息的编码和校验机制。在真实监测数据样本增强的基础上,利用分布式消息模拟工具对虚拟网关性能进行测试,结果表明,该虚拟网关实现了多点位多协议的交通基础设施监测数据统一接入,每亿条数据接入时间、存储时间分别达到8.14 s和9.75 s,平均数据溯源时间为2.96 s,具有亿级规模点位监测数据的接入能力,可为交通基础设施数字化监测的研究和应用提供理论支撑。

基于DQueue和CCF的消息队列设计要点分析

消息队列作为一种常见的数据结构,在应用程序和软件操作系统中得到了广泛应用,而随着处理器的不断迭代,传统的锁同步消息队列逐渐无法发挥多核处理器的性能。因此,研究人员尝试引入布谷鸟过滤器(Cuckoo Filter,CCF)和DQueue技术对消息队列进行优化升级,创建云开发消息队列(Cloud Development Message Queue,CDMQ)。基于上述两种技术同时生成多个队列写入数据,操作者利用CCF对数据进行过滤检验,并读取相关信息。通过对CDMQ的性能测试,研究人员证明该消息队列结构具有伸缩性强和吞吐量高等优势,对提高消息队列性能具有重要意义。

事件驱动的云原生应用软件研究

事件驱动是云原生应用的主要驱动力,是实时敏捷数字业务的核心。通过侦听物联网设备、移动应用程序、业务网络和用户行为等事件源,捕获业务事件,驱动服务。事件的捕获、通信、转换和持久化是关键,可以扩展、适配不同类型的服务。消息队列是异步的,消息的发送和接收者不需要同时与消息队列交互,减少了服务间的耦合;如果系统请求流量瞬时剧增,消息队列将缓存请求,提高系统的稳定性和用户体验;事件溯源可以回溯到任何一个事件状态,增强系统的可靠性和容错。CloudEvents是描述事件数据通用格式的规范,提供跨服务、平台和系统的互操作。基于主题和分区将事件路由到不同的服务实例实现分布式并发。事件驱动架构融合微服务和无服务器函数,构建实时、可扩展、高负载和大规模可伸缩的云原生应用软件。

一种基于区块链的MQTT协议优化算法

通信协议的设计已然成为实现设备与互联网通信的重要支撑,其覆盖了整个物联网系统的各个环节。针对传统物联网协议中关键数据被伪造或篡改的安全问题,文章设计了一种在数据传输过程中使用区块链技术来保证传输数据安全的改进消息队列遥测传输(message queue telemetry transmission,MQTT)协议,进而保证了存储在broker的数据不被恶意篡改。通过仿真实验证明,该方法具有高效、轻量以及易实现等多方面的特点,在保护物联网的数据安全方面效果十分显著。

基于BIM的智能运维管理监控系统设计与实现

为切实提升生产设备的信息化和智能化水平、提高生产效率和故障诊断能力,设计一套基于BIM的智能运维管理监控系统。系统将多源传感器数据融合,结合BIM技术进行展示,并引入基于专家经验转化的故障诊断技术。该系统已保障某场站安全运行生产200余天,达到很好的预期。同时,系统产生160 GB原始监测数据和专家经验标定结果,为后续引入基于机器学习的故障诊断方法提供原始训练数据支持。

FastQueue:一种高性能的磁盘队列存储管理机制

1.引言 随着消息通信(如消息、短消息)的爆炸式增长,消息传递系统的性能面临严峻的挑战.消息通信的首要特点是高可靠性,在发送人确认消息收到之前必须将消息保存到磁盘上.

基于Spark技术的气象数据分析

近些年来,气象数据规模及复杂性大大增加,这对气象数据的存储、利用及加工分析提出了更高的要求。需采用适当的技术及策略,更好地利用分析气象数据,为天气预报、气候研究及社会公共服务提供更大的价值。通过网络爬虫爬取实时天气数据,发送实时数据到Kafka消息系统中,利用Spark技术从消息队列中获取实时数据并进行数据清洗、转换、归一化、聚合、汇总、分组等操作,实现气象数据的多维度分析,利用Spark计算结果将处理后的数据进行可视化,以图表、图形等形式进行展示。

基于Lua脚本的可动态扩展档案库房环境监控系统

为适应国家信息化建设和档案事业发展的要求,提升档案的信息化、智能化、现代化管理水平。结合现阶段档案管理工作实际,建设智慧保障一体化管理平台。主要监控对象包括:库房温湿度、空气质量、普通空调、加湿除湿净化消毒一体机、漏水、消防、视频监控、红外入侵、门禁等,以保障环境及设备安全高效运行。由于不同终端传感器采用通信协议不同,为了在不停止服务的情况下动态扩展新型终端,使用Lua脚本配合消息队列在实现系统动态扩展性的同时保证吞吐量。

基于国产化软件的博物馆数字化展示空间的设计

利用国产化操作系统、数据库及芯片技术和设备,构建基于国产化软件的博物馆高性能数字化展示空间系统。系统分为基础设施层和应用服务层,基础设施层全部由国产化技术构建;应用服务层使用框架技术进行搭建。服务层的展馆3D智能导览功能利用Unity 3D引擎平台和3DS Max建模技术构建,通过消息队列优化性能。对TPS和RT两个指标进行性能测试,均取得了良好的性能结果,可保证数据及系统的安全可靠。

煤矿机电装备远程监控系统的设计与实现方法

为响应国家智能化矿山的建设要求,满足煤机装备的远程监控、健康状态诊断需求,降低采煤机械生产中的故障停机率,提高设备的运行可靠性和生命周期,设计了一种煤矿机电装备远程监控系统。该系统可实现远程对煤矿采煤装备的实时无线数据通信,并通过远程监控平台系统实现对煤矿机电装备的远程监控管理、健康状态分析诊断。

在线评测平台中的Python程序设计

阐述一个三层架构的在线评测平台构建方法,优化编程作业的提交和评估过程。探讨评测算法的设计,实现基于最小编辑距离的输出验证,以及利用消息队列技术提高算法的并行处理能力。

基于SignalR的卫星遥测数据实时推送系统设计与验证

卫星批量化生产过程中会实时生成各类海量遥测数据,如何将海量遥测数据实时准确地发送至所需位置是保证卫星状态受控的首要前提.针对卫星海量数据实时推送的问题,设计了基于SignalR的卫星遥测数据实时推送系统并完成了验证.该系统采用消息队列+SignalR的模式,可实现测试数据实时推送到各个终端软件.它能够满足百颗星量级同时测试时产生数据的实时推送,并支持各个终端软件订阅不同卫星的不同类型的遥测测试数据.该系统已应用于某批量化生产卫星,可将多颗卫星的实时遥测数据同时推送至1台或多台终端,完成了1人测试并监测1颗卫星模式向1人测试并监测多颗卫星模式的转变,且能够实时动态切换不同卫星遥测数据状态,可支持卫星批量化生产模式.

应用于企业的高效跨系统数据汇聚方案

为了提升大型多层级集团企业在信息化管理中的数据传输效率,建设一个高质量的数据传输系统至关重要。本文提出了一种基于ORM监听器和Kafka的跨系统高效传输方案。通过对象关系映射框架监听器无感地采集业务数据日志,使用Kafka消息队列系统作为消息中间件,为数据高效传输提供保障。实践结果表明,采用该方案构建的系统能够有效满足企业对数据汇聚的需求,同时具备高效、准确、易扩展的特点。

基于ZeroMQ的聚变数据实时发布系统研究

针对等离子体核聚变放电实验中传统数据获取方式的滞后性,设计并实现一套实时数据发布系统,旨在提升实验数据的即时性,支持实验过程中的即时决策与调整。采用分布式架构,通过分布式的诊断数据收集模块实时采集实验数据,并利用高效的通信协议将数据快速传输至中央服务器。服务器根据客户端需求,将处理后的数据实时推送到客户端,实现数据的实时共享与可视化。性能测试结果表明,该系统能实现等离子体核聚变放电实验数据的实时发布,数据传输延迟低于60 s,且兼容Windows、Android等主流操作系统,确保研究人员可随时随地访问实时数据。该实时数据发布系统显著提高了核聚变实验的数据时效性,增强了实验操作的灵活性和安全性,对推动核聚变科学的发展具有重要意义。

一种基于改进MQ协议的船岸信息交互方案

为解决船岸通信带宽不足导致的船岸信息传输受限的问题,提高船岸数据交互效率,提出一种基于改进的消息队列(Messages Queue,MQ)协议的船岸信息交互方案。针对单一通信方式带宽不足和覆盖区域不全的问题,提出多种通信模式自动识别和自动切换的船岸通信方法,并给出不同船舶运营场景下的通信策略;针对船舶系统间数据交互信息量较大,易出现数据处理不及时和丢失的问题,对MQ通信技术进行改进,提出流量削峰技术方案。以某化学品船的船岸一体安全监控系统数据交互为例验证该船岸信息交互方案的可行性,设置网络连接状态模拟不同的通信场景,设置不同的数据传输频率模拟数据传输的带宽压力,结果表明该方案能有效解决数据丢包问题,缓解计算资源压力,提升信息传输效率。

高并发条件下消息队列的设计与实现

针对电商平台商品销售功能存在的消息队列并发量不高、对服务器要求过高、占用系统资源过多等问题,研发设计了一个即时消息列队FineMQ。该消息列队利用中间件的处理能力解决应用解耦,通过消息队列的分流特性使系统在遭遇高并发场景时不会瘫痪,提升了系统的稳定性及安全性,减轻了服务器压力,减少了占用的内存。

基于流式处理架构的日志采集系统的设计与实现

对信息系统运行记录、操作日志、告警信息的采集问题进行了研究,提出了一种面向泛政府行业安全运行管理平台的统一日志采集系统;采用基于消息队列的流式处理架构,实现日志采集、日志处理、日志上报等各个环节的解耦;采用标准化接口和插件技术,实现各种异构日志信息的采集和数据上报;采用消息队列的流量削峰技术,保证日志传输的安全可靠;依据日志流量特征,提出一种支持动态调整消费组的设计模式,达到超过20000条日志/每秒的高性能采集要求;整个系统由日志采集、数据上报、数据管理、系统管理、策略管理、Agent管理、日志源管理模块和日志采集代理(Agent)子系统组成,可满足对各类安全数据的集中分析、安全威胁感知和智能研判。