物联网环境下的大吞吐量下消息服务集群设计

简介:

1、基于IBM MQ产品来实施JMS技术的消息服务应用服务器。

2、物联网消息采用MQTT协议,WebSphere MQ Telemetry Transport (MQTT) 是一项专为受限设备和受限网络设计的异步消息通信协议,以轻量、精简、开放和易于实现为主要特点。

3、MQTT 规范是开放并且免版税使用的,这有助于更好地推广。提供开源的实现,在 http://eclipse.org/paho/上有各种客户端的开源实现

4、发布 - 订阅的消息通信协议,允许一条消息只发布一次,便可被多个消费端(应用程序 / 设备)所接收

5、提供多种消息服务质量,包括 MQ 的黄金准则 -- 保证传递且仅有一次传递

0 :消息最多被传递一次

1 :消息会被传递但可能会重复传递

2 :消息保证传递且仅有一次传递

6、为受限的设备所设计 :

预期客户端应用程序 / 设备有可能仅具备非常有限的处理能力和资源

占用空间极小的 MQTT 客户端 ( 和服务器 ) 类库

7、易于使用(和实现)

简单的动词集合,包括 connect, publish, subscribe 和 disconnect

内建结构支持处理客户端和服务器之间的连接丢失

如果客户端意外掉线,使用“遗愿和遗嘱”发布一条消息

8、WebSphere MQ Telemetry 由 Telemetry 服务和 Telemetry 客户端组成。其中 Telemetry 服务作为 Queue Manager 的一部分,可作为 MQTT 连接的服务器,Telemetry 客户端可用来测试 MQTT 连接的可用性。

9、在传统的开放平台 WebSphere MQ 应用架构中,每个队列管理器都是独立的。当一个 QM 给另一个 QM 发送消息时,需要定义一个传输队列(transmission queue), 一个连接到目的端 QM 的通道,并且需要在发送消息的客户端上定义远程队列定义(remote queue definition)。为了简化 MQ 系统配置,可以通过 MQ 集群的使用,减少队列管理器上的对象数量,使得不同的 QM 可以互相通信而不需要定义众多的传输队列、通道以及远程队列定义。当集群中含有一个以上的同一队列实例时,WebSphere® MQ 会根据负载均衡算法选择最佳的队列进行消息路由。

10、MQ 集群中的完全存储仓库存储集群中队列管理器的元数据信息,一个集群不建议使用超过两个完全存储仓库

11、完全存储仓库建议不做业务应用,具体业务应用使用不完全存储仓库

12、在 MQ 集群中使用 MQTT Telemetry 服务时,只需要在集群中建立集群主题(Cluster Topic),并且只需要在集群中的一个队列管理器创建,不需要创建共享队列,默认使用 SYSTEM.MQTT.TRANSMIT.QUEUE

13、使用 MQ Telemetry 不需要手动创建订阅对象(Subscriptions),MQXR 服务默认使用 client ID :topic string 为名字自动创建订阅对象

14、完整的MQTT协议规范pdf下载:http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/MQTT_V3.1_Protocol_Specific.pdf

15、 java -Xms50M -Xmx50M -Djava.ext.dirs=/root/mq/lib -cp mqttperf.jar SingleTopicSub -b 9.119.154.235 -c 1000 -m 50000 -t TestTopic -s 1 即一共创建了 1000 个订阅者,无差错情况下会接收到 50000 条消息。命令中参数 -Xms 指程序的初始化内存大小,-Xmx 指程序占用的最大内存,-Djava.ext.dirs 指引用包路径,该路径文件夹中应该包含有 org.eclipse.paho.client.mqttv3.jar。注意:其中 -m 参数主要用来标记所有客户端应该收到的消息总数,其值为所有客户端数与发布程序发布的消息数之乘积,用来和实际接收到的消息总数做比较,判断所有消息是否被可靠传输。


作者:jaminwm

