java - 使用 JMeter 对 CassandraDB 进行负载测试

标签 java performance jmeter performance-testing cassandra-2.0

我正在使用 Cassandra JMeter 插件 https://github.com/slowenthal/jmeter-cassandra#cassandra-jmeter-plugin-for-cassandra我已将其集成到 apache-JMeter2.9

我有一个 Cassandra 集群，其中包含 2 个数据中心和每个数据中心上的 2 个节点。

JMeter:

Cassandra 连接:

contact points : 192.168.1.50,192.168.1.51,192.168.1.52
keyspace : test_db

Cassandra 采样器 

CQL Query : select  * from test_db.feed_yogesh limit 1000;
Consistency Level : QUORUM

测试场景

1.获取1个用户的1000条记录

User/Thread : 1
Ramp-Up-Period : 0
Generate Summary Results =      1 in   2.2s =    0.5/s Avg:  2180 Min:  2180 Max:  2180 Err:     0 (0.00%)

2.获取1000个用户的1000条记录

我想同时测试多个用户，因此我将 Ramp-Up-period 添加为 0，根据 JMeter 将立即启动所有用户。

User/Thread : 1000
RampUp Period : 0
Summary Results =   1000 in    18s =   56.1/s Avg:  6857 Min:  5000 Max: 17044 Err:   987 (98.70%)

它确实启动了我的所有用户，但只有 4-5 个用户返回成功，其余的都给我错误，例如 

All host(s) tried for query failed (tried: /192.168.1.50:9042 (com.datastax.driver.core.BusyConnectionException))

但是当我测试相同的 1000 个用户并给出 300 的 Ramp-up-period 时，它会返回所有成功。

User/Thread : 1000
RampUp Period : 300
Generate Summary Results =   1000 in   301s =    3.3/s Avg:   519 Min:   255 Max:  1811 Err:     0 (0.00%)

Cassndra Sampler.jmx

<?xml version="1.0" encoding="UTF-8"?>
<jmeterTestPlan version="1.2" properties="2.4" jmeter="2.9 r1437961">
  <hashTree>
    <TestPlan guiclass="TestPlanGui" testclass="TestPlan" testname="Test Plan" enabled="true">
      <stringProp name="TestPlan.comments"></stringProp>
      <boolProp name="TestPlan.functional_mode">false</boolProp>
      <boolProp name="TestPlan.serialize_threadgroups">false</boolProp>
      <elementProp name="TestPlan.user_defined_variables" elementType="Arguments" guiclass="ArgumentsPanel" testclass="Arguments" testname="User Defined Variables" enabled="true">
        <collectionProp name="Arguments.arguments"/>
      </elementProp>
      <stringProp name="TestPlan.user_define_classpath"></stringProp>
    </TestPlan>
    <hashTree>
      <ThreadGroup guiclass="ThreadGroupGui" testclass="ThreadGroup" testname="Thread Group" enabled="true">
        <stringProp name="ThreadGroup.on_sample_error">continue</stringProp>
        <elementProp name="ThreadGroup.main_controller" elementType="LoopController" guiclass="LoopControlPanel" testclass="LoopController" testname="Loop Controller" enabled="true">
          <boolProp name="LoopController.continue_forever">false</boolProp>
          <stringProp name="LoopController.loops">1</stringProp>
        </elementProp>
        <stringProp name="ThreadGroup.num_threads">1000</stringProp>
        <stringProp name="ThreadGroup.ramp_time">0</stringProp>
        <longProp name="ThreadGroup.start_time">1420788860000</longProp>
        <longProp name="ThreadGroup.end_time">1420788860000</longProp>
        <boolProp name="ThreadGroup.scheduler">false</boolProp>
        <stringProp name="ThreadGroup.duration"></stringProp>
        <stringProp name="ThreadGroup.delay"></stringProp>
      </ThreadGroup>
      <hashTree>
        <org.apache.cassandra.jmeter.config.CassandraConnection guiclass="TestBeanGUI" testclass="org.apache.cassandra.jmeter.config.CassandraConnection" testname="Cassandra Connection" enabled="true">
          <stringProp name="contactPoints">192.168.1.50,192.168.1.51,192.168.1.52</stringProp>
          <stringProp name="keyspace">test_db</stringProp>
          <stringProp name="loadBalancer">Default</stringProp>
          <stringProp name="localDataCenter"></stringProp>
          <stringProp name="password"></stringProp>
          <stringProp name="sessionName">mydatabase</stringProp>
          <stringProp name="username"></stringProp>
        </org.apache.cassandra.jmeter.config.CassandraConnection>
        <hashTree/>
        <org.apache.cassandra.jmeter.sampler.CassandraSampler guiclass="TestBeanGUI" testclass="org.apache.cassandra.jmeter.sampler.CassandraSampler" testname="Cassandra Sampler" enabled="true">
          <stringProp name="batchSize"></stringProp>
          <stringProp name="consistencyLevel">QUORUM</stringProp>
          <stringProp name="query">select  * from test_db.feed_yogesh limit 1000;</stringProp>
          <stringProp name="queryArguments">Running</stringProp>
          <stringProp name="queryType">Simple Statement</stringProp>
          <stringProp name="resultVariable"></stringProp>
          <stringProp name="sessionName">mydatabase</stringProp>
          <stringProp name="variableNames">VARCHAR</stringProp>
        </org.apache.cassandra.jmeter.sampler.CassandraSampler>
        <hashTree/>
        <ResultCollector guiclass="ViewResultsFullVisualizer" testclass="ResultCollector" testname="View Results Tree" 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>false</fieldNames>
              <responseHeaders>false</responseHeaders>
              <requestHeaders>false</requestHeaders>
              <responseDataOnError>false</responseDataOnError>
              <saveAssertionResultsFailureMessage>false</saveAssertionResultsFailureMessage>
              <assertionsResultsToSave>0</assertionsResultsToSave>
              <bytes>true</bytes>
            </value>
          </objProp>
          <stringProp name="filename"></stringProp>
        </ResultCollector>
        <hashTree/>
        <ResultCollector guiclass="SummaryReport" testclass="ResultCollector" testname="Summary Report" 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>false</fieldNames>
              <responseHeaders>false</responseHeaders>
              <requestHeaders>false</requestHeaders>
              <responseDataOnError>false</responseDataOnError>
              <saveAssertionResultsFailureMessage>false</saveAssertionResultsFailureMessage>
              <assertionsResultsToSave>0</assertionsResultsToSave>
              <bytes>true</bytes>
            </value>
          </objProp>
          <stringProp name="filename"></stringProp>
        </ResultCollector>
        <hashTree/>
      </hashTree>
    </hashTree>
  </hashTree>
