test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

替换jmx值

This commit is contained in:
Captain.B 2020-03-03 14:22:09 +08:00
parent 07f286322d
commit c23f5bd795
1 changed files with 25 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
backend/src/main/java/io/metersphere/parse/xml/reader/jmx/JmeterDocumentParser.java
View File

@ -21,6 +21,7 @@ import java.nio.charset.StandardCharsets;
public class JmeterDocumentParser implements DocumentParser { public class JmeterDocumentParser implements DocumentParser {
private final static String HASH_TREE_ELEMENT = "hashTree"; private final static String HASH_TREE_ELEMENT = "hashTree";
private final static String STRING_PROP = "stringProp"; private final static String STRING_PROP = "stringProp";
private final static String COLLECTION_PROP = "collectionProp";
private final static String CONCURRENCY_THREAD_GROUP = "com.blazemeter.jmeter.threads.concurrency.ConcurrencyThreadGroup"; private final static String CONCURRENCY_THREAD_GROUP = "com.blazemeter.jmeter.threads.concurrency.ConcurrencyThreadGroup";
private final static String VARIABLE_THROUGHPUT_TIMER = "kg.apc.jmeter.timers.VariableThroughputTimer"; private final static String VARIABLE_THROUGHPUT_TIMER = "kg.apc.jmeter.timers.VariableThroughputTimer";
private EngineContext context; private EngineContext context;
@ -106,7 +107,6 @@ public class JmeterDocumentParser implements DocumentParser {
private void processVariableThroughputTimer(Element variableThroughputTimer) { private void processVariableThroughputTimer(Element variableThroughputTimer) {
if (variableThroughputTimer.getChildNodes().getLength() > 0) { if (variableThroughputTimer.getChildNodes().getLength() > 0) {
final NodeList childNodes = variableThroughputTimer.getChildNodes(); final NodeList childNodes = variableThroughputTimer.getChildNodes();
int stringPropCount = 0;
for (int i = 0; i < childNodes.getLength(); i++) { for (int i = 0; i < childNodes.getLength(); i++) {
Node node = childNodes.item(i); Node node = childNodes.item(i);
if (node instanceof Element) { if (node instanceof Element) {
@ -115,19 +115,34 @@ public class JmeterDocumentParser implements DocumentParser {
continue; continue;
} }
// kg.apc.jmeter.timers.VariableThroughputTimer的stringProp的name属性是动态的 // TODO kg.apc.jmeter.timers.VariableThroughputTimer的stringProp的name属性是动态的
if (nodeNameEquals(ele, STRING_PROP)) { if (nodeNameEquals(ele, COLLECTION_PROP)) {
NodeList eleChildNodes = ele.getChildNodes();
for (int j = 0; j < eleChildNodes.getLength(); j++) {
Node item = eleChildNodes.item(j);
if (nodeNameEquals(item, COLLECTION_PROP)) {
int stringPropCount = 0;
NodeList itemChildNodes = item.getChildNodes();
for (int k = 0; k < itemChildNodes.getLength(); k++) {
Node prop = itemChildNodes.item(k);
if (nodeNameEquals(prop, STRING_PROP)) {
if (stringPropCount < 2) { if (stringPropCount < 2) {
stringPropCount++; stringPropCount++;
} else { } else {
stringPropCount = 0; stringPropCount = 0;
ele.getFirstChild().setNodeValue(context.getProperty("duration").toString()); prop.getFirstChild().setNodeValue(context.getProperty("duration").toString());
continue; continue;
} }
ele.getFirstChild().setNodeValue(context.getProperty("rpsLimit").toString()); prop.getFirstChild().setNodeValue(context.getProperty("rpsLimit").toString());
} }
} }
} }
}
}
}
}
} }
} }