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

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

2017-07-31 584

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

微信关注我们

原文链接：https://yq.aliyun.com/articles/194476

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

浅谈2016年医疗行业面临的几种安全威胁

2016年伊始，医疗行业就遭遇了多起安全事件，比如洛杉矶医院的勒索软件攻击、德国某医院的勒索软件攻击、病人监护仪和输药管系统的入侵、墨尔本医院的攻击事件等。2016年刚过两个月就发生了如此多起重大安全事件，这是多么可观、又可怕的趋势。近几年，物联网行业势如破竹般的崛起，从安全角度来看，医疗设备行业作为物联网中一个重要组成部分，其安全问题不容小觑。现代的医疗设备都已经互联网化，操作系统、应用程序等全依托在电脑上（65岁的老中医也被迫要学着使用电脑）。这些设备上配置着精密的尖端技术，目的是帮助医生更好的诊断病情。但和其他工业系统一样，这些设备只注重优化医疗方面的技术，而忽略了网络安全方面的东西。程序设计构架漏洞、不安全的授权、未加密的通信信道、软件中的漏洞，这些都可能导致医疗设备被黑客入侵。未授权访问设备会造成很严重的影响：不仅仅是窃取用户重要数据，还会对病人的健康和生命造成重大影响。简简单单就能入侵医院系统，从医疗设备中窃取私人信息，获取设备的访问权限等等，这是多么恐怖的一件事情。想象一个场景，一个真正意义上的目标攻击：一个黑客完全掌控了某医疗设备的控制权限，病情诊断结果和治疗措施...

2017-08-01

628

金融大数据是大数据技术在金融行业的应用，也指在经济和金融活动之中产生的海量数据。金融大数据的应用带动了金融行业的转型，成为了行业新的驱动力和增长模式。金融大数据的行业影响金融大数据在金融行业的应用能有效的帮助金融行业实现信息化转型，使得金融行业整体更为高效。金融大数据的帮助下，金融信息将会以更多的方式呈现。借助大数据可视化技术，结构化和非结构化数据可以从大量的金融信息之中提取出最有用的数据，并且用最合适的方式呈现，让用户可以从更多的角度和价值模型之中获益，帮助用于金融研究以及决策。金融大数据可视化还可以提供经济分析、管理分析以及绩效评估等工具，帮助提高金融体系整体效率。金融大数据将会引领行业走向定制化和智慧化。在人工智能技术发展的情况下，金融行业必须进行智慧转型，这其中技术和数据成为最重要的两点。大数据融入金融行业之后可以引领技术变革，将用户数据、征信数据以及行为数据等结合，利用大数据处理技术进行数据建模，对用户进行精准画像，确定金融活动目标可靠性。在通过机器学习后，让更多用户享受金融大数据带来的变革红利，让定制化金融和智慧金融服务走近每个人。金融大数据可以帮助用户更好的洞察...

2017-08-01

533

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。