扩展数据类型:HyperLogLog / Bitmap / GEO / Stream

# 用户签到: bit 位 = 日期偏移量(0=1号, 1=2号...)
# key = sign:{uid}:{yyyy-MM}

# 用户 1001 在 6 月 1 日签到
SETBIT sign:1001:2024-06 0 1    → (integer) 0  ← 返回旧值

# 6 月 3 日签到
SETBIT sign:1001:2024-06 2 1    → (integer) 0

# 查询 6 月 2 日是否签到
GETBIT sign:1001:2024-06 1      → (integer) 0  ← 未签到

# 查询 6 月 3 日
GETBIT sign:1001:2024-06 2      → (integer) 1  ← 已签到

# 本月签到了几天
BITCOUNT sign:1001:2024-06    → (integer) 2

# 连续签到判断: 找第一个为 0 的位(即第一天未签到)
BITPOS sign:1001:2024-06 0    → (integer) 1  ← 第 2 天断签

# 多用户活跃统计: 哪些用户在周一和周二都活跃了?
# active:2024-06-01 → 用户ID为offset, 活跃则设为1
# active:2024-06-02 → 同上
BITOP AND active:both active:2024-06-01 active:2024-06-02
BITCOUNT active:both    → 连续两天都活跃的用户数

# 统计页面 UV
PFADD page:home:uv "user_1" "user_2" "user_3"    → (integer) 1
PFADD page:home:uv "user_2" "user_4"              → (integer) 1  ← user_2重复但不影响
PFADD page:home:uv "user_2"                       → (integer) 0  ← 无变化

PFCOUNT page:home:uv    → (integer) 4    ← 去重后 4 个独立用户

# 按天统计, 合并为周 UV
PFADD uv:2024-06-01 "u1" "u2" "u3"
PFADD uv:2024-06-02 "u2" "u3" "u4" "u5"

PFMERGE uv:week1 uv:2024-06-01 uv:2024-06-02
PFCOUNT uv:week1    → (integer) 5    ← 两天去重后的并集

# 存储几家门店的位置
GEOADD stores 116.397128 39.916527 "beijing_store"
GEOADD stores 121.473701 31.230416 "shanghai_store"
GEOADD stores 113.264385 23.129112 "guangzhou_store"
GEOADD stores 116.407526 39.904030 "tiananmen"

# 查看坐标
GEOPOS stores "beijing_store"
1) "116.39712780714035034"
2) "39.91652647362980844"

# 计算北京门店到天安门的距离
GEODIST stores "beijing_store" "tiananmen" KM
→ "1.3850"    ← 约 1.4 公里

# 北京到上海
GEODIST stores "beijing_store" "shanghai_store" KM
→ "1067.5980"

# 以天安门为中心, 搜索 5 公里内的门店
GEOSEARCH stores FROMMEMBER "tiananmen" BYRADIUS 5 KM ASC WITHCOORD WITHDIST
1) 1) "tiananmen"
   2) "0.0000"
   3) 1) "116.40752649307250977"
      2) "39.90403009498505874"
2) 1) "beijing_store"
   2) "1.3850"
   3) 1) "116.39712780714035034"
      2) "39.91652647362980844"

# 以经纬度为中心搜索(不依赖已有 member)
GEOSEARCH stores FROMLONLAT 116.40 39.91 BYRADIUS 2 KM ASC COUNT 3 WITHDIST
1) 1) "tiananmen"
   2) "0.8245"
2) 1) "beijing_store"
   2) "0.7410"

# 矩形范围搜索
GEOSEARCH stores FROMLONLAT 116.40 39.91 BYBOX 10 10 KM ASC

# 生产者: 发送订单事件
XADD orders * user_id 1001 action "create" amount 299
→ "1717200000000-0"    ← 自动生成的消息 ID

XADD orders * user_id 1002 action "pay" amount 599
→ "1717200000001-0"

XADD orders * user_id 1001 action "cancel" amount 299
→ "1717200000002-0"

# 查看消息数
XLEN orders    → (integer) 3

# 读取全部消息
XRANGE orders - +
1) 1) "1717200000000-0"
   2) 1) "user_id" 2) "1001" 3) "action" 4) "create" 5) "amount" 6) "299"
2) 1) "1717200000001-0"
   2) 1) "user_id" 2) "1002" 3) "action" 4) "pay" 5) "amount" 6) "599"
3) 1) "1717200000002-0"
   2) 1) "user_id" 2) "1001" 3) "action" 4) "cancel" 5) "amount" 6) "299"

# 限制 Stream 最多保留 1000 条(近似裁剪用 ~)
XADD orders MAXLEN ~ 1000 * user_id 1003 action "create" amount 199

# 消费者: 阻塞等待新订单(类似 BLPOP)
XREAD BLOCK 0 STREAMS orders $
# ... 阻塞等待中, 有新消息时立即返回

# 创建消费者组(从头开始消费)
XGROUP CREATE orders order_processors 0
OK

# 消费者 worker_1 读取消息
XREADGROUP GROUP order_processors worker_1 COUNT 1 STREAMS orders >
1) 1) "orders"
   2) 1) 1) "1717200000000-0"
         2) 1) "user_id" 2) "1001" 3) "action" 4) "create" 5) "amount" 6) "299"

# 消费者 worker_2 读取消息(获得下一条, 不重复)
XREADGROUP GROUP order_processors worker_2 COUNT 1 STREAMS orders >
1) 1) "orders"
   2) 1) 1) "1717200000001-0"
         2) 1) "user_id" 2) "1002" 3) "action" 4) "pay" 5) "amount" 6) "599"

# worker_1 处理完毕, 确认
XACK orders order_processors "1717200000000-0"
→ (integer) 1

# 查看未确认消息(PEL)
XPENDING orders order_processors - + 10
1) 1) "1717200000001-0"
   2) "worker_2"
   3) (integer) 30000    ← 距上次投递已过 30 秒
   4) (integer) 1        ← 投递次数

# worker_2 挂了, 30 秒后将其未确认消息转给 worker_3
XCLAIM orders order_processors worker_3 30000 "1717200000001-0"
→ 1) 1) "1717200000001-0"
      2) 1) "user_id" 2) "1002" ...