用OpenResty shared_dict做实时流量统计更高效轻量,关键在于维度化键设计、原子incr更新和安全读取;需在log_by_lua阶段埋点,用content_by_lua暴露查询接口,并通过时间前缀或手动校验实现过期控制。

直接用 OpenResty 的 shared_dict 做实时流量统计,比写日志再解析快得多,也更轻量。关键不是“存数据”,而是怎么设计结构、怎么原子更新、怎么安全读取。
共享字典的初始化与结构设计
在 http 块里定义一个共享内存区域,比如:
lua_shared_dict req_counter 10m;
这个 10MB 足够支撑数万 QPS 的计数场景。结构上建议按“维度 + 时间窗口”组织键名,例如:
-
req:20260507:19:prod_api—— 每分钟统计 prod_api 接口调用量 -
req:ip:192.168.1.100—— 单 IP 实时请求数(用于限流) -
req:upstream:backend_canary—— 灰度分组当前已转发请求数
避免用长字符串或嵌套 JSON 作 key,key 要简洁可预测,value 统一用整数(Lua 中用 ngx.shared.DICT:incr() 原子自增)。
在请求生命周期中埋点计数
推荐在 log_by_lua* 阶段更新计数,确保无论 upstream 是否成功、响应是否返回,只要请求进入 Nginx 就被记录:
log_by_lua_block {
local dict = ngx.shared.req_counter
local now = ngx.now()
local date = os.date("%Y%m%d", now)
local hour = os.date("%H", now)
local uri = ngx.var.uri
<pre class='brush:php;toolbar:false;'>-- 按接口路径统计(自动截断长 path 防 key 过长)
local path_key = "req:" .. date .. ":" .. hour .. ":" .. (string.sub(uri, 1, 32) or "unknown")
dict:incr(path_key, 1, 0)
-- 同时记 IP 维度(可选)
local ip = ngx.var.remote_addr
dict:incr("req:ip:" .. ip, 1, 0)}
注意:incr(key, step, init) 的 init 参数设为 0 表示首次写入时从 0 开始,避免 nil 报错;该操作是原子的,无需加锁。
对外提供统计查询接口
用 content_by_lua 暴露一个内部 API,比如 /api/stats?scope=minute&group=prod_api:
- 解析参数,拼出对应 key(如
req:20260507:19:prod_api) - 调用
dict:get(key)读取当前值,不存在则返回 0 - 返回 JSON:
{"count": 1428, "timestamp": 1746644400}
可配合定时任务每分钟拉取一次,绘制成监控图表;也可在 balancer_by_lua 阶段读取该值,动态调整路由权重(比如某后端请求超阈值就降权)。
清理与过期控制
shared_dict 不支持 TTL,需自行管理过期:
- 不依赖自动过期时,用时间戳前缀(如
req:20260507:19:...)天然隔离旧数据 - 需要精确过期可额外存一个“最后更新时间”,读取时判断是否超时,超时则重置
- 避免遍历全量 key(性能差),只查已知结构的 key
若长期运行后发现内存占用持续上涨,大概率是 key 泄漏(比如带随机参数的 URI 未归一化),应提前对 ngx.var.uri 做标准化处理(如去掉 query string 或哈希化)。


















