jmeter系列七(Visualizer的TestElement-ResultCollector)

前面分析了Visualizer，今天看下他对应的testelement-ResultCollector

ResultCollector实现了SampleListener, Clearable, Serializable,TestStateListener, Remoteable, NoThreadClone这几个接口

一个一个的看下

SampleListener接口 notification on events occuring during the sampling process

Clearable接口 同上

Serializable接口 可序列化

TestStateListener接口 测试开始的过程中实现了这个接口的类可以被回调

Remoteable接口 以后分析

NoThreadClone接口 标记接口，标记了这个接口的testelement，在多个test run之间不会被clone

重点看实现了TestStateListener接口的方法和实现了SampleListener接口的方法

testStarted testEnded sampleOccurred

@Override
    public void testStarted(String host) {
        synchronized(LOCK){
            if (instanceCount == 0) { // Only add the hook once
                shutdownHook = new Thread(new ShutdownHook());
                Runtime.getRuntime().addShutdownHook(shutdownHook);
            }
            instanceCount++;
            try {
                initializeFileOutput();
                if (getVisualizer() != null) {
                    this.isStats = getVisualizer().isStats();
                }
            } catch (Exception e) {
                log.error("", e);
            }
        }
        inTest = true;

        if(summariser != null) {
            summariser.testStarted(host);
        }
    }

@Override
    public void testEnded(String host) {
        synchronized(LOCK){
            instanceCount--;
            if (instanceCount <= 0) {
                // No need for the hook now
                Runtime.getRuntime().removeShutdownHook(shutdownHook);
                finalizeFileOutput();
                inTest = false;
            }
        }

        if(summariser != null) {
            summariser.testEnded(host);
        }
    }

@Override
    public void sampleOccurred(SampleEvent event) {
        SampleResult result = event.getResult();

        if (isSampleWanted(result.isSuccessful())) {
            sendToVisualizer(result);
            if (out != null && !isResultMarked(result) && !this.isStats) {
                SampleSaveConfiguration config = getSaveConfig();
                result.setSaveConfig(config);
                try {
                    if (config.saveAsXml()) {
                        SaveService.saveSampleResult(event, out);
                    } else { // !saveAsXml
                        String savee = CSVSaveService.resultToDelimitedString(event);
                        out.println(savee);
                    }
                } catch (Exception err) {
                    log.error("Error trying to record a sample", err); // should throw exception back to caller
                }
            }
        }

        if(summariser != null) {
            summariser.sampleOccurred(event);
        }
    }

其中涉及到的SaveService,CSVSaveService都是帮助保存文件的辅助类