小丑西瓜9

这个屌丝很懒，什么也没留下！

热门标签

Jmeter对RabbitMQ压力测试_jmeter压测rabbitmq

作者：小丑西瓜9 | 2024-04-09 15:34:30

踩

jmeter压测rabbitmq

环境准备

安装jmeter安装包

下载jmeter

链接：Apache JMeter - Download Apache JMeter

解压jmeter压缩包

apache-jmeter-5.5.zip

JMeter环境变量配置

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

新建系统变量 JMETER_HOME

变量名：JMETER_HOME

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

编辑变量名 Path

新增环境变量：

%JMETER_HOME%\bin

安装jdk

下载地址

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

解压安装jdk压缩包

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

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

Jdk环境变量配置

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

新建系统变量 JAVA_HOME

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

新建系统变量 CLASSPATH

变量名：CLASSPATH
变量值：

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

编辑变量名 Path

新增环境变量：

%JAVA_HOME%\bin

%JAVA_HOME%\jre\bin

检验是否配置成功

打开命令提示符，输入 java -version
展示以下内容即为配置成功

安装AMQP插件

下载地址

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

解压AMQP插件

电脑安装apache-ant

下载地址

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

解压apache-ant安装包

apache-ant配置环境变量

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

下载地址

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

修改配置文件

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

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

打包生成JMeterAMQP.jar

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

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

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

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

jmeter对rabbitmq进行性能测试

新建线程组

新建AMQP Publisher

新建AMQP Consumer

启动查看结果树

启动聚合报告

查看rabbitmq控制台

脚本文件

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


<?xml version="1.0" encoding="UTF-8"?>
 