来源:51CTO

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
相关文章
|
4月前
|
传感器 数据采集 存储
物联网技术在智能环境监测中的部署与优化
物联网技术在智能环境监测中的部署与优化
|
4月前
|
传感器 物联网 数据安全/隐私保护
智慧城市中的环境监测:物联网的角色
【6月更文挑战第6天】智慧城市中的物联网技术在环境监测中发挥关键作用,如路灯上的传感器实时监测空气质量和气候,智能垃圾桶自动检测垃圾容量。物联网使环境监测更全面、精准,但需解决数据安全、设备可靠性和标准统一等问题。随着科技发展,未来智慧城市将因物联网变得更加绿色宜居,环境监测将与城市各领域深度融合。我们期待科技带来的惊喜变革,为建设美好城市努力。
78 2
|
5月前
|
Kubernetes 物联网 区块链
未来技术的脉动:区块链、物联网和虚拟现实的新纪元Kubernetes 集群性能优化实践
【5月更文挑战第27天】 随着科技的飞速发展,新兴技术如区块链、物联网(IoT)和虚拟现实(VR)正在重塑我们的世界。这些技术不仅在逐步成熟,而且在各个行业中找到了创新的应用。区块链技术以其不可篡改和去中心化的特性,为金融交易、供应链管理和身份验证提供了新的解决方案。物联网通过智能设备和系统的互联互通,优化了资源管理并提升了生活品质。而虚拟现实技术则在娱乐、教育和医疗等领域创造了沉浸式体验。本文将深入探讨这些技术的发展趋势和多样化应用场景,展望它们如何共同塑造未来社会的面貌。
|
传感器 数据采集 编解码
基于STM32的物联网环境监测系统
基于STM32的物联网环境监测系统
430 0
基于STM32的物联网环境监测系统
|
数据采集 传感器 监控
【工业物联网基础】现代企业环境中的DCS(分布式控制系统)和SCADA(站点控制和数据采集)
【工业物联网基础】现代企业环境中的DCS(分布式控制系统)和SCADA(站点控制和数据采集)
|
弹性计算 小程序 数据挖掘
从零开始搭建物联网平台(二)环境准备
从零开始搭建物联网平台(二)环境准备
314 0
|
传感器 存储 安全
IFIT2022-智能城市环境中的医疗物联网:基于量子同态加密的医疗成像架构
随着医疗互联网的不断壮大,越来越多的数据在医疗互联网中生成,保护医疗数据的隐私性与安全性越来越重要。量子计算作为能够高效破解基于质因数分解的经典密码技术备受瞩目,因此未来一定是以量子技术为安全基础的高性能计算时代。现正处于经典计算到量子计算的过渡阶段,该阶段下如何将经典算法与量子算法进行有机结合进而提高效率与安全性一直是一个开放型的课题。本文基于上述背景,提出了一个基于量子同态加密的安全云框架,该框架将量子计算与同态加密结合从而构建了一个安全且高效的云环境。该系统基于量子特性与同态密码的理论进行设计,它们的具体实现存在困难,希望能为以后研究者们的持续研究做出引导思路的贡献。
215 0
|
SQL 存储 分布式计算
助力工业物联网,工业大数据项目介绍及环境构建【一】
第一产业:植业、林业、畜牧业、水产养殖业等直接以自然物为生产对象的产业;第二产业:工业、建筑业;第三产业:交通运输业、通讯产业、商业、餐饮业、金融业、教育产业
314 0
助力工业物联网,工业大数据项目介绍及环境构建【一】
|
物联网 Android开发
Android物联网应用程序开发(智慧城市)—— 环境状态值范围设置界面开发
Android物联网应用程序开发(智慧城市)—— 环境状态值范围设置界面开发
348 0
Android物联网应用程序开发(智慧城市)—— 环境状态值范围设置界面开发
|
存储 SQL 监控
基于 IoT物联网 + 表格存储DB + DataV 搭建实时环境监控大屏
基于 IoT物联网 + 表格存储DB + DataV 搭建实时环境监控大屏
2346 0

相关产品

  • 物联网平台