</jmeterTestPlan>

我很困惑，这是否意味着多个用户无法同时读取数据，我们是否需要强制添加 Ramp-Up-Period 值。

最佳答案

加速周期决定用户应该上线或开始达到目标负载的时间范围。

您的结果显示，当您以 0 加速开始时，所有 1000 个用户同时启动(1000 个并发用户同时访问数据库)。结果显示，只有少数用户(1%)通过了测试，其余的则失败，如果没有进行适当的调整或数据库服务器没有足够的配置，这是预料之中的。

出现上述行为的原因可能是您的数据库服务器无法一次承受那么多负载。它试图尽可能多地提供服务，但超出了一定的限制，它就停止了工作。

但是，当您添加提升后，查询/用户达到数据库速率的速度就在数据库服务限制之内，因此它可以正常运行。

您可以检查的是找出瓶颈或这些故障的原因。可能有一些原因，

  1. 连接池低
  2. 减少事务超时
  3. 低配置
  4. 数据库缺乏调整参数

原因可能有很多，但请尝试调试和解决性能问题，并以较低的提升速度再次重新测试(对于 1000 个用户，不建议使用 0 秒，至少保持 5-10 秒)。如果您希望 1000 个用户同时点击某个点，则称为同步计时器组件可以帮助您。

关于java - 使用 JMeter 对 CassandraDB 进行负载测试，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/27860106/

上一篇：Java:如何在命令提示符下编译代码的整个目录结构？

下一篇：java - 为什么在 swing 中使用公共(public)静态文本字段

相关文章：

java - RxJava 出错后如何继续流式传输项目？

java - 嵌套在 do-while 循环中的 try-catch 没有实际循环是否有原因？

java - Java中的接口(interface)方法重载

ruby-on-rails - 为什么 ActionDispatch::Routing::RouteSet 需要这么长时间

regex - 使用正则表达式匹配 URL 中的 ID

jmeter - 如何在jmeter中使用post请求循环遍历csv文件

java - 如何使用 iText 7 在 PDF 文件中添加复选框？

sql - ORM 性能成本

c++ - G++ 是否足够聪明来优化它？

imap - 缺少 CR - TCP 采样器

©2024 IT工具网  联系我们