如何在 JMeter 中使用 MQTT 插件

JMeter 内置 >MQTT协议是广泛应用的物联网协议，使用测试MQTT协议需要MQTT的代理。有两种方法使用MQTT服务，一是租用现成的MQTT服务器，如阿里云，百度云，华为云等公用的云平台提供的MQTT服务，使用公用的MQTT服务器的好处是省事，但如果仅仅用于测试学习还需要注册帐号，灵活性差些，有的平台还需要付费。另一方法是自己使用开源的MQTT组件来搭建。
MQTT服务器非常多，如apache的ActiveMQ，emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。
这里介绍的是用轻量级的mosquitto开源项目来搭建一个属于自己的MQTT服务器。
第一步：需要安装一台linux主机，这不多介绍，可以使用真机安装也可以使用虚拟机安装。如果仅仅是自己测试使用都可以。
第二步：下载mosquitto需要的依赖
sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake
第三步：下载mosquitto并解压，现在mosquitto官网最新的版本是151
tar xzvf mosquitto-151targz
第四步：编译
cd mosquitto-151/
make
make install
第五步：启动mosquitto
/mosquitto -v
1535473957: mosquitto version 151 starting
1535473957: Using default config
1535473957: Opening ipv4 listen socket on port 1883
1535473957: Opening ipv6 listen socket on port 1883
这时候mosquitto就会以默认的参数启动。如果需要带配置文件可以修改配置文件mosquittoconf，
启动时候加上参数 -c，
/mosquitto -c mosquittoconf
可以看到，mosquitto监听的端口为1883
这时候我们的MQTT服务器就搭建好了。可找一个mqtt客户端来测试一下。
先发布一个主题“home/garden/fountain/2”
内容是“hello world”
这时候在mosquitto会打印出下面的log
535474247: New connection from 1921681105 on port 1883
1535474247: New client connected from 1921681105 as MQTT_FX_Client (c1, k60)
1535474247: No will message specified
1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)
1535474307: Received PINGREQ from MQTT_FX_Client
1535474307: Sending PINGRESP to MQTT_FX_Client
1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', (12 bytes))
1535474367: Received PINGREQ from MQTT_FX_Client
1535474367: Sending PINGRESP to MQTT_FX_Client
订阅主题“home/garden/fountain/2”
可以看到收到了自己发布的消息。
用wireshark抓包
可以看到抓到了一个MQTT的publish的报文。

MQTT 最初由 IBM 于上世纪 90 年代晚期发明和开发。它最初的用途是将石油管道上的传感器与卫星相链接。顾名思义，它是一种支持在各方之间异步通信的消息协议。异步消息协议在空间和时间上将消息发送者与接收者分离，因此可以在不可靠的网络环境中进行扩展。虽然叫做消息队列遥测传输，但它与消息队列毫无关系，而是使用了一个发布和订阅的模型。在 2014 年末，它正式成为了一种 OASIS 开放标准，而且在一些流行的编程语言中受到支持（通过使用多种开源实现）。

物联网设备选择MQTT协议的原因分析

物联网 (IoT) 设备必须连接互联网。通过连接到互联网，设备就能相互协作，以及与后端服务协同工作。互联网的基础网络协议是 TCP/IP。MQTT（消息队列遥测传输） 是基于 TCP/IP 协议栈而构建的，已成为 IoT 通信的标准。

MQTT 是一种轻量级的、灵活的网络协议，致力于为 IoT 开发人员实现适当的平衡：

1、这个轻量级协议可在严重受限的设备硬件和高延迟/带宽有限的网络上实现。

2、它的灵活性使得为 IoT 设备和服务的多样化应用场景提供支持成为可能。

SKYLAB有哪几款支持MQTT的IoT UART接口WiFi模块

串口WiFi模块

SKYLAB支持MQTT的IoT UART接口WiFi模块有四款，分别是基于国产TR6260方案的小尺寸低功耗低成本串口WiFi模块LCS6260，基于国产ESP8266方案的小尺寸低功耗低成本串口WiFi模块WG219/WG229，基于国产ESP8285方案的小尺寸低功耗低成本串口WiFi模块WG231

