Tio Boot DocsTio Boot Docs
Home
  • java-db
  • api-table
  • Enjoy
  • Tio Boot Admin
  • ai_agent
  • translator
  • knowlege_base
  • ai-search
  • 案例
Abount
  • Github
  • Gitee
Home
  • java-db
  • api-table
  • Enjoy
  • Tio Boot Admin
  • ai_agent
  • translator
  • knowlege_base
  • ai-search
  • 案例
Abount
  • Github
  • Gitee
  • 01_tio-boot 简介

    • tio-boot:新一代高性能 Java Web 开发框架
    • tio-boot 入门示例
    • Tio-Boot 配置 : 现代化的配置方案
    • tio-boot 整合 Logback
    • tio-boot 整合 hotswap-classloader 实现热加载
    • 自行编译 tio-boot
    • 最新版本
    • 开发规范
  • 02_部署

    • 使用 Maven Profile 实现分环境打包 tio-boot 项目
    • Maven 项目配置详解:依赖与 Profiles 配置
    • tio-boot 打包成 FastJar
    • 使用 GraalVM 构建 tio-boot Native 程序
    • 使用 Docker 部署 tio-boot
    • 部署到 Fly.io
    • 部署到 AWS Lambda
    • 到阿里云云函数
    • 使用 Deploy 工具部署
    • 胖包与瘦包的打包与部署
    • 使用 Jenkins 部署 Tio-Boot 项目
    • 使用 Nginx 反向代理 Tio-Boot
    • 使用 Supervisor 管理 Java 应用
  • 03_配置

    • 配置参数
    • 服务器监听器
    • 内置缓存系统 AbsCache
    • 使用 Redis 作为内部 Cache
    • 静态文件处理器
    • 基于域名的静态资源隔离
    • DecodeExceptionHandler
  • 04_原理

    • 生命周期
    • 请求处理流程
    • 重要的类
  • 05_json

    • Json
    • 接受 JSON 和响应 JSON
    • 响应实体类
  • 06_web

    • 概述
    • 文件上传
    • 接收请求参数
    • 接收日期参数
    • 接收数组参数
    • 返回字符串
    • 返回文本数据
    • 返回网页
    • 请求和响应字节
    • 文件下载
    • 返回视频文件并支持断点续传
    • http Session
    • Cookie
    • HttpRequest
    • HttpResponse
    • Resps
    • RespBodyVo
    • /zh/06_web/19.html
    • 全局异常处理器
    • 异步
    • 动态 返回 CSS 实现
    • 返回图片
    • Transfer-Encoding: chunked 实时音频播放
    • Server-Sent Events (SSE)
    • 接口访问统计
    • 接口请求和响应数据记录
    • 自定义 Handler 转发请求
    • 使用 HttpForwardHandler 转发所有请求
    • 跨域
    • 添加 Controller
    • 常用工具类
    • HTTP Basic 认证
    • WebJars
    • JProtobuf
  • 07_validate

    • 数据紧校验规范
    • 参数校验
  • 08_websocket

    • 使用 tio-boot 搭建 WebSocket 服务
    • WebSocket 聊天室项目示例
  • 09_java-db

    • java‑db
    • 操作数据库入门示例
    • SQL 模板
    • 数据源配置与使用
    • ActiveRecord
    • Model
    • 生成器与 Model
    • Db 工具类
    • 批量操作
    • 数据库事务处理
    • Cache 缓存
    • Dialect 多数据库支持
    • 表关联操作
    • 复合主键
    • Oracle 支持
    • Enjoy SQL 模板
    • Java-DB 整合 Enjoy 模板最佳实践
    • 多数据源支持
    • 独立使用 ActiveRecord
    • 调用存储过程
    • java-db 整合 Guava 的 Striped 锁优化
    • 生成 SQL
    • 通过实体类操作数据库
    • java-db 读写分离
    • Spring Boot 整合 Java-DB
    • like 查询
    • 常用操作示例
    • Druid 监控集成指南
    • SQL 统计
  • 10_api-table

    • ApiTable 概述
    • 使用 ApiTable 连接 SQLite
    • 使用 ApiTable 连接 Mysql
    • 使用 ApiTable 连接 Postgres
    • 使用 ApiTable 连接 TDEngine
    • 使用 api-table 连接 oracle
    • 使用 api-table 连接 mysql and tdengine 多数据源
    • EasyExcel 导出
    • EasyExcel 导入
    • TQL(Table SQL)前端输入规范
    • ApiTable 实现增删改查
    • 数组类型
    • 单独使用 ApiTable
  • 11_aop

    • JFinal-aop
    • Aop 工具类
    • 配置
    • 配置
    • 独立使用 JFinal Aop
    • @AImport
    • 原理解析
  • 12_cache

    • Caffine
    • Jedis-redis
    • hutool RedisDS
    • Redisson
    • Caffeine and redis
    • CacheUtils 工具类
    • 使用 CacheUtils 整合 caffeine 和 redis 实现的两级缓存
    • 使用 java-db 整合 ehcache
    • 使用 java-db 整合 redis
    • Java DB Redis 相关 Api
    • redis 使用示例
  • 13_认证和权限

    • hutool-JWT
    • FixedTokenInterceptor
    • 使用内置 TokenManager 实现登录
    • 用户系统
    • 重置密码
    • 匿名登录
    • Google 登录
    • 权限校验注解
    • Sa-Token
    • sa-token 登录注册
    • StpUtil.isLogin() 源码解析
    • 短信登录
    • 移动端微信登录实现指南
    • 移动端重置密码
  • 14_i18n

    • i18n
  • 15_enjoy

    • tio-boot 整合 Enjoy 模版引擎文档
    • 引擎配置
    • 表达式
    • 指令
    • 注释
    • 原样输出
    • Shared Method 扩展
    • Shared Object 扩展
    • Extension Method 扩展
    • Spring boot 整合
    • 独立使用 Enjoy
    • tio-boot enjoy 自定义指令 localeDate
    • PromptEngine
    • Enjoy 入门示例-擎渲染大模型请求体
    • Enjoy 使用示例
  • 16_定时任务

    • Quartz 定时任务集成指南
    • 分布式定时任务 xxl-jb
    • cron4j 使用指南
  • 17_tests

    • TioBootTest 类
  • 18_tio

    • TioBootServer
    • tio-core
    • 内置 TCP 处理器
    • 独立启动 UDPServer
    • 使用内置 UDPServer
    • t-io 消息处理流程
    • tio-运行原理详解
    • TioConfig
    • ChannelContext
    • Tio 工具类
    • 业务数据绑定
    • 业务数据解绑
    • 发送数据
    • 关闭连接
    • Packet
    • 监控: 心跳
    • 监控: 客户端的流量数据
    • 监控: 单条 TCP 连接的流量数据
    • 监控: 端口的流量数据
    • 单条通道统计: ChannelStat
    • 所有通道统计: GroupStat
    • 资源共享
    • 成员排序
    • ssl
    • DecodeRunnable
    • 使用 AsynchronousSocketChannel 响应数据
    • 拉黑 IP
    • 深入解析 Tio 源码:构建高性能 Java 网络应用
  • 19_aio

    • ByteBuffer
    • AIO HTTP 服务器
    • 自定义和线程池和池化 ByteBuffer
    • AioHttpServer 应用示例 IP 属地查询
    • 手写 AIO Http 服务器
  • 20_netty

    • Netty TCP Server
    • Netty Web Socket Server
    • 使用 protoc 生成 Java 包文件
    • Netty WebSocket Server 二进制数据传输
    • Netty 组件详解
  • 21_netty-boot

    • Netty-Boot
    • 原理解析
    • 整合 Hot Reload
    • 整合 数据库
    • 整合 Redis
    • 整合 Elasticsearch
    • 整合 Dubbo
    • Listener
    • 文件上传
    • 拦截器
    • Spring Boot 整合 Netty-Boot
    • SSL 配置指南
    • ChannelInitializer
    • Reserve
  • 22_MQ

    • Mica-mqtt
    • EMQX
    • Disruptor
  • 23_tio-utils

    • tio-utils
    • HttpUtils
    • Notification
    • 邮箱
    • JSON
    • 读取文件
    • Base64
    • 上传和下载
    • Http
    • Telegram
    • RsaUtils
    • EnvUtils 使用文档
    • 系统监控
    • 毫秒并发 ID (MCID) 生成方案
  • 24_tio-http-server

    • 使用 Tio-Http-Server 搭建简单的 HTTP 服务
    • tio-boot 添加 HttpRequestHandler
    • 在 Android 上使用 tio-boot 运行 HTTP 服务
    • tio-http-server-native
    • handler 常用操作
  • 25_tio-websocket

    • WebSocket 服务器
    • WebSocket Client
  • 26_tio-im

    • 通讯协议文档
    • ChatPacket.proto 文档
    • java protobuf
    • 数据表设计
    • 创建工程
    • 登录
    • 历史消息
    • 发消息
  • 27_mybatis

    • Tio-Boot 整合 MyBatis
    • 使用配置类方式整合 MyBatis
    • 整合数据源
    • 使用 mybatis-plus 整合 tdengine
    • 整合 mybatis-plus
  • 28_mongodb

    • tio-boot 使用 mongo-java-driver 操作 mongodb
  • 29_elastic-search

    • Elasticsearch
    • JavaDB 整合 ElasticSearch
    • Elastic 工具类使用指南
    • Elastic-search 注意事项
    • ES 课程示例文档
  • 30_magic-script

    • tio-boot 整合 magic-script
  • 31_groovy

    • tio-boot 整合 Groovy
  • 32_firebase

    • 整合 google firebase
    • Firebase Storage
    • Firebase Authentication
    • 使用 Firebase Admin SDK 进行匿名用户管理与自定义状态标记
    • 导出用户
    • 注册回调
    • 登录注册
  • 33_文件存储

    • 文件上传数据表
    • 本地存储
    • 使用 AWS S3 存储文件并整合到 Tio-Boot 项目中
    • 存储文件到 腾讯 COS
  • 34_spider

    • jsoup
    • 爬取 z-lib.io 数据
    • 整合 WebMagic
    • WebMagic 示例:爬取学校课程数据
    • Playwright
    • Flexmark (Markdown 处理器)
    • tio-boot 整合 Playwright
    • 缓存网页数据
  • 36_integration_thirty_party

    • tio-boot 整合 okhttp
    • 整合 GrpahQL
    • 集成 Mailjet
    • 整合 ip2region
    • 整合 GeoLite 离线库
    • 整合 Lark 机器人指南
    • 集成 Lark Mail 实现邮件发送
    • Thymeleaf
    • Swagger
    • Clerk 验证
  • 37_dubbo

    • 概述
    • dubbo 2.6.0
    • dubbo 2.6.0 调用过程
    • dubbo 3.2.0
  • 38_spring

    • Spring Boot Web 整合 Tio Boot
    • spring-boot-starter-webflux 整合 tio-boot
    • Tio Boot 整合 Spring Boot Starter
    • Tio Boot 整合 Spring Boot Starter Data Redis 指南
  • 39_spring-cloud

    • tio-boot spring-cloud
  • 40_mysql

    • 使用 Docker 运行 MySQL
    • /zh/42_mysql/02.html
  • 41_postgresql

    • PostgreSQL 安装
    • PostgreSQL 主键自增
    • PostgreSQL 日期类型
    • Postgresql 金融类型
    • PostgreSQL 数组类型
    • PostgreSQL 全文检索
    • PostgreSQL 查询优化
    • 获取字段类型
    • PostgreSQL 向量
    • PostgreSQL 优化向量查询
    • PostgreSQL 其他
  • 43_oceanbase

    • 快速体验 OceanBase 社区版
    • 快速上手 OceanBase 数据库单机部署与管理
    • 诊断集群性能
    • 优化 SQL 性能指南
    • /zh/43_oceanbase/05.html
  • 50_media

    • JAVE 提取视频中的声音
    • Jave 提取视频中的图片
    • /zh/50_media/03.html
  • 51_asr

    • Whisper-JNI
  • 54_native-media

    • java-native-media
    • JNI 入门示例
    • mp3 拆分
    • mp4 转 mp3
    • 使用 libmp3lame 实现高质量 MP3 编码
    • Linux 编译
    • macOS 编译
    • 从 JAR 包中加载本地库文件
    • 支持的音频和视频格式
    • 任意格式转为 mp3
    • 通用格式转换
    • 通用格式拆分
    • 视频合并
    • VideoToHLS
    • split_video_to_hls 支持其他语言
    • 持久化 HLS 会话
  • 55_telegram4j

    • 数据库设计
    • /zh/55_telegram4j/02.html
    • 基于 MTProto 协议开发 Telegram 翻译机器人
    • 过滤旧消息
    • 保存机器人消息
    • 定时推送
    • 增加命令菜单
    • 使用 telegram-Client
    • 使用自定义 StoreLayout
    • 延迟测试
    • Reactor 错误处理
    • Telegram4J 常见错误处理指南
  • 56_telegram-bots

    • TelegramBots 入门指南
    • 使用工具库 telegram-bot-base 开发翻译机器人
  • 60_LLM

    • 简介
    • AI 问答
    • /zh/60_LLM/03.html
    • /zh/60_LLM/04.html
    • 增强检索(RAG)
    • 结构化数据检索
    • 搜索+AI
    • 集成第三方 API
    • 后置处理
    • 推荐问题生成
    • 连接代码执行器
    • 避免 GPT 混乱
    • /zh/60_LLM/13.html
  • 61_ai_agent

    • 数据库设计
    • 示例问题管理
    • 会话管理
    • 历史记录
    • 对接 Perplexity API
    • 意图识别与生成提示词
    • 智能问答模块设计与实现
    • 文件上传与解析文档
    • 翻译
    • 名人搜索功能实现
    • Ai studio gemini youbue 问答使用说明
    • 自建 YouTube 字幕问答系统
    • 自建 获取 youtube 字幕服务
    • 通用搜索
    • /zh/61_ai_agent/15.html
    • 16
    • 17
    • 18
    • 在 tio-boot 应用中整合 ai-agent
    • 16
  • 62_translator

    • 简介
  • 63_knowlege_base

    • 数据库设计
    • 用户登录实现
    • 模型管理
    • 知识库管理
    • 文档拆分
    • 片段向量
    • 命中测试
    • 文档管理
    • 片段管理
    • 问题管理
    • 应用管理
    • 向量检索
    • 推理问答
    • 问答模块
    • 统计分析
    • 用户管理
    • api 管理
    • 存储文件到 S3
    • 文档解析优化
    • 片段汇总
    • 段落分块与检索
    • 多文档解析
    • 对话日志
    • 检索性能优化
    • Milvus
    • 文档解析方案和费用对比
    • 离线运行向量模型
  • 64_ai-search

    • ai-search 项目简介
    • ai-search 数据库文档
    • ai-search SearxNG 搜索引擎
    • ai-search Jina Reader API
    • ai-search Jina Search API
    • ai-search 搜索、重排与读取内容
    • ai-search PDF 文件处理
    • ai-search 推理问答
    • Google Custom Search JSON API
    • ai-search 意图识别
    • ai-search 问题重写
    • ai-search 系统 API 接口 WebSocket 版本
    • ai-search 搜索代码实现 WebSocket 版本
    • ai-search 生成建议问
    • ai-search 生成问题标题
    • ai-search 历史记录
    • Discover API
    • 翻译
    • Tavily Search API 文档
    • 对接 Tavily Search
    • 火山引擎 DeepSeek
    • 对接 火山引擎 DeepSeek
    • ai-search 搜索代码实现 SSE 版本
    • jar 包部署
    • Docker 部署
    • 爬取一个静态网站的所有数据
    • 网页数据预处理
    • 网页数据检索与问答流程整合
  • 65_java-linux

    • Java 执行 python 代码
    • 通过大模型执行 Python 代码
    • MCP 协议
    • Cline 提示词
    • Cline 提示词-中文版本
  • 66_manim

    • 简介
    • Manim 开发环境搭建
    • 生成场景提示词
    • 生成代码
    • 完整脚本示例
    • 语音合成系统
    • Fish.audio TTS 接口说明文档与 Java 客户端封装
    • 整合 fishaudio 到 java-uni-ai-server 项目
    • 执行 Python (Manim) 代码
    • 使用 SSE 流式传输生成进度的实现文档
    • 整合全流程完整文档
    • HLS 动态推流技术文档
    • manim 分场景生成代码
    • 分场景运行代码及流式播放支持
    • 分场景业务端完整实现流程
    • Maiim布局管理器
    • 仅仅生成场景代码
    • 使用 modal 运行 manim 代码
    • Python 使用 Modal GPU 加速渲染
    • Modal 平台 GPU 环境下运行 Manim
    • Modal Manim OpenGL 安装与使用
    • 优化 GPU 加速
    • 生成视频封面流程
    • Java 调用 manim 命令 执行代码 生成封面
    • Manim 图像生成服务客户端文档
    • manim render help
    • 显示 中文公式
    • manimgl
    • EGL
    • /zh/66_manim/30.html
    • /zh/66_manim/31.html
    • 成本核算
    • /zh/66_manim/33.html
  • 70_tio-boot-admin

    • 入门指南
    • 初始化数据
    • token 存储
    • 与前端集成
    • 文件上传
    • 网络请求
    • 图片管理
    • /zh/70_tio-boot-admin/08.html
    • Word 管理
    • PDF 管理
    • 文章管理
    • 富文本编辑器
  • 71_tio-boot

    • /zh/71_tio-boot/01.html
    • Swagger 整合到 Tio-Boot 中的指南
    • HTTP/1.1 Pipelining 性能测试报告
  • 80_性能测试

    • 压力测试 - tio-http-serer
    • 压力测试 - tio-boot
    • 压力测试 - tio-boot-native
    • 压力测试 - netty-boot
    • 性能测试对比
    • TechEmpower FrameworkBenchmarks
    • 压力测试 - tio-boot 12 C 32G
  • 99_案例

    • 封装 IP 查询服务
    • tio-boot 案例 - 全局异常捕获与企业微信群通知
    • tio-boot 案例 - 文件上传和下载
    • tio-boot 案例 - 整合 ant design pro 增删改查
    • tio-boot 案例 - 流失响应
    • tio-boot 案例 - 增强检索
    • tio-boot 案例 - 整合 function call
    • tio-boot 案例 - 定时任务 监控 PostgreSQL、Redis 和 Elasticsearch
    • Tio-Boot 案例:使用 SQLite 整合到登录注册系统
    • tio-boot 案例 - 执行 shell 命令

监控: 客户端的流量数据

概述

本文介绍了如何使用 Tio-boot 通过 MyIpStatListener 来监控基于客户端 IP 的网络流量数据。通过这种方式,可以获取有关网络通信的详细数据,如连接请求次数、发送和接收的字节数、处理消息包的时间等。

实现步骤

IpStatDuration

定义 IP 统计时段,以 5 分钟为例:


import com.litongjava.jfinal.aop.Aop;
import com.litongjava.tio.core.ChannelContext;
import com.litongjava.tio.core.Node;
import com.litongjava.tio.core.TioConfig;
import com.litongjava.tio.core.intf.Packet;
import com.litongjava.tio.core.stat.IpStat;
import com.litongjava.tio.core.stat.IpStatListener;
import com.litongjava.tio.http.common.HttpRequest;
import com.litongjava.tio.http.common.utils.HttpIpUtils;
import com.litongjava.tio.utils.json.JsonUtils;
import com.litongjava.tio.utils.thread.TioThreadUtils;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class MyIpStatListener implements IpStatListener {
  public static final MyIpStatListener me = new MyIpStatListener();

  private MyIpStatListener() {
  }

  @Override
  public void onAfterConnected(ChannelContext channelContext, boolean isConnected, boolean isReconnect, IpStat ipStat) throws Exception {
    if (log.isInfoEnabled()) {
      log.info("连接成功:{}", JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onAfterReceivedBytes(ChannelContext channelContext, int receivedBytes, IpStat ipStat) throws Exception {
    if (log.isInfoEnabled()) {
      log.info("接收字节数:{}", JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onAfterDecoded(ChannelContext channelContext, Packet packet, int packetSize, IpStat ipStat) throws Exception {
    if (log.isInfoEnabled()) {
      if (packet instanceof HttpRequest) {
        // 获取真实IP
        String realIp = HttpIpUtils.getRealIp((HttpRequest) packet);
        // 设置真实IP
        ipStat.setIp(realIp);
        int port = channelContext.getClientNode().getPort();
        channelContext.setProxyClientNode(new Node(realIp, port));
        TioConfig tioConfig = channelContext.getTioConfig();
        // 将真实IP添加到内置监控
        for (Long v : tioConfig.ipStats.durationList) {
          tioConfig.ipStats.get(v, channelContext);
        }
      }
      log.info("消息解码完成:{} {}", packet.logstr(), JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onDecodeError(ChannelContext channelContext, IpStat ipStat) {
    if (log.isInfoEnabled()) {
      log.info("解码错误:{}", JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onAfterHandled(ChannelContext channelContext, Packet packet, IpStat ipStat, long cost) throws Exception {
    if (log.isInfoEnabled()) {
      log.info("消息处理完成:{} {}", packet.logstr(), JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onAfterSent(ChannelContext channelContext, Packet packet, boolean isSentSuccess, IpStat ipStat) throws Exception {
    if (log.isInfoEnabled()) {
      log.info("消息发送完成:{} {}", packet.logstr(), JsonUtils.toJson(ipStat));
    }
  }

  @Override
  public void onExpired(TioConfig tioConfig, IpStat ipStat) {
    // 当统计数据过期时,可以将数据入库或记录日志
    TioThreadUtils.submit(() -> {
      log.info("统计数据过期,数据如下:{}", JsonUtils.toJson(ipStat));
      Aop.get(SysIpStatService.class).save(ipStat);
    });

  }
}

配置 TioBootServerConfig

配置 TioBootServerConfig,启用 IP 统计监听器,并设定统计时段:

package com.litongjava.tio.web.hello.config;

import com.litongjava.jfinal.aop.annotation.AConfiguration;
import com.litongjava.jfinal.aop.annotation.AInitialization;
import com.litongjava.tio.boot.server.TioBootServer;
import com.litongjava.tio.server.ServerTioConfig;
import com.litongjava.tio.web.hello.stat.IpStatDuration;
import com.litongjava.tio.web.hello.stat.MyIpStatListener;

@AConfiguration
public class TioBootServerConfig {

  @Initialization
  public void config() {
    TioBootServer server = TioBootServer.me();
    ServerTioConfig serverTioConfig = server.getServerTioConfig();
    serverTioConfig.debug = true;

    // 设置 IP 统计监听器
    serverTioConfig.setIpStatListener(MyIpStatListener.me);
    // 设置 IP 统计时段
    serverTioConfig.ipStats.addDurations(IpStatDuration.IPSTAT_DURATIONS);
  }
}

实现原理

MyIpStatListener

MyIpStatListener 提供了多种数据获取的时机,可以监控网络通信的各个阶段:

  1. onExpired: 当 IP 统计数据过期时被触发,适合将数据存储到数据库或记录日志。
  2. onAfterConnected: 客户端与服务器成功建立连接后触发,提供有关该连接的统计信息。
  3. onDecodeError: 当发生解码错误时触发,可以记录解码失败的次数。
  4. onAfterSent: 消息发送完成后触发,统计有关发送的消息包和字节数。
  5. onAfterDecoded: 消息解码完成后触发,记录已解码的消息包数量和字节数。
  6. onAfterReceivedBytes: 接收字节数后触发,统计接收到的数据量。
  7. onAfterHandled: 消息处理完成后触发,记录处理消息的时间和资源消耗。

IP 统计时段的作用

IP 统计时段 是指服务器对每个 IP 进行统计的时间窗口。在配置时通过 IpStatDuration 类中的 DURATION_1 设置为 5 分钟(300 秒)。每 5 分钟为一个时间窗口,在这段时间内收集统计信息,比如 IP 发送的字节数、接收的字节数、错误次数等。当时间窗口结束时,onExpired 方法会被调用,清除过期的数据并进行处理。

IpStat

IpStat 类用于监控基于客户端 IP 的网络流量数据,帮助识别恶意行为(如攻击),或者记录某个 IP 的通信状况。以下是 IpStat 类中各个字段的详细解释:

  1. start (Date start)
    记录了统计数据的开始时间。该时间戳用于确定统计数据的起点。

  2. duration (long duration)
    记录了当前统计持续了多长时间,单位是毫秒。这个值通常在 getDuration() 方法中动态计算,表示自 start 开始到当前的时间差。

  3. durationType (Long durationType)
    记录统计时段的长度,单位是秒。常见的时段有 60 秒、3600 秒等,这个字段主要用于设定 IP 监控的时间窗口。

  4. ip (String ip)
    客户端的 IP 地址,表示当前监控的是哪个 IP 的数据。

  5. decodeErrorCount (AtomicInteger decodeErrorCount)
    解码错误的次数。如果某个 IP 在解码请求数据时频繁出错,表明该 IP 存在潜在的攻击行为或其他异常。

  6. requestCount (AtomicInteger requestCount)
    该 IP 发起的连接请求次数,表明该 IP 多次与服务器建立连接。

  7. sentBytes (AtomicLong sentBytes)
    服务器向该 IP 发送的字节数总量。这个字段帮助监控服务器发送给客户端的数据流量。

  8. sentPackets (AtomicLong sentPackets)
    服务器向该 IP 发送的数据包数量。这与 sentBytes 配合使用,可以更好地分析发送的数据包大小和频率。

  9. handledBytes (AtomicLong handledBytes)
    服务器处理的数据字节数总量(针对该 IP)。这个字段监控的是服务器处理来自该 IP 的流量。

  10. handledPackets (AtomicLong handledPackets)
    服务器处理的数据包数量(针对该 IP)。配合 handledBytes,可以反映服务器为该 IP 处理的数据包频率和数据量。

  11. handledPacketCosts (AtomicLong handledPacketCosts)
    处理消息包的总耗时,单位为毫秒。这个字段用于监控服务器处理某个 IP 的请求时花费的总时间,衡量服务器的响应性能。

  12. receivedBytes (AtomicLong receivedBytes)
    服务器从该 IP 接收到的字节总量。此字段监控该 IP 向服务器发送的数据量,用于监控流量和发现异常行为。

  13. receivedTcps (AtomicLong receivedTcps)
    服务器从该 IP 接收到的 TCP 数据包总数。此字段用于监控网络层传输,判断 TCP 层的通信量。

  14. receivedPackets (AtomicLong receivedPackets)
    服务器从该 IP 接收到的应用层数据包总数。与 receivedTcps 相对应,此字段用于监控具体的业务数据包。

  15. getBytesPerTcpReceive()
    计算每个 TCP 连接接收到的平均字节数。可以用于检测慢速攻击(Slow Attack),如果每个 TCP 包接收到的字节数特别少,表明潜在的慢速攻击。

  16. getPacketsPerTcpReceive()
    计算每个 TCP 连接接收到的业务包的平均数量。与慢速攻击检测相关,如果该值较低,表明攻击行为。

  17. getHandledCostsPerPacket()
    计算每个数据包的平均处理耗时。该值用于衡量服务器的性能以及对该 IP 请求的处理效率。

小结

  • 流量数据统计:IpStat 可以帮助收集某个 IP 的发送、接收字节数和数据包数,以及服务器处理这些数据包的时长。
  • 异常行为检测:通过统计错误解码次数、每个 TCP 包的字节数等,可以用于检测慢速攻击、异常连接等问题。
  • 性能监控:通过统计数据包处理时间,可以用于监控服务器的性能瓶颈,分析某些 IP 是否消耗了过多资源。

这套统计机制可以帮助系统实时监控 IP 流量,发现潜在的攻击,优化服务器资源分配。

IpStatListener 详解

在 Tio-boot 环境下,MyIpStatListener 提供了一系列接口用于监控和记录基于客户端 IP 的流量数据。这些接口在网络通信的不同阶段被触发,帮助开发者了解和分析通信过程中的各类事件。以下将详细解释这些接口的调用顺序,并结合提供的日志示例解析日志中各字段的数据含义。

日志

2024-09-08 12:41:30.019 [tio-group-2] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterConnected:22 - 连接成功:{"duration":"-1","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":0.0,"receivedPackets":0,"packetsPerTcpReceive":0.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":0,"handledBytes":0,"receivedTcps":0,"sentBytes":0,"requestCount":1,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"0毫秒"}
2024-09-08 12:41:30.022 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterReceivedBytes:29 - 接收字节数:{"duration":"-1","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":1469.0,"receivedPackets":0,"packetsPerTcpReceive":0.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":0,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"0毫秒"}
2024-09-08 12:41:30.029 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterDecoded:36 - 消息解码完成:request ID_1
 {"duration":"15","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":0,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"15毫秒"}
2024-09-08 12:41:30.216 [tio-group-3] INFO  c.l.t.b.h.h.DefaultHttpRequestHandler.handler:317 -
-----------action report---------------------
request:GET / HTTP/1.1
method:public com.litongjava.tio.utils.resp.RespBodyVo com.litongjava.tio.web.hello.controller.IndexController.index()

2024-09-08 12:41:30.231 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterHandled:50 - 消息处理完成:request ID_1
 {"duration":"216","handledPacketCosts":201,"handledPackets":1,"handledCostsPerPacket":201.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":1469,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"216毫秒"}
2024-09-08 12:41:30.235 [tio-group-5] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterSent:57 - 消息发送完成:reponse: requestID_1  /
 {"duration":"216","handledPacketCosts":201,"handledPackets":1,"handledCostsPerPacket":201.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":2,"receivedBytes":1469,"handledBytes":1469,"receivedTcps":1,"sentBytes":274,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"216毫秒"}

1、接口调用顺序

根据提供的日志示例,以下是各接口的典型调用顺序:

  1. onAfterConnected

    • 触发时机:当客户端与服务器成功建立连接后立即触发。
    • 作用:记录连接建立的统计信息,如连接时间、客户端 IP 等。
  2. onAfterReceivedBytes

    • 触发时机:服务器接收到来自客户端的字节数据后触发。
    • 作用:统计接收到的字节数、TCP 数据包数等信息。
  3. onAfterDecoded

    • 触发时机:服务器成功解码接收到的数据包后触发。
    • 作用:记录解码完成的消息包数量和字节数。
  4. 业务逻辑处理

    • 触发时机:服务器处理解码后的业务请求,此阶段涉及控制器处理请求。
    • 作用:执行业务逻辑,如处理 HTTP 请求、生成响应等。
  5. onAfterHandled

    • 触发时机:服务器完成业务逻辑处理后触发。
    • 作用:记录处理完成的消息包数量、处理耗时等信息。
  6. onAfterSent

    • 触发时机:服务器完成向客户端发送响应后触发。
    • 作用:统计发送的消息包和字节数,以及发送是否成功。
  7. onExpired

    • 触发时机:IP 统计数据超过设定的统计时段(如 5 分钟)后触发。
    • 作用:处理过期的统计数据,如将数据存储到数据库或记录日志。

注意:onDecodeError 仅在发生数据解码错误时触发。在提供的日志示例中未出现解码错误,因此未调用该接口。

2、日志数据含义解析

以下是提供的日志示例及其解析:

1. onAfterConnected

2024-09-08 12:41:30.019 [tio-group-2] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterConnected:22 - 连接成功:{"duration":"-1","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":0.0,"receivedPackets":0,"packetsPerTcpReceive":0.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":0,"handledBytes":0,"receivedTcps":0,"sentBytes":0,"requestCount":1,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"0毫秒"}
  • 触发时机: 当客户端与服务器成功建立连接后。
  • 关键字段:
    • ip: 客户端 IP 地址,0:0:0:0:0:0:0:1 表示本地回环地址。
    • requestCount: 请求次数,1 表示首次请求。
    • duration: 持续时间,初始值为 -1 表示还没有数据传输。
  • 含义: 客户端与服务器成功建立了连接,初始化了 IP 统计信息。

2. onAfterReceivedBytes

2024-09-08 12:41:30.022 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterReceivedBytes:29 - 接收字节数:{"duration":"-1","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":1469.0,"receivedPackets":0,"packetsPerTcpReceive":0.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":0,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"0毫秒"}
  • 触发时机: 当服务器从客户端接收到字节数据后。
  • 关键字段:
    • receivedBytes: 收到的字节数,1469 字节。
    • bytesPerTcpReceive: 每个 TCP 接收的字节数为 1469.0。
  • 含义: 服务器从客户端接收了 1469 字节的数据。

3. onAfterDecoded

2024-09-08 12:41:30.029 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterDecoded:36 - 消息解码完成:request ID_1
 {"duration":"15","handledPacketCosts":0,"handledPackets":0,"handledCostsPerPacket":0.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":0,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"15毫秒"}
  • 触发时机: 服务器成功解码收到的数据包后。
  • 关键字段:
    • receivedPackets: 收到的业务包数量为 1。
    • formatedDuration: 持续时间为 15 毫秒。
  • 含义: 服务器成功解码了从客户端接收到的一个业务数据包。

4. 业务逻辑处理

2024-09-08 12:41:30.216 [tio-group-3] INFO  c.l.t.b.h.h.DefaultHttpRequestHandler.handler:317 -
-----------action report---------------------
request:GET / HTTP/1.1
method:public com.litongjava.tio.utils.resp.RespBodyVo com.litongjava.tio.web.hello.controller.IndexController.index()
  • 触发时机: 业务逻辑处理阶段。
  • 内容: 处理 GET / 请求,由 IndexController.index() 方法处理。
  • 含义: 服务器处理了来自客户端的 HTTP 请求。

5. onAfterHandled

2024-09-08 12:41:30.231 [tio-group-3] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterHandled:50 - 消息处理完成:request ID_1
 {"duration":"216","handledPacketCosts":201,"handledPackets":1,"handledCostsPerPacket":201.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":0,"receivedBytes":1469,"handledBytes":1469,"receivedTcps":1,"sentBytes":0,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"216毫秒"}
  • 触发时机: 业务逻辑处理完成后。
  • 关键字段:
    • handledPackets: 处理的包数为 1。
    • handledPacketCosts: 消息包处理耗时为 201 毫秒。
  • 含义: 服务器成功处理了一个消息包,耗时 201 毫秒。

6. onAfterSent

2024-09-08 12:41:30.235 [tio-group-5] INFO  c.l.t.w.h.s.MyIpStatListener.onAfterSent:57 - 消息发送完成:reponse: requestID_1  /
 {"duration":"216","handledPacketCosts":201,"handledPackets":1,"handledCostsPerPacket":201.0,"bytesPerTcpReceive":1469.0,"receivedPackets":1,"packetsPerTcpReceive":1.0,"ip":"0:0:0:0:0:0:0:1","sentPackets":2,"receivedBytes":1469,"handledBytes":1469,"receivedTcps":1,"sentBytes":274,"requestCount":2,"start":"2024-09-08 12:41:30","durationType":"300","decodeErrorCount":0,"formatedDuration":"216毫秒"}
  • 触发时机: 服务器向客户端发送响应后。

  • 关键字段:

    • sentBytes: 发送的字节数为 274。
    • sentPackets: 发送的包数量为 2。
  • 含义: 服务器成功向客户端发送了 2 个包,合计 274 字节。

3、日志字段详细解释

以下是日志中 IpStat 对象各字段的详细解释,结合上述日志示例中的数据:

  1. duration

    • 含义:当前统计的持续时间,单位为毫秒。
    • 示例:
      • -9: 是初始值或计算错误。
      • 6: 6 毫秒。
      • 209: 209 毫秒。
  2. bytesPerTcpReceive

    • 含义:每个 TCP 接收的平均字节数。
    • 示例:1495.0 表示每个 TCP 数据包平均接收 1495 字节。
  3. packetsPerTcpReceive

    • 含义:每个 TCP 接收的业务包数量。
    • 示例:
      • 初始为 0.0。
      • 更新为 1.0,表示每个 TCP 数据包对应一个业务包。
  4. handledPackets

    • 含义:服务器处理的消息包数量。
    • 示例:0 表示尚未处理,1 表示已处理一个消息包。
  5. receivedPackets

    • 含义:服务器接收到的业务包数量。
    • 示例:0 表示尚未接收,1 表示已接收一个业务包。
  6. handledPacketCosts

    • 含义:处理消息包的总耗时,单位为毫秒。
    • 示例:203 表示处理一个消息包耗时 203 毫秒。
  7. handledCostsPerPacket

    • 含义:每个消息包的平均处理耗时,单位为毫秒。
    • 示例:203.0 毫秒。
  8. ip

    • 含义:客户端的 IP 地址。
    • 示例:0:0:0:0:0:0:0:1 表示本地回环地址(IPv6)。
  9. handledBytes

    • 含义:服务器处理的总字节数,针对该 IP。
    • 示例:0 表示尚未处理,1495 表示已处理 1495 字节。
  10. receivedBytes

    • 含义:服务器从该 IP 接收到的总字节数。
    • 示例:0 表示尚未接收,1495 表示已接收 1495 字节。
  11. sentPackets

    • 含义:服务器发送给该 IP 的消息包数量。
    • 示例:0 表示尚未发送,日志中未更新。
  12. sentBytes

    • 含义:服务器发送给该 IP 的总字节数。
    • 示例:0 表示尚未发送,日志中未更新。
  13. receivedTcps

    • 含义:服务器从该 IP 接收到的 TCP 数据包数量。
    • 示例:
      • 初始为 0。
      • 更新为 1,表示接收到一个 TCP 数据包。
  14. requestCount

    • 含义:来自该 IP 的连接请求次数。
    • 示例:1 表示一次连接请求。
  15. start

    • 含义:统计开始时间。
    • 示例:2024-09-08 11:59:08。
  16. decodeErrorCount

    • 含义:解码错误的次数。
    • 示例:0 表示无解码错误。
  17. formatedDuration

    • 含义:格式化的统计持续时间,便于阅读。
    • 示例:
      • "0毫秒"
      • "6毫秒"
      • "209毫秒"
  18. durationType

    • 含义:统计时段的长度,单位为秒。
    • 示例:"300" 表示 5 分钟(300 秒)的统计窗口。

4、总结

通过上述日志示例和字段解释,可以清晰地了解在一次完整的客户端请求过程中,MyIpStatListener 各接口的调用顺序及其所记录的数据含义。具体流程如下:

  1. 连接建立:onAfterConnected 被调用,记录连接建立的信息。
  2. 数据接收:onAfterReceivedBytes 被调用,统计接收到的数据量和 TCP 数据包数。
  3. 数据解码:onAfterDecoded 被调用,记录解码完成的消息包数量。
  4. 业务处理:服务器通过控制器处理业务逻辑,相关日志记录处理过程。
  5. 处理完成:onAfterHandled 被调用,记录处理完成的消息包数量和耗时。
  6. 响应发送:onAfterSent 被调用,记录响应发送的信息。
  7. 数据过期:若统计数据超过设定的时间窗口(如 5 分钟),onExpired 被触发,处理过期的数据。

这种详细的日志记录机制,有助于开发者实时监控网络通信的各个环节,分析性能瓶颈,发现潜在的异常行为,并优化系统的整体性能和安全性。

统计数据入库

onExpired 数据

MyIpStatListener onExpired 返回的统计数据如下

{
  "durationType": "1",
  "duration": "17833",
  "handledPackets": 1,
  "bytesPerTcpReceive": 1469.0,
  "packetsPerTcpReceive": 1.0,
  "receivedPackets": 1,
  "handledCostsPerPacket": 237.0,
  "handledPacketCosts": 237,
  "sentPackets": 2,
  "receivedTcps": 1,
  "sentBytes": 1315,
  "receivedBytes": 1469,
  "handledBytes": 1469,
  "ip": "0:0:0:0:0:0:0:1",
  "formatedDuration": "17秒833毫秒",
  "start": "2024-09-08 18:22:31",
  "requestCount": 2,
  "decodeErrorCount": 0
}
  1. durationType: "1",表示统计的时间类型,通常用于标识统计周期。
  2. duration: "17833" 毫秒,即统计周期的持续时间为 17 秒 833 毫秒。
  3. handledPackets: "1",表示处理的总数据包数。
  4. bytesPerTcpReceive: "1469.0",每个 TCP 接收包的字节数。
  5. packetsPerTcpReceive: "1.0",每个 TCP 接收包中的数据包数。
  6. receivedPackets: "1",接收到的数据包数。
  7. handledCostsPerPacket: "237.0",处理每个数据包的时间成本(毫秒)。
  8. handledPacketCosts: "237",处理数据包的总时间(毫秒)。
  9. sentPackets: "2",发送的数据包数。
  10. receivedTcps: "1",接收到的 TCP 连接数。
  11. sentBytes: "1315",发送的字节数。
  12. receivedBytes: "1469",接收到的字节数。
  13. handledBytes: "1469",处理的字节数。
  14. ip: "::1",IPv6 格式的本地 IP 地址(表示本地环回地址)。
  15. formatedDuration: "17 秒 833 毫秒",格式化后的持续时间。
  16. start: "2024-09-08 18:22:31",统计开始的时间戳。
  17. requestCount: "2",处理的请求总数。
  18. decodeErrorCount: "0",解码错误的次数。

这个统计数据反映了短时间内 IP 地址 ::1 的一个流量情况,包括接收和发送的数据包数量、字节数,以及处理这些数据包所花费的时间。

  • 该统计周期内有 1 个 TCP 接收,接收了 1 个数据包,大小为 1469 字节。
  • 系统共处理了 1 个数据包,处理时间为 237 毫秒。
  • 发送了 2 个数据包,发送字节总数为 1315。
  • 请求总数为 2,解码错误为 0。

创建表

这个统计数据是可以入库的,尤其是它提供了丰富的流量和性能统计信息,适合做 IP 流量监控、性能分析等。可以设计如下的数据库表结构来存储该数据: 将这些数据入库之后,可以进行定期分析,跟踪特定 IP 地址的流量情况,并检测处理时间和请求数量的变化情况,从而优化系统的性能。

CREATE TABLE sys_ip_stat (
  id BIGINT NOT NULL primary key,
  ip VARCHAR(39),                    -- IP地址
  duration_type INT,                 -- 时间类型
  duration BIGINT,                   -- 持续时间(毫秒)
  handled_packets INT,               -- 处理的数据包数
  bytes_per_tcp_receive DECIMAL,     -- 每个TCP接收包的字节数
  packets_per_tcp_receive DECIMAL,   -- 每个TCP接收包的数据包数
  received_packets INT,              -- 接收的数据包数
  handled_costs_per_packet DECIMAL,  -- 每个包的处理时间
  handled_packet_costs BIGINT,       -- 处理数据包的总时间
  sent_packets INT,                  -- 发送的数据包数
  received_tcps INT,                 -- 接收的TCP连接数
  sent_bytes BIGINT,                 -- 发送的字节数
  received_bytes BIGINT,             -- 接收的字节数
  handled_bytes BIGINT,              -- 处理的字节数
  formated_duration VARCHAR(50),     -- 格式化的持续时间
  start TIMESTAMP,                   -- 统计开始时间
  request_count INT,                 -- 请求数量
  decode_error_count INT,            -- 解码错误次数
  update_time TIMESTAMP WITHOUT TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP,
  deleted SMALLINT NOT NULL DEFAULT 0,
  tenant_id BIGINT NOT NULL DEFAULT 0
);

编写入库代码


import com.litongjava.db.activerecord.Db;
import com.litongjava.db.activerecord.Row;
import com.litongjava.tio.core.stat.IpStat;
import com.litongjava.tio.utils.mcid.McIdUtils;

public class SysIpStatService {

  public void save(IpStat ipStat) {
    Row row = Row.by("id", McIdUtils.id())
        //
        .set("ip", ipStat.getIp())
        //
        .set("duration_type", ipStat.getDurationType()).set("duration", ipStat.getDuration())
        //
        .set("handled_packets", ipStat.getHandledBytes())
        //
        .set("bytes_per_tcp_receive", ipStat.getBytesPerTcpReceive())
        //
        .set("packets_per_tcp_receive", ipStat.getPacketsPerTcpReceive())
        //
        .set("received_packets", ipStat.getReceivedPackets())
        //
        .set("handled_costs_per_packet", ipStat.getHandledCostsPerPacket())
        //
        .set("handled_packet_costs", ipStat.getHandledPacketCosts())
        //
        .set("sent_packets", ipStat.getSentPackets()).set("received_tcps", ipStat.getReceivedTcps())
        //
        .set("sent_bytes", ipStat.getSentBytes()).set("received_bytes", ipStat.getReceivedBytes())
        //
        .set("handled_bytes", ipStat.getHandledBytes()).set("formated_duration", ipStat.getFormatedDuration())
        //
        .set("start", ipStat.getStart()).set("request_count", ipStat.getRequestCount())
        //
        .set("decode_error_count", ipStat.getDecodeErrorCount());
    try {
      Db.save("sys_ip_stat", row);
    } catch (Exception e) {
      e.printStackTrace();
    }

  }

}

总结

通过 MyIpStatListener 和 IpStatDuration,我们可以实现基于客户端 IP 的详细流量监控,捕获网络通信中的各类事件。通过这些数据,可以优化服务器资源分配,检测异常行为,并提升系统的整体性能和安全性。

这种实现适用于需要对网络流量进行实时监控和分析的场景,特别是对高流量系统的监控非常有帮助。

参考文献

tiocloud 文档资料

Edit this page
Last Updated:
Contributors: Tong Li
Prev
监控: 心跳
Next
监控: 单条 TCP 连接的流量数据