本文介绍一种不依赖 redis、仅用 go 原生并发安全机制实现在线用户实时统计的方案：通过哈希 ip+useragent 生成匿名标识，配合定时清理的线程安全 map 实现低开销、高可用的在线用户追踪。
本文介绍一种不依赖 redis、仅用 go 原生并发安全机制实现在线用户实时统计的方案：通过哈希 ip+useragent 生成匿名标识，配合定时清理的线程安全 map 实现低开销、高可用的在线用户追踪。
在 Go Web 开发中，若需轻量级追踪“当前在线用户数”（例如最近 5 分钟内有活跃请求的用户），且不引入 Redis 等外部依赖，最合理的方式是采用内存 + 定时过期 + 并发保护的组合策略。该方案适用于单进程部署、中小流量场景，兼顾性能、隐私与实现简洁性。
Redis Skill - 高性能缓存管理
下载
Redis 缓存和数据结构管理技能。通过自然语言操作 Redis，支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。
核心设计思路
-
用户标识匿名化：不直接存储 IP 或 SessionID（避免隐私风险与会话管理复杂度），而是对
RemoteAddr（客户端 IP）与User-Agent字符串进行 SHA256 哈希，并 Base64 URL 编码，生成唯一且不可逆的匿名 ID。 -
内存存储 + 读写锁保护：使用
sync.RWMutex保护全局map[string]time.Time，确保高并发下的读写安全；RWMutex在读多写少场景下性能优于普通Mutex。 - 主动过期清理：启动一个后台 goroutine，按固定间隔（如 30 秒）扫描并删除早于设定窗口（如 5 分钟）的记录，避免内存无限增长。
完整可运行示例
package main
import (
"crypto/sha256"
"encoding/base64"
"log"
"net/http"
"sync"
"time"
)
var (
PurgeInterval = 5 * time.Minute
Identifiers = make(map[string]time.Time)
mu sync.RWMutex
)
// hashID 生成匿名用户标识（IP + UA）
func hashID(ip, ua string) string {
hasher := sha256.New()
hasher.Write([]byte(ip))
hasher.Write([]byte(ua))
return base64.URLEncoding.EncodeToString(hasher.Sum(nil))
}
// trackUser 记录用户最新活跃时间
func trackUser(ip, ua string) {
id := hashID(ip, ua)
mu.Lock()
Identifiers[id] = time.Now()
mu.Unlock()
}
// onlineCount 返回当前在线用户数（窗口内）
func onlineCount() int {
now := time.Now()
mu.RLock()
defer mu.RUnlock()
count := 0
for _, t := range Identifiers {
if t.After(now.Add(-PurgeInterval)) {
count++
}
}
return count
}
// purgeExpired 清理过期条目
func purgeExpired() {
ticker := time.NewTicker(30 * time.Second)
defer ticker.Stop()
for range ticker.C {
purgeTime := time.Now().Add(-PurgeInterval)
mu.Lock()
for k, v := range Identifiers {
if v.Before(purgeTime) {
delete(Identifiers, k)
}
}
mu.Unlock()
}
}
// Tracker 中间件：自动记录每次请求
type Tracker struct {
http.Handler
}
func NewTracker(h http.Handler) *Tracker {
return &Tracker{Handler: h}
}
func (t *Tracker) ServeHTTP(w http.ResponseWriter, r *http.Request) {
ip := getClientIP(r)
ua := r.UserAgent()
trackUser(ip, ua)
t.Handler.ServeHTTP(w, r)
}
// 简单获取真实 IP（支持 X-Forwarded-For）
func getClientIP(r *http.Request) string {
if ip := r.Header.Get("X-Forwarded-For"); ip != "" {
return ip
}
return r.RemoteAddr
}
// 示例 handler：返回当前在线人数
func statusHandler(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(http.StatusOK)
w.Write([]byte(`{"online": ` + string(rune(onlineCount())) + `}`))
}
func main() {
// 启动清理 goroutine
go purgeExpired()
// 构建路由
mux := http.NewServeMux()
mux.HandleFunc("/status", statusHandler)
mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte("Hello, tracked world!"))
})
// 包裹中间件
handler := NewTracker(mux)
srv := &http.Server{
Handler: handler,
Addr: ":8080",
WriteTimeout: 15 * time.Second,
ReadTimeout: 15 * time.Second,
}
log.Println("Server starting on :8080")
log.Fatal(srv.ListenAndServe())
}注意事项与最佳实践
- ✅ 排除非用户流量：生产环境中应在
trackUser前过滤爬虫（检查User-Agent是否含bot,crawler,rss等关键词）、健康检查路径（如/healthz）及静态资源请求（.js,.css, 图片等），避免虚高统计。 - ⚠️ 单机局限性：该方案仅适用于单进程部署；若使用多实例（如负载均衡后多个 Go 进程），各进程内存独立，无法共享状态——此时必须迁移到 Redis、etcd 或数据库等共享存储。
- ? 重启丢失数据：服务重启后
Identifiersmap 清空，计数归零。如需持久化，建议后续接入 Redis 的SET+EXPIRE或使用redis-go封装带 TTL 的 Set 操作。 - ?️ 隐私合规：哈希处理已去除原始 IP 和 UA，符合 GDPR/《个人信息保护法》中“去标识化”要求；但若需更高合规等级，可进一步截断 IP（如仅保留前两段）或加入随机盐值（salt）增强抗碰撞能力。
该方案以极简代码实现了生产可用的在线用户统计能力，是 Go 初学者进阶中间件开发与并发控制的典型范例，亦可作为向分布式架构演进的坚实起点。
