【原创】MQTT开发笔记（四）- 压力测试_Java

一、前言

jmeter 是 apache 公司基于 java 开发的一款开源压力测试工具，体积小，功能全，使用方便，是一个比较轻量级的测试工具，使用起来非常简单。因为 jmeter 是 java 开发的，所以运行的时候必须先要安装 jdk 才可以。jmeter 是免安装的，拿到安装包之后直接解压就可以使用，同时它在 linux/windows/macos 上都可以使用。
jmeter 可以做接口测试和压力测试。其中接口测试的简单操作包括做 http 脚本（发 get/post 请求、加 cookie、加 header、加权限认证、上传文件）、做 webservice 脚本、参数化、断言、关联（正则表达式提取器和处理 json-json path extractor）和 jmeter 操作数据库等等。

二、安装

1、下载 jmeter & 解压

官网地址：apache jmeter - download apache jmeter

jmeter压测工具使用手册（完整版）

2、配置 jmeter 环境变量

注意是系统变量表里直接添加，而不是用户环境变量，也不是在path中。
按下面变量名和变量值配置 jmeter 系统环境变量：

变量名1 ：jmeter_home
变量名1值 ：d:\program files\jmeter\apache-jmeter-4.0（jmeter 解压路径）
变量名2 ：classpath
变量名2值 ：% jmeter_home\lib\ext\apachejmeter_core.jar;% jmeter_home%\lib\jorphan.jar;% jmeter_home%\lib\logkit-2.0.jar;

3、安装mqtt插件

jmeter中不包含mqtt的测试，要单独安装一个mqtt插件。

3.1、从 github 上下载最新版本插件 mqtt-xmeter-2.0.2-jar-with-dependencies.jar，该插件支持 jmeter 3.2 及以上版本。

地址：https://github.com/emqx/mqtt-jmeter/releases

3.2、将插件 jar 包拷贝到 jmeter 的插件目录：/lib/ext

4. 启动

jmeter 解压路径下bin中的 jmeter.bat

三、使用

关于使用，网上有很多链接，讲的很全面，这里就不赘述了，主要参考：

jmeter 压测工具使用手册（完整版） | server 运维论坛

jmeter之mqtt请求_jmeter mqtt-csdn博客

四、测试思路和解决方法

1. 控制器和配置

在负载压力测试中，尽量连接和断开一次，使用“仅一次控制器”，把线程数和负载长度作为主要参数进行考核。

2. java堆栈空间不够用

java: java.lang.outofmemoryerror: java heap space

是由于线程过多或者payload负载过大导致jvm虚拟机内存不够用，解决办法就是增加虚拟机内存。右键用记事本打开 jmeter.bat，修改-xms1g -xmx4g中的数字值，他们分别代表最小和最大值为1gb~4gb，当然你也可以改小为m（兆）的单位，这要根据你的需求来。以下是我的设置：

3. 执行效率

gui界面是用来配置工程和debug用的，他很耗资源，因此一旦配置好后，还是采用控制台执行测试比较贴合实际，通过以下命令就可以简单启动测试：

jmeter -n -t xxxxx.jmx

4. 状态异常

测试中控制台的上述异常是mqtt-xmeter插件的线程池异常，不代表测试失败，不用管它，他会重新启动。我们只需要在控制台注意查看测试信息中的err：是否为0%就好了。再用一个客户端去订阅测试中的topic，看看是否能够接到数据，能接到说明测试没有中止。

贴个mqtt客户端的python代码给你：

pip install paho-mqtt

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("connected with result code " + str(rc))
    client.subscribe("test_topic", qos=1)

def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))

client = mqtt.client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("xx.xx.xx.xx", 1883, 60)

client.loop_forever()