WG219是一款基于ESP8266芯片方案的小尺寸低功耗低成本串口WiFi模块，符合80211b / g / n 无线模块标准，支持UART-WiFi -以太网数据传输。专为移动设备和物联网应用设计，可将用户的物理设备连接到WiFi无线网络上，进行互联网或局域网通信，实现联网功能。

WG229是一款基于ESP8266芯片方案的小尺寸低功耗低成本串口WiFi模块，符合80211b / g / n 无线模块标准，支持UART-WiFi -以太网数据传输。专为移动设备和物联网应用设计，可将用户的物理设备连接到WiFi无线网络上，进行互联网或局域网通信，实现联网功能。另外WG229仅需要通过出串口使用AT指令控制，就能满足大部分的网络功能需求。WG229高性能、低功耗、低成本、支持串口透传等特性，使得WG229在高集成、低功耗自动化和传感器解决方案的理想解决方案，WG229和LCS6260 Pin对Pin兼容，可替代ESP8266方案的ESP-12F。

WG231是一款基于ESP8285芯片方案的小尺寸低功耗低成本串口WiFi模块，符合80211b / g / n 无线模块标准，支持UART-WiFi -以太网数据传输。专为移动设备和物联网应用设计，可将用户的物理设备连接到WiFi无线网络上，进行互联网或局域网通信，实现联网功能。高性能、低功耗、低成本、小尺寸（11010020（mm））支持串口透传等特性，使得WG231在高集成、低功耗自动化和传感器的理想解决方案。

LCS6260是一款基于TR6260国产芯片的小尺寸低功耗低成本串口WiFi模块，符合80211b / g / n 无线模块标准，支持UART-WiFi -以太网数据传输。专为移动设备和物联网应用设计，可将用户的物理设备连接到WiFi无线网络上，进行互联网或局域网通信，实现联网功能。另外LCS6260仅需要通过出串口使用AT指令控制，就能满足大部分的网络功能需求。LCS6260和WG229 Pin对Pin兼容，可替代ESP8266方案的ESP-12F。

针对客户的物联网应用，SKYLAB支持MQTT的IoT UART接口WiFi模块也都是支持对接云端服务的。LCS6260支持对接阿里云、涂鸦云，WG219/WG229/WG231支持对接阿里云。

以原生支持“MQTT协议”切入物联网战场
原生支持MQTT协议成为百度开放云推出的物联网服务一大特点。首先需要解读的是，为什么百度开放云会选择“MQTT协议”？
百度开放云支持的MQTT（Message Queuing Telemetry Transport）是国际物联网标准协议，旨在为低带宽和不稳定的网络环境中的物联网设备提供可靠的网络服务，可以适应各种物联网应用场景。
相对于其它标准协议，MQTT属于轻量级双向消息传输协议，主要优势是开源、可靠、轻巧、简单。MQTT的传输格式非常精小，最小的数据包只有2个比特，且无应用消息头。MQTT可以保证消息的可靠性，它包括三种不同的服务质量（最多只传一次、最少被传一次、一次且只传一次），如果客户端意外掉线，可以使用“遗愿”发布一条消息，同时支持持久订阅。
MQTT在物联网应用中的主要优势有：一，可靠传输。MQTT可以保证消息可靠安全的传输，并可以与企业应用简易集成；二，消息推送。支持消息实时通知、丰富的推送内容、灵活的Pub-Sub以及消息存储和过滤。三，低带宽、低耗能、低成本。占用移动应用程序带宽小，并且带宽利用率高，耗电量较少。
MQTT的优势还表现在安全性。安全设计对于物联网项目而言，是需要非常重视的问题，但是却常常容易被工程师所轻视。今年央视315晚会，揭秘了无人机、智能摄像头、智能POS机、智能汽车、洗衣机、电烤箱、智能插座等智能家居存在的三大安全隐患——泄露隐私、财产损失、甚至危及生命安全。而MQTT协议则可以提供多层次的安全特性，在传输层上可以使用TLS加密；在应用层提供了客户标识（Client Identifier）以及用户名密码，不但传输的内容是二进制字节，而且还受惠于传输层的TLS加密。
MQTT开放协议已有17年历史，先期在2014年被国际标准化组织定义为物联网的推荐协议。在应用层传输协议这个领域，它已经走在了其它协议的前面。正因为MQTT的综合优势非常突显，业界不少专家认为，MQTT非常适合各种物联网场景，有望是未来最主流的物联网标准协议。
原生支持“MQTT协议”背后旨在推动物联网标准化
接下来的问题是，那么为什么百度开放云要在国内率先成为原生支持MQTT协议的公有云服务商？
在笔者看来，首先，这和百度开放云在物联网行业的核心目标有着紧密的关系。在去年的“百度世界2015”开放云论坛上,百度开放云高层曾对物联网的发展战略做出阐述，指出：打破行业与行业之间的界限，以“连接人与服务”为核

java mqtt是什么，让我们一起了解一下？

MQTT是一个基于客户端-服务器的消息发布或订阅传输协议，MQTT协议是轻量、简单、开放和易于实现的，如果工作在TCP或IP协议上，是为硬件性能低下的远程设备以及网络状况糟糕的情况下而设计的发布或订阅型的消息协议。

MQTT主要应用在哪些场合？

1、它是一种机器之间通讯 machine-to-machine (M2M)、物联网 Internet of Things （IoT）常用的一种轻量级消息传输协议。

2、适用于网络带宽较低的场合。
3、包含发布、订阅模式，通过一个代理服务器（broker），任何一个客户端（client）都可以订阅或者发布某个主题的消息，然后订阅了该主题的客户端则会收到该消息。

实战 *** 作：模拟客户端接收消息。 import javautilconcurrentScheduledExecutorService; import orgeclipsepahoclientmqttv3MqttClient; import orgeclipsepahoclientmqttv3MqttConnectOptions; import orgeclipsepahoclientmqttv3MqttTopic; import orgeclipsepahoclientmqttv3persistMemoryPersistence;   /   模拟一个客户端接收消息     @author Unclue_liu  / public class ClientMQTT {       public static final String HOST = "tcp://192168177:1883";     public static final String TOPIC1 = "pos_message_all";     private static final String clientid = "12345678";     private MqttClient client;     private MqttConnectOptions options;     private String userName = "mqtt";    //非必须     private String passWord = "mqtt";  //非必须     private ScheduledExecutorService scheduler;       private void start() {         try {             // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存             client = new MqttClient(HOST, clientid, new MemoryPersistence());             // MQTT的连接设置             options = new MqttConnectOptions();             // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，设置为true表示每次连接到服务器都以新的身份连接             optionssetCleanSession(false);             // 设置连接的用户名             optionssetUserName(userName);             // 设置连接的密码             optionssetPassword(passWordtoCharArray());             // 设置超时时间 单位为秒             optionssetConnectionTimeout(10);             // 设置会话心跳时间 单位为秒 服务器会每隔1520秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制             optionssetKeepAliveInterval(20);             //设置断开后重新连接             optionssetAutomaticReconnect(true);             // 设置回调             clientsetCallback(new PushCallback());             MqttTopic topic = clientgetTopic(TOPIC1);             //setWill方法，如果项目中需要知道客户端是否掉线可以调用该方法。设置最终端口的通知消息             //遗嘱             optionssetWill(topic, "close"getBytes(), 1, true);             clientconnect(options);             //订阅消息             int[] Qos = {1};//0：最多一次 、1：最少一次 、2：只有一次             String[] topic1 = {TOPIC1};             clientsubscribe(topic1, Qos);           } catch (Exception e) {             eprintStackTrace();         }     }       public static void main(String[] args)  {         ClientMQTT client = new ClientMQTT();         clientstart();       }

问题1：工业物联网是什么？

简单来说，就是物联网在工业控制上的具体应用。

问题2：SSL/TLS是什么？

SSL(Secure Sockets Layer 安全套接层),及其继任者传输层安全（Transport Layer Security，TLS）是为网络通信提供安全及数据完整性的一种 安全协议 。TLS与SSL在传输层对网络连接进行加密。大部分互联网登录都是用的SSL/TLS，可以去网易邮箱>MQTT 协议 因为其轻量、灵活等特点成为了当今世界上最受欢迎的物联网协议，它已经广泛应用于车联网、智能家居、物流、即时聊天应用和移动消息推送等领域，连接了数以亿计的设备，并且每时每刻都有无数设备开始使用和接入 MQTT 协议。MQTT 协议为这些设备提供了稳定、可靠的通信基础，这些设备庞大的接入数量也向 MQTT 协议规范提出了挑战， MQTT 50 的诞生便是为了更好地满足这一需求。

MQTT（消息队列遥测传输）最初由 IBM 于上世纪 90 年代晚期发明。它最初的用途是将石油管道上的传感器与卫星相链接，所以 MQTT 从诞生之初就是专为受限设备和低带宽、高延迟或不可靠的网络而设计，它使用了发布订阅模型，在空间和时间上解耦了消息的发送者与接收者，并且基于 TCP/IP 提供稳定可靠的网络连接，拥有非常轻量的报头以减少传输开销，支持可靠消息传输，可以说天生就满足了物联网场景的各种需求。在 MQTT 311 发布并成为 OASIS 标准的四年后，MQTT 50 正式发布，这是一次重大的改进和升级，它的目的不仅仅是满足现阶段的行业需求，更是为行业未来的发展变化做了充足的准备。2019 年 3 月，MQTT 50 成为了新的 OASIS 标准。

面对迅速增长的设备数量和层出不穷的需求，OASIS MQTT 技术委员会需要从繁杂的需求中提取出通用部分，将其纳入标准规范，并且尽可能不增加开销或降低易用性，在不增加不必要的复杂性的前提下提高性能和易用性。

最终，OASIS MQTT 技术委员会为 MQTT 50 添加了大量的全新功能与特性，50 成为 MQTT 有史以来变化最大的一个版本。在这里，我们将列举一些比较重要的特性：

完整的新属性列表包含在协议标准的附录C，您可以访问以下网址了解详情： >

MQTT协议是Message Queuing Telemetry Transport的缩写，中文名叫作消息队列遥测传输。是一个即时通讯协议，该协议支持所有平台，可以当作传感器来使用，举个例子，你仅仅在家通过此协议制造一个“传感器”，家里有医疗设备和装置并且安上了无线发射器，这样很适合那些有旧疾而且需要定期检查的病人们，在家就可以用设备自我检查之后通过无线MQTT协议将检查结果发送给负责你的医生，医生可以随时查看你的健康状况，并给出合理的建议，这样极大地方便了用户和医生的交流，非常便利。所以在推送信息和快速即时方面MQTT协议发展前景很是可观。

而TCP协议是学过计算机的人都比较熟悉的协议，分了四层，面向连接又可靠，可以用于文件传输、远程登陆、发送邮件等，但传输速度较慢，要求也比较多。这两个协议中大多数人都会推荐MQTT协议，因为MQTT是建立在TCP基础之上的，光实时性这一点就符合许多人的要求，现在信息高速时代大家要的第一点就是快速，让生活方便，并且比TCP有过之而无不及。

我也相信在未来MQTT协议会出现在我们的生活各个方面，这样灵活便捷的协议如果我们很好地利用，对我们信息技术的发展一定有着很大的帮助，这也是移动互联网发展的特色了吧。其实也不能绝对性地说MQTT比TCP好，只能说它功能更加全面，适应时代发展的要求，所以推荐选择它。

现在MQTT协议国内外也在逐渐应用，相信它会发展得越来越好的。

---