Jmeter对RabbitMQ压力测试

1. 安装jmeter安装包

1. 下载jmeter

链接：Apache JMeter - Download Apache JMeter

1. 解压jmeter压缩包

apache-jmeter-5.5.zip

1. JMeter环境变量配置

1. 找到 此电脑右键-【属性】-【高级系统设置】-【环境变量】

1. 新建系统变量 JMETER_HOME

变量名：JMETER_HOME

变量值：jmeter的安装路径。例如：D:\下载的软件\Jmeter\apache-jmeter-5.5

1. 编辑变量名 Path

新增环境变量：

%JMETER_HOME%\bin

1. 安装jdk

1. 下载地址

https://www.oracle.com/java/technologies/downloads/#jdk18-windows

1. 解压安装jdk压缩包

1. 新建一个文件夹用于安装jdk，新建的文件夹名字最好是全英文；否则安装过程中可能会出现安装失败的情况

1. 按照安装向导一步步往下走

1. Jdk环境变量配置

1. 找到 此电脑右键-【属性】-【高级系统设置】-【环境变量】

1. 新建系统变量 JAVA_HOME

变量名：JAVA_HOME

变量值：jdk的安装路径。例如：D:\Tools\JDK

1. 新建系统变量 CLASSPATH

变量名：CLASSPATH

变量值：

.;%JAVA_HOME%\lib;%JAVA_HOME%\lib\tools.jar;

1. 编辑变量名 Path

新增环境变量：

%JAVA_HOME%\bin

%JAVA_HOME%\jre\bin

1. 检验是否配置成功

打开命令提示符，输入 java -version

展示以下内容即为配置成功

1. 安装AMQP插件

1. 下载地址

GitHub - jlavallee/JMeter-Rabbit-AMQP: A JMeter plugin to publish & consume messages from RabbitMQ or any AMQP message broker

1. 解压AMQP插件

1. 电脑安装apache-ant

1. 下载地址

https://dlcdn.apache.org//ant/binaries/apache-ant-1.9.16-bin.zip

1. 解压apache-ant安装包

1. apache-ant配置环境变量

1. 下载 RabbitMQ客户端插件amqp-client-3.4.4.jar

1. 下载地址

https://repo1.maven.org/maven2/com/rabbitmq/amqp-client/3.4.4/amqp-client-3.4.4.jar

1. 修改配置文件

1. 修改AMQP插件源码里的build.xml，http改成https

1. 修改build.xml里面ivy.install.version，2.3.0改成2.5.0

1. 打包生成JMeterAMQP.jar

直接在AMQP插件所在目录，执行ant命令即可

1. 插件复制插件到jmeter目录

1. 把上面下载的amqp-client-3.4.4.jar复制到jmeter安装目录的lib\ext目录下

1. 把AMQP插件源码目录下target\dist目录下的JMeterAMQP.jar也复制到lib\ext目录下

1. 启动jmeter的时候就出现rabbitmq测试的取样器

• jmeter对rabbitmq进行性能测试
  1. 新建线程组

  

  1. 新建AMQP Publisher

  

  

  1. 新建AMQP Consumer

  

  1. 启动查看结果树

  

  1. 启动聚合报告

  

  1. 查看rabbitmq控制台

  

  • 脚本文件

    将下述文件的内容保存到一个rabbitmq.jmx，打开后修改rabbitmq的主机配置以及账号密码

    
    
      
        
          
          false
          true
          
            
          
          
        
        
          
            stoptest
            
              false
              1
            
            2
            10
            false
            10
            
            true
          
          
            
              
                hostname
                port
                username
                password
                queuename
              
              
                
                  1.1.2.2
                  3xxx
                  defauweR0
                  8gG558p1_H-Jz9L
                  zytest-1
                
              
              false
            
            
            
              true
              1
            
            
              
                zyjmeterExchange
                true
                true
                false
                zytest-1
                zytest-1
                /
                
                
                direct
                true
                false
                false
                false
                5000
                1
                10.10.21.29
                3214
                default_user_fZzFDUx3r-0As9gFfOl
                4hYbpm_if3KK0RuMV42tTrfSoYZOvL5U
                false
                false
                false
                zytest-1
                hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.hello,rabbitmq.helo
                
                
                
                text/plain 
                
                
                  
                
              
              
            
            
              zyjmeterExchange
              true
              true
              false
              zytest-1
              zytest-1
              /
              
              
              direct
              true
              false
              false
              false
              1000
              100
              ${hostname}
              ${port}
              ${username}
              ${password}
              false
              true
              0
              
              false
              true
              false
            
            
            
              false
              
                saveConfig
                
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  false
                  true
                  true
                  false
                  false
                  false
                  true
                  false
                  false
                  false
                  true
                  0
                  true
                  true
                  true
                  true
                  true
                  true
                
              
              
            
            
            
              false
              
                saveConfig
                
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  true
                  false
                  true
                  true
                  false
                  false
                  false
                  true
                  false
                  false
                  false
                  true
                  0
                  true
                  true
                  true
                  true
                  true
                  true
                
              
              
            
            
          
        
      
    

    • 参数说明
      1. AMQP Publisher参数说明

      

      1. 采样器的名称和备注。这是JMeter所有采样器的属性，用来进行线程组的采样管理。建议取有意义的名字。
      2. 交换机信息。如果需要发送的MQ消息是以交换机的方式进行消息传递，需要配置。如果不需要则配置“Exchange”属性为空即可。具体的属性含义如下。

      Exchange：交换机名称，默认为jmeterExchange。RabbitMQ消息传递通过交换机或队列模型进行，需要根据实际系统定义情况进行配置。

      Exchange Type：交换机类型，规定了消息的路由策略，根据实际的消息交换机类型进行配置，可选为direct,topic,headers,fanout。

      Durable?：交换机的持久化属性。持久化队列和非持久化队列的区别是，持久化队列会被保存在磁盘中，固定并持久的存储，当服务重启后，该队列会保持原来的状态在RabbitMQ中被管理，而非持久化队列不会被保存在磁盘中，服务重启后队列就会消失。

      Auto Delete?：交换机的自动删除属性。如果该交换机没有任何订阅的消费者的话，该交换机会被自动删除。这种队列适用于临时队列。

      Redeclare?：该交换机是否可以重新声明。当声明的交换机Durable?或者Auto Delete?与已经存在交换机不一致，会出现类似如下错误：

      Caused by:com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method(reply-code=406,reply-text=PRECONDITION_FAILED - inequivalent arg 'durable' for exchange'jmeterExchange' in vhost '/': received 'false' butcurrent is 'true', class-id=40, method-id=10)

      所以AMQP插件增加了重新声明属性，当交换机声明与已经存在的不一致时，如果勾选了可重新声明，会将原交换机删除，重新定义一个新的。

      3、队列信息。如果需要发送的MQ消息是以队列的方式进行消息传递，需要配置。如果不需要则配置“Queue”属性为空即可。具体的属性含义如下。

      Queue：队列名称，默认为jmeterQueue。

      Routing Key：队列的路由关键字，通过路由关键字的设定，可以完成多个消息统一处理的需求。对于队列的方式，需要与队列名称一致。

      Durable?、Auto Delete?、Redeclare?属性的作用与交换机类似。

      Exclusive?：队列的排他性属性。如果想创建一个只有自己可见的队列，即不允许其它用户访问，可以将一个Queue声明成为排他性的（Exclusive Queue）。

      Message TTL：Time-To-Live，消息过期时间，单位为毫秒。

      Expires：队列的超期时间，单位为毫秒。该值必须为正数(与消息 TTL 不同，该值不可以为 0)，所以如果该参数设置为 1000 ，则表示该队列如果在 1 秒钟之内未被使用则会被删除。

      4、RabbitMQ服务信息。RabbitMQ服务的连接信息。具体包括如下属性。

      Virtual HOST：使用的RabbitMQ服务虚拟主机信息。通过虚拟主机可以在服务器上划分多个虚拟空间，起到消息隔离的作用，默认为根目录“/”。

      Host：RabbitMQ服务所在主机IP或名称，使用名称时需要保证DNS正确性。

      Port：RabbitMQ服务所在端口，默认为5672。

      Username：使用RabbitMQ服务的用户名。

      Password：使用RabbitMQ服务的密码。

      Timeout：连接RabbitMQ服务的超时时间，单位为毫秒。

      

      1、发送消息条数。Number ofsamples to Aggregate表示AMQP采样器工作一次发送几条消息。

      2、消息属性。具体包括如下信息。

      Persistent?：消息的持久化属性。设置了持久化的消息，即使当时Consumer没有在监听，等Consumer启动后也能够收到该消息。反之，如果当时Consumer没有监听，则无法获取消息。

      Use Transactions？:是否将发送消息通道设置为事务模式。事务能够解决Publisher与消息服务之间消息确认的问题，只有消息成功被服务接受，事务提交才能成功，否则我们便可以在捕获异常进行事务回滚操作同时进行消息重发，但是使用事务机制的话会降低RabbitMQ的性能。

      Routing Key：消息的路由关键字。队列方式需要与队列名称一致，交换机方式根据实际需求设定。

      Message Type：消息类型属性。可以自定义消息的类型，如String,Object等。

      Reply-To Queue：用于指定回复的队列的名称。该属性是业务流程的需要，不会自动创建指定的回复队列。

      Correlation Id：消息的关联ID。当存在多个计算节点时，通过该属性是的每个线程确定收到的消息与该线程对应。

      ContentType：消息扩展类型。与HTTP中的相同字段意义一致，可以是text/plain，JSON等。

      Message Id：消息的ID。通过设定消息ID，完成业务上的某些需求。

      3、消息头信息。Key-value格式设置头信息，可以是任意的进行业务逻辑的数据。

      1. 消息体。实际发送的消息内容，可以通过增加字符的方式修改消息体内容大小（1kb，10kb，50kb，100kb）
      1. AMQP Consumer参数说明

      

      1. 采样器的名称和备注。这是JMeter所有采样器的属性，用来进行线程组的采样管理。建议取有意义的名字。
      2. 交换机信息。如果需要发送的MQ消息是以交换机的方式进行消息传递，需要配置。如果不需要则配置“Exchange”属性为空即可。具体的属性含义如下。

      Exchange：交换机名称，默认为jmeterExchange。RabbitMQ消息传递通过交换机或队列模型进行，需要根据实际系统定义情况进行配置。

      Exchange Type：交换机类型，规定了消息的路由策略，根据实际的消息交换机类型进行配置，可选为direct,topic,headers,fanout。

      Durable?：交换机的持久化属性。持久化队列和非持久化队列的区别是，持久化队列会被保存在磁盘中，固定并持久的存储，当服务重启后，该队列会保持原来的状态在RabbitMQ中被管理，而非持久化队列不会被保存在磁盘中，服务重启后队列就会消失。

      Auto Delete?：交换机的自动删除属性。如果该交换机没有任何订阅的消费者的话，该交换机会被自动删除。这种队列适用于临时队列。

      Redeclare?：该交换机是否可以重新声明。当声明的交换机Durable?或者Auto Delete?与已经存在交换机不一致，会出现类似如下错误：

      Caused by:com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method(reply-code=406,reply-text=PRECONDITION_FAILED - inequivalent arg 'durable' for exchange'jmeterExchange' in vhost '/': received 'false' butcurrent is 'true', class-id=40, method-id=10)

      所以AMQP插件增加了重新声明属性，当交换机声明与已经存在的不一致时，如果勾选了可重新声明，会将原交换机删除，重新定义一个新的。

      3、队列信息。如果需要发送的MQ消息是以队列的方式进行消息传递，需要配置。如果不需要则配置“Queue”属性为空即可。具体的属性含义如下。

      Queue：队列名称，默认为jmeterQueue。

      Routing Key：队列的路由关键字，通过路由关键字的设定，可以完成多个消息统一处理的需求。对于队列的方式，需要与队列名称一致。

      Durable?、Auto Delete?、Redeclare?属性的作用与交换机类似。

      Exclusive?：队列的排他性属性。如果想创建一个只有自己可见的队列，即不允许其它用户访问，可以将一个Queue声明成为排他性的（Exclusive Queue）。

      Message TTL：Time-To-Live，消息过期时间，单位为毫秒。

      Expires：队列的超期时间，单位为毫秒。该值必须为正数(与消息 TTL 不同，该值不可以为 0)，所以如果该参数设置为 1000 ，则表示该队列如果在 1 秒钟之内未被使用则会被删除。

      4、RabbitMQ服务信息。RabbitMQ服务的连接信息。具体包括如下属性。

      Virtual HOST：使用的RabbitMQ服务虚拟主机信息。通过虚拟主机可以在服务器上划分多个虚拟空间，起到消息隔离的作用，默认为根目录“/”。

      Host：RabbitMQ服务所在主机IP或名称，使用名称时需要保证DNS正确性。

      Port：RabbitMQ服务所在端口，默认为5672。

      Username：使用RabbitMQ服务的用户名。

      Password：使用RabbitMQ服务的密码。

      Timeout：连接RabbitMQ服务的超时时间，单位为毫秒。

      

      1、接收设置。接收消息本身的属性。

      Number of samples to Aggregate表示AMQP采样器工作一次消费几条消息。

      Reccive Timeout：接收超时时间。即等待设置时间没有收到消息则退出，单位毫秒。

      PrefetchCount：直观理解是预先获取的消息条数。Prefetch Count允许为每个Consumer指定最大的unacked messages数目。简单来说就是用来指定一个Consumer一次可以从消息中心中获取多少条message并缓存。一旦缓冲区满了，会停止投递新的message给该Consumer，直到它发出ack。

      2、队列操作。接收消息时对队列本身的处理。具体包括如下信息。

      Purge Queue：清除队列。消费消息后将队列清空。

      Auto ACK：自动应答属性。在订阅消息的时候可以指定应答模式，当自动应答等于true的时候，表示当消费者一收到消息就表示消费者收到了消息，消费者收到了消息就会立即从队列中删除。

      Read Response：读取消息内容。一般情况都是要读取消息体的。

      UseTransactions？:与AMQP Publisher含义一致。

      • 问题收集

        无

        • 备注

          无