InfluxdbBackendListener扩展

        前几天文章介绍了测试结果、环境监控基于influxdb、Grafana展示报表搭建。Jmeter错误日志信息写入结果文件，出现错误时第一时间查看比较吃力，基于后置处理器Backend Listener的InfluxdbBackendListenerClient简单扩展可实现错误日志Grafana实时展示。

InfluxdbBackendListenerClient

一、Influxdb数据格式

1、Influxdb insert

通过http端口

curl -i -XPOST 'http://127.0.0.1:8086/write?db=jmeter' --data-binary 'error,Tag=123,application=MIa\ APi Code="404",Label="HTTP请求" 1502245705524000000'

Line Protocol

influxdb写入数据，使用固定的Point格式，详情见influxdb官网文档

{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列表

addMetric

2.writeAndSendMetrics

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

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

4XX：数据格式异常

5XX：服务端异常

writeAndSendMetrics

2、InfluxdbBackendListenerClient

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

handleSampleResults

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

setupTest

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

teardownTest

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

addMetric sendMetrics

3、InfluxdbBackendListenerClient扩展

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

ErrorMetric

2、handleSampleResults获取SampleResult，写入ErrorMetric

ErrorMetric数据输入

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

addErrorCode

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

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

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

influxdb数据写入实例

三、Grafana展示

Grafana提供Table类型报表，可以使用此类型。设置Meterics时注意直接使用SQL语句，本人为配置成功，SQL语句方式可直接按照顺序展示。SQL语句也可以做错误统计，具体使用方式可访问官网自行查找使用方式。

ADD Panel Table Tab了 Edit