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

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

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

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

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

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

RabbitMQ在WOES智能优化节能系统的应用

本文介绍了RabbitMQ在WOES智能优化节能系统中的应用,结合节能系统的特点,描述了消息队列在系统中的作用,提高系统各模块间信息交互效率,速度,还保证了系统数据的准确的和及时性。

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

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

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

针对交通基础设施点位监测数据来源多样、结构各异、协议不一的特点,分析具体接入需求,提出一种基于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是描述事件数据通用格式的规范,提供跨服务、平台和系统的互操作。基于主题和分区将事件路由到不同的服务实例实现分布式并发。事件驱动架构融合微服务和无服务器函数,构建实时、可扩展、高负载和大规模可伸缩的云原生应用软件。

消息传输中间件JWMQ原理和应用

为保障信息交换的可靠性和应用接口的简单性,中间件技术可以为应用提供简单的消息传输接口,并在接口内部实现了断电续传、消息路由、消息转发、传输监控和数据加密等功能。大量的实际应用表明,JWMQ的应用可简化应用实现的复杂性,增强系统的模块化,提高数据传输的可靠性,具有较好的社会和商业应用价值。

基于RabbitMQ技术的气象标准格式数据传输研究

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

基于ARM Cortex-M4的MQX调度的上下文切换机制分析

针对ARM Cortex-M4平台上MQX系统运行调度实现中最关键的任务上下文切换的实现,在对处理器的硬件特性的分析基础上,重点剖析MQX任务调度过程的底层实现方法,从调度指令级别深层次解析SVC调用和Pend SV调用的实现过程,揭示了MQX任务调度上下文切换的实质。实验对比MQX的上下文切换时间大大少于μC/OS-Ⅱ和FreeRTOS,对其高效调度机制的研究工作具有实践意义和应用推广价值。

基于物联网的浮标锚链闭环全生命周期管理辅助决策系统

为提高浮标锚链全链条信息协作能力,设计一种基于消息队列遥测传输(Message Queuing Telemetry Transport,MQTT)的浮标锚链闭环全生命周期管理辅助决策系统。该系统采用前后端分离技术(Nginx消息代理、Redis会话缓存)实现了系统Web应用框架,大幅提升系统的敏捷性、复用性和可维护性。通过在北海航海保障中心营口航标处部署实施,可实时识别记录新型锚链全生命周期信息,实现锚链堆场分布、航道分布、制造商分布等辅助决策支持,提高浮标锚链的智能监管能力与使用效率。

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

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

矢量电子地图在线更新方法研究

以“天地图·浙江”为研究对象,研究矢量电子地图数据的在线更新技术.使用Mapbox矢量瓦片技术提升大规模矢量数据的渲染效率,利用Redis缓存在高存取量方面的优势实现矢量瓦片的高效调度,基于矢量数据节点捕捉技术提高要素在线编辑的效率,利用Rocket MQ消息队列保障多并发环境下的系统稳定性,研发了电子地图在线更新模块.以浙江省某县级市作为试点地区进行要素更新实践,验证了电子地图在线更新技术方法的高效性.

WebSphere MQ在零售业系统数据传输中的应用

结合企业数据通信系统功能等方面的要求,借助消息队列件(WebSphere MQ)技术确保大量商业数据文件的有效传输.以零售企业前、后台日常销售数据传输为例,设计方案并实现了典型零售业系统数据传输功能.

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

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

浅谈消息中间件IBM WebSphere MQ

详细地论述了MQ的基本概念、工作原理、基本配置及其在实际中的应用。

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

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

IBM消息中间件WebSphere MQ的应用

消息中间件为不同应用系统之间的数据交互搭建了安全、稳定、高效的桥梁。IBM WebSphereMQ是一款优秀的消息中间件产品。它基于消息队列的存储转发机制，包括队列管理器、队列、通道、消息等各种对象．在联网核查公民身份信息系统中，通过使用WebSphereMQ．在商业银行和人民银行问建立了双向的实时交易报文和批量交易报文通道，形成了统一的报文交互平台。

基于MSMQ消息通信的研究与实现

MSMQ(MicroSoftMessageQueue,微软消息队列)是在多个不同的应用之间实现相互通信的一种异步传输模式。本文在研究MSMQ机制的基础上,实现了MSMQ服务器、客户端消息异步传送进程和接收进程,以及发布者与订阅者模型。