文章目录
- MQTT概念
- Jmeter压测MQTT
- MQTT服务器
- 下载Jmeter MQTT插件
- 测试MQTT
- 测试思路和解决方法
MQTT概念
MQTT是什么
MQTT是用于物联网（IoT）的OASIS标准消息传递协议。它被设计为一种非常轻量级的发布/订阅消息传输，非常适合使用较少的代码占用和最小的网络带宽连接远程设备。如今，MQTT已广泛应用于汽车、制造业、电信、石油和天然气等行业。
官网：https://mqtt.org/
MQTT原理
MQTT架构
举例：温度传感器（client）采集温度，发布主题为【温度】，内容为24摄氏度的报文，代理/服务器（broker）根据订阅规则，对订阅主题为【温度】的client进行分发。
MQTT特性：
（1）发布者和订阅者不用了解彼此
（2）发布者和订阅者不直接建立联系
（3）发布者和订阅者不用同时在线，非请求/应答模式
- 建立连接
第一步：client向broker发送CONNECT报文。
第二步：broker向client发送CONNACK报文。
- 发布主题client–>broker
- 订阅主题client–>broker
- 订阅确认broker–>client
QoS
QoS用于告知物联网系统，哪些信息是重要信息，需要准确无误的传输，邮些信息不那么重要，丢失也没有问题。
QoS=0，只负责发送，不负责检查消息是否被收到。占用网络资源低，适合传输不重要的信息。
QoS=1，发送端发送完成后，检查接收端是否已经成功收到了信息，要确认。占用网络资源中，建议便用。
QoS=2，发送端发送完成后，检查接收端是否已经成功收到了信息，收到确认，再次发送询间（你确定收到了吗？），等待二次回复，实现二次确认。占用网络资源多，适合传输重要信息。
Jmeter压测MQTT
MQTT服务器
- 下载EMQX：
docker pull emqx:5.3.2 - 启动容器：
docker run -d --name emqx -p 18083:18083 -p 1883:1883 emqx:5.3.2（1883是MQTT端口，18083是管理端端口） - 进入管理端：http://x.x.x:18083，默认admin/public
下载Jmeter MQTT插件
- 下载MQTT插件：https://jmeter-plugins.org/
- jar下载好后，拷贝到jmeter目录下的lib\ext目录下，重启jmeter
注意事项：
（1）发布主题
发布的主题没有订阅，发布不成功。https://www.emqx.com/zh/blog/mqtt-5-introduction-to-publish-subscribe-model
（2）会话
3.1 Clean Session=5.0 Clean Start +Session Expiry Interval
https://www.emqx.com/zh/blog/mqtt5-new-feature-clean-start-and-session-expiry-interval
jmeter里Clean Session为false，会话会保留，方便复用
jmeter里Clean Session为true，连接断开后，emqx看不到会话记录
（3）保留信息
retained messages为true，broker会保留信息，订阅取样器发送请求可以获取信息
retained messages为false，broker不会保留信息，订阅取样器发送请求无法获服信息
测试MQTT
- 连接和释放
MQTT Connect取样器发起连接后，EMQX有连接的会话。
添加MQTT DisConnect取样器，再次发起连接，EMQX没有多余的连接。
因为在MQTT3.1.1中连接参数Clean session设置为true，等同于在MQTT5.0中将Clean Start设置为1，并且将Session Expiry Interval设置为0，即会话的生命周期与网络连接保持一致。（此时连接已断开，会话终止）
如果在MQTT3.1.1中Clean session设置为false，等同于在MQTT5.0中将Clean Start设置0，并且将Session Expiry Interval设置为OxFFFFFFFF，即会话永不过期。但是为了节省资源，EMQX会额外限制2小时。加上MQTT DisConnect，会话断开，但是会保留会话记录，方便复用。
- 发布和订阅
测试发布和订阅之前，禁用MQTT DisConnect取样器。（如果没有禁用，EMQX看不到订阅主题的任何数据，没有订阅，主题就会被丢弃）
MQTT Pub Sampler发布主题（MQTT Sub Sampler没有使用）
EMQX没有看到主题，原因：如果不存在任何订阅，那么消息会被丢弃。
添加MQTT Sub Sampler后，再次发起主题。EMQX看到主题和订阅。
PS:- EMQX会针对已经订阅主题并且处于连接状态的客户端进行分发。
- EMQX一般情况不保存消息。
- 客户端一发布主题，EMQX就转发；客户端一订阅主题，EMQX就转发（需要MQTT Pub Sampler
Retained message为true）
测试思路和解决方法
- 控制器和配置
在负载压力侧试中，尽量连接和断开一次，使用 “仅一次控制器” ，把线程数和负载长度作为主要参数进行考核。 - Java堆栈空间不够用
java: java.lang.OutofMemoryError: Java heap space
是由于线程过多或者Payload负载过大导致JVM虚拟机内存不够用，解决办法就是增加虚拟机内存。右键用记事本打开jmeter.bat，修改-Xms1g-Xmx4g中的数字值，他们分别代表最小和最大值为1GB~4GB，当然你也可以改小为m（兆）的单位，这要根据你的需求来。以下是我的设置：set HEAP=-Xms1g -Xmx4g -XX:MaxMetaspaceSize=256m - 执行效率
GUI界面是用来配置工程和Debug用的，他很耗资源，因此一旦配置好后，还是采用控制台执行测试比较贴合实际，通过以下命令就可以简单启动测试：jmeter -n -t xxxxx.jmx - 状态异常
java.lang.IllegalStateException: Current state = RESET, new state = FLUSHED
测试中控制台的上述异常是mqtt-xmeter插件的线程池异常，不代表测试失败，不用管它，他会重新启动。我们只需要在控制台注意查看测试信息中的Err：是否为0%就好了。再用一个客户端去订阅测试中的Topic，看看是否能够接到数据，能接到说明测试没有中止。