<jmeterTestPlan version="1.2" properties="5.0" jmeter="5.5">
 
  <hashTree>
 
    <TestPlan guiclass="TestPlanGui" testclass="TestPlan" testname="测试计划" enabled="true">
 
      <stringProp name="TestPlan.comments"></stringProp>
 
      <boolProp name="TestPlan.functional_mode">false</boolProp>
 
      <boolProp name="TestPlan.serialize_threadgroups">true</boolProp>
 
      <elementProp name="TestPlan.user_defined_variables" elementType="Arguments" guiclass="ArgumentsPanel" testclass="Arguments" testname="用户定义的变量" enabled="true">
 
        <collectionProp name="Arguments.arguments"/>
 
      </elementProp>
 
      <stringProp name="TestPlan.user_define_classpath"></stringProp>
 
    </TestPlan>
 
    <hashTree>
 
      <ThreadGroup guiclass="ThreadGroupGui" testclass="ThreadGroup" testname="线程组" enabled="true">
 
        <stringProp name="ThreadGroup.on_sample_error">stoptest</stringProp>
 
        <elementProp name="ThreadGroup.main_controller" elementType="LoopController" guiclass="LoopControlPanel" testclass="LoopController" testname="循环控制器" enabled="true">
 
          <boolProp name="LoopController.continue_forever">false</boolProp>
 
          <stringProp name="LoopController.loops">1</stringProp>
 
        </elementProp>
 
        <stringProp name="ThreadGroup.num_threads">2</stringProp>
 
        <stringProp name="ThreadGroup.ramp_time">10</stringProp>
 
        <boolProp name="ThreadGroup.scheduler">false</boolProp>
 
        <stringProp name="ThreadGroup.duration">10</stringProp>
 
        <stringProp name="ThreadGroup.delay"></stringProp>
 
        <boolProp name="ThreadGroup.same_user_on_next_iteration">true</boolProp>
 
      </ThreadGroup>
 
      <hashTree>
 
        <UserParameters guiclass="UserParametersGui" testclass="UserParameters" testname="用户参数" enabled="false">
 
          <collectionProp name="UserParameters.names">
 
            <stringProp name="-299803597">hostname</stringProp>
 
            <stringProp name="3446913">port</stringProp>
 
            <stringProp name="-265713450">username</stringProp>
 
            <stringProp name="1216985755">password</stringProp>
 
            <stringProp name="-1738693860">queuename</stringProp>
 
          </collectionProp>
 
          <collectionProp name="UserParameters.thread_values">
 
            <collectionProp name="1819310027">
 
              <stringProp name="275943087">1.1.2.2</stringProp>
 
              <stringProp name="48578295">3xxx</stringProp>
 
              <stringProp name="1211207374">defauweR0</stringProp>
 
              <stringProp name="-909111453">8gG558p1_H-Jz9L</stringProp>
 
              <stringProp name="1306055093">zytest-1</stringProp>
 
            </collectionProp>
 
          </collectionProp>
 
          <boolProp name="UserParameters.per_iteration">false</boolProp>
 
        </UserParameters>
 
        <hashTree/>
 
        <LoopController guiclass="LoopControlPanel" testclass="LoopController" testname="循环控制器" enabled="true">
 
          <boolProp name="LoopController.continue_forever">true</boolProp>
 
          <stringProp name="LoopController.loops">1</stringProp>
 
        </LoopController>
 
        <hashTree>
 
          <com.zeroclue.jmeter.protocol.amqp.AMQPPublisher guiclass="com.zeroclue.jmeter.protocol.amqp.gui.AMQPPublisherGui" testclass="com.zeroclue.jmeter.protocol.amqp.AMQPPublisher" testname="AMQP Publisher-生产者" enabled="true">
 
            <stringProp name="AMQPSampler.Exchange">zyjmeterExchange</stringProp>
 
            <boolProp name="AMQPSampler.ExchangeDurable">true</boolProp>
 
            <boolProp name="AMQPSampler.ExchangeAutoDelete">true</boolProp>
 
            <boolProp name="AMQPSampler.ExchangeRedeclare">false</boolProp>
 
            <stringProp name="AMQPSampler.Queue">zytest-1</stringProp>
 
            <stringProp name="AMQPSampler.RoutingKey">zytest-1</stringProp>
 
            <stringProp name="AMQPSampler.VirtualHost">/</stringProp>
 
            <stringProp name="AMQPSampler.MessageTTL"></stringProp>
 
            <stringProp name="AMQPSampler.MessageExpires"></stringProp>
 
            <stringProp name="AMQPSampler.ExchangeType">direct</stringProp>
 
            <stringProp name="AMQPSampler.QueueDurable">true</stringProp>
 
            <stringProp name="AMQPSampler.QueueExclusive">false</stringProp>
 
            <stringProp name="AMQPSampler.QueueAutoDelete">false</stringProp>
 
            <boolProp name="AMQPSampler.Redeclare">false</boolProp>
 
            <stringProp name="AMQPSampler.Timeout">5000</stringProp>
 
            <stringProp name="AMQPSampler.Iterations">1</stringProp>
 
            <stringProp name="AMQPSampler.Host">10.10.21.29</stringProp>
 
            <stringProp name="AMQPSampler.Port">3214</stringProp>
 
            <stringProp name="AMQPSampler.Username">default_user_fZzFDUx3r-0As9gFfOl</stringProp>
 
            <stringProp name="AMQPSampler.Password">4hYbpm_if3KK0RuMV42tTrfSoYZOvL5U</stringProp>
 
            <stringProp name="AMQPSampler.SSL">false</stringProp>
 
            <boolProp name="AMQPPublisher.Persistent">false</boolProp>
 
            <boolProp name="AMQPPublisher.UseTx">false</boolProp>
 
            <stringProp name="AMQPPublisher.MessageRoutingKey">zytest-1</stringProp>
 
            <stringProp name="AMQPPublisher.Message">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</stringProp>
 
            <stringProp name="AMQPPublisher.MessageType"></stringProp>
 
            <stringProp name="AMQPPublisher.ReplyToQueue"></stringProp>
 
            <stringProp name="AMQPPublisher.CorrelationId"></stringProp>
 
            <stringProp name="AMQPPublisher.ContentType">text/plain </stringProp>
 
            <stringProp name="AMQPPublisher.MessageId"></stringProp>
 
            <elementProp name="AMQPPublisher.Headers" elementType="Arguments" guiclass="ArgumentsPanel" testclass="Arguments" testname="用户定义的变量" enabled="true">
 
              <collectionProp name="Arguments.arguments"/>
 
            </elementProp>
 
          </com.zeroclue.jmeter.protocol.amqp.AMQPPublisher>
 
          <hashTree/>
 
        </hashTree>
 
        <com.zeroclue.jmeter.protocol.amqp.AMQPConsumer guiclass="com.zeroclue.jmeter.protocol.amqp.gui.AMQPConsumerGui" testclass="com.zeroclue.jmeter.protocol.amqp.AMQPConsumer" testname="AMQP Consumer-消费者" enabled="false">
 
          <stringProp name="AMQPSampler.Exchange">zyjmeterExchange</stringProp>
 
          <boolProp name="AMQPSampler.ExchangeDurable">true</boolProp>
 
          <boolProp name="AMQPSampler.ExchangeAutoDelete">true</boolProp>
 
          <boolProp name="AMQPSampler.ExchangeRedeclare">false</boolProp>
 
          <stringProp name="AMQPSampler.Queue">zytest-1</stringProp>
 
          <stringProp name="AMQPSampler.RoutingKey">zytest-1</stringProp>
 
          <stringProp name="AMQPSampler.VirtualHost">/</stringProp>
 
          <stringProp name="AMQPSampler.MessageTTL"></stringProp>
 
          <stringProp name="AMQPSampler.MessageExpires"></stringProp>
 
          <stringProp name="AMQPSampler.ExchangeType">direct</stringProp>
 
          <stringProp name="AMQPSampler.QueueDurable">true</stringProp>
 
          <stringProp name="AMQPSampler.QueueExclusive">false</stringProp>
 
          <stringProp name="AMQPSampler.QueueAutoDelete">false</stringProp>
 
          <boolProp name="AMQPSampler.Redeclare">false</boolProp>
 
          <stringProp name="AMQPSampler.Timeout">1000</stringProp>
 
          <stringProp name="AMQPSampler.Iterations">100</stringProp>
 
          <stringProp name="AMQPSampler.Host">${hostname}</stringProp>
 
          <stringProp name="AMQPSampler.Port">${port}</stringProp>
 
          <stringProp name="AMQPSampler.Username">${username}</stringProp>
 
          <stringProp name="AMQPSampler.Password">${password}</stringProp>
 
          <stringProp name="AMQPSampler.SSL">false</stringProp>
 
          <boolProp name="AMQPConsumer.ReadResponse">true</boolProp>
 
          <stringProp name="AMQPConsumer.PrefetchCount">0</stringProp>
 
          <stringProp name="AMQPConsumer.ReceiveTimeout"></stringProp>
 
          <stringProp name="AMQPConsumer.PurgeQueue">false</stringProp>
 
          <stringProp name="AMQPConsumer.AutoAck">true</stringProp>
 
          <boolProp name="AMQPConsumer.UseTx">false</boolProp>
 
        </com.zeroclue.jmeter.protocol.amqp.AMQPConsumer>
 
        <hashTree/>
 
        <ResultCollector guiclass="ViewResultsFullVisualizer" testclass="ResultCollector" testname="察看结果树" enabled="true">
 
          <boolProp name="ResultCollector.error_logging">false</boolProp>
 
          <objProp>
 
            <name>saveConfig</name>
 
            <value class="SampleSaveConfiguration">
 
              <time>true</time>
 
              <latency>true</latency>
 
              <timestamp>true</timestamp>
 
              <success>true</success>
 
              <label>true</label>
 
              <code>true</code>
 
              <message>true</message>
 
              <threadName>true</threadName>
 
              <dataType>true</dataType>
 
              <encoding>false</encoding>
 
              <assertions>true</assertions>
 
              <subresults>true</subresults>
 
              <responseData>false</responseData>
 
              <samplerData>false</samplerData>
 
              <xml>false</xml>
 
              <fieldNames>true</fieldNames>
 
              <responseHeaders>false</responseHeaders>
 
              <requestHeaders>false</requestHeaders>
 
              <responseDataOnError>false</responseDataOnError>
 
              <saveAssertionResultsFailureMessage>true</saveAssertionResultsFailureMessage>
 
              <assertionsResultsToSave>0</assertionsResultsToSave>
 
              <bytes>true</bytes>
 
              <sentBytes>true</sentBytes>
 
              <url>true</url>
 
              <threadCounts>true</threadCounts>
 
              <idleTime>true</idleTime>
 
              <connectTime>true</connectTime>
 
            </value>
 
          </objProp>
 
          <stringProp name="filename"></stringProp>
 
        </ResultCollector>
 
        <hashTree/>
 
        <ResultCollector guiclass="StatVisualizer" testclass="ResultCollector" testname="聚合报告" enabled="true">
 
          <boolProp name="ResultCollector.error_logging">false</boolProp>
 
          <objProp>
 
            <name>saveConfig</name>
 
            <value class="SampleSaveConfiguration">
 
              <time>true</time>
 
              <latency>true</latency>
 
              <timestamp>true</timestamp>
 
              <success>true</success>
 
              <label>true</label>
 
              <code>true</code>
 
              <message>true</message>
 
              <threadName>true</threadName>
 
              <dataType>true</dataType>
 
              <encoding>false</encoding>
 
              <assertions>true</assertions>
 
              <subresults>true</subresults>
 
              <responseData>false</responseData>
 
              <samplerData>false</samplerData>
 
              <xml>false</xml>
 
              <fieldNames>true</fieldNames>
 
              <responseHeaders>false</responseHeaders>
 
              <requestHeaders>false</requestHeaders>
 
              <responseDataOnError>false</responseDataOnError>
 
              <saveAssertionResultsFailureMessage>true</saveAssertionResultsFailureMessage>
 
              <assertionsResultsToSave>0</assertionsResultsToSave>
 
              <bytes>true</bytes>
 
              <sentBytes>true</sentBytes>
 
              <url>true</url>
 
              <threadCounts>true</threadCounts>
 
              <idleTime>true</idleTime>
 
              <connectTime>true</connectTime>
 
            </value>
 
          </objProp>
 
          <stringProp name="filename"></stringProp>
 
        </ResultCollector>
 
        <hashTree/>
 
      </hashTree>
 
    </hashTree>
 
  </hashTree>
 
</jmeterTestPlan>

参数说明

AMQP Publisher参数说明

采样器的名称和备注。这是JMeter所有采样器的属性，用来进行线程组的采样管理。建议取有意义的名字。
交换机信息。如果需要发送的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<channel.close>(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格式设置头信息，可以是任意的进行业务逻辑的数据。

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

AMQP Consumer参数说明

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

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

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

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

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

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

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

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

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

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

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

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

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含义一致。

问题收集

无

备注

无

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/393676