# kmetrics

**Repository Path**: kool2017/kmetrics

## Basic Information

- **Project Name**: kmetrics
- **Description**: mqtt指标系统，执行流处理任务，计算mqtt系统的各类指标。
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2021-04-06
- **Last Updated**: 2021-12-23

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# kmetrics

#### 介绍
指标统计系统，执行流处理逻辑。计算kmqtt系统的各类指标。

累加指标，存redis，3天过期：
当日各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
当日主题的入站PUBLISH报文数、出站PUBLISH报文数；
当日用户的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
当日用户的主题的入站PUBLISH报文数、出站PUBLISH报文数；
当日客户端的主题的入站PUBLISH报文数、出站PUBLISH报文数；
当日客户端地址的主题的入站PUBLISH报文数、出站PUBLISH报文数；
当日各种报文类型的出站报文数、成功数、失败数；
当日用户的各种报文类型的出站报文数、成功数、失败数；
当日客户端的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
当日客户端的各种报文类型的出站报文数、成功数、失败数；
当日客户端地址的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
当日客户端地址的各种报文类型的出站报文数、成功数、失败数；

时序指标，存redis，每分钟更新，3天过期：
当前会话数

时序指标，存redis，每天更新，30天过期：
出站未确认消息数

时序指标，存prometheus：
用户的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
客户端的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
客户端地址的各种报文类型的入站报文数、成功数、失败数、平均耗时、最大耗时；
用户的主题的入站PUBLISH报文数；
客户端的主题的入站PUBLISH报文数；
客户端地址的主题的入站PUBLISH报文数；
用户的主题的出站PUBLISH报文数；
客户端的主题的出站PUBLISH报文数；
客户端地址的主题的出站PUBLISH报文数；
用户的各种报文类型的出站报文数、成功数、失败数；
客户端的各种报文类型的出站报文数、成功数、失败数；
客户端地址的各种报文类型的出站报文数、成功数、失败数；
会话数
出站未确认消息数


#### 日志
20210411 redis指标、prometheus指标、mysql订阅快照