InfluxdbBackendListener扩展

一、Influxdb数据格式

1、Influxdb insert

Line Protocol

{measurement}{ ,tag_set} {field_set} {}timestamp}

error,Tag=123,application=MIa\ APi Code="404",Label="HTTP请求" 1502245705524000000

measurement ：表名，如error

tag_set ：tag标签，和时间戳共同确定唯一值

field_set：数据point

timestamp ：时间戳

二、Jmeter Influxdb BackendListener插件

Jmeter基于CloseableHttpAsyncClient异步HTTP请求写入influxdb

1、HttpMetricsSender 请求发送

1.addMetric 

addMetric将influxdb Point数据写入metric list列表

2.writeAndSendMetrics

writeAndSendMetrics异步NIO方式批量发送influxdb数据。数据发送失败不影响jmeter正常运行，超时时间及发送频率参考Jmeter配置文件。

2XX：成功，204成功但是内容为空

4XX：数据格式异常

5XX：服务端异常

2、InfluxdbBackendListenerClient

handleSampleResults：处理sampler可以实现写入文件或者写入实例server

setupTest：客户端初始化操作，尽量避免进行测试行为。Executors、ScheduledExecutorService定时任务创建

teardownTest：测试线程结束后，资源释放清理。定时任务关闭，influxdb资源释放

重点来了，Backend Listener的InfluxdbBackendListenerClient如何实现数据写入，addMetric等方法完成数据Metrics写入，基于ScheduledExecutorService接口通过run方法定时触发sendMetrics()实现。

3、InfluxdbBackendListenerClient扩展

1、参考UserMetric，创建ErrorMetric定义错误Metric。只需要通过SampleResult获取错误相关内容即可。非必需类。

2、handleSampleResults获取SampleResult，写入ErrorMetric

3、addErrorCode按照influxdb Point格式组织influxdb数据并写入metric list列表

备注：未考虑性能等问题，只介绍简单实现方式。后续可根据需要加入统计等等。

编写完成，运行Jmeter，数据成功写入influx后确认无误后，执行ant package 打包命令替换Jar即可。

select * from error   查看表是否自动创建数据写入

三、Grafana展示