计数器 #

计数器特点：

✓ 64位有符号整数
✓ 支持原子递增/递减
✓ 分布式安全
✓ 高性能

计数器限制：

表限制
├── 计数器表只能包含主键和计数器列
├── 不能包含其他类型的列
└── 不能设置TTL

操作限制
├── 只能递增/递减
├── 不能直接设置值
└── 不能使用轻量级事务

CREATE TABLE table_name (
    pk_column data_type,
    counter_column COUNTER,
    ...
    PRIMARY KEY (pk_column)
);

-- 用户统计计数器
CREATE TABLE user_counters (
    user_id UUID PRIMARY KEY,
    login_count COUNTER,
    page_views COUNTER,
    purchase_count COUNTER
);

-- 全局统计计数器
CREATE TABLE global_counters (
    counter_name TEXT PRIMARY KEY,
    counter_value COUNTER
);

-- 多维度计数器
CREATE TABLE daily_stats (
    stat_date DATE,
    stat_type TEXT,
    stat_value COUNTER,
    PRIMARY KEY (stat_date, stat_type)
);

-- 递增1
UPDATE user_counters 
SET login_count = login_count + 1
WHERE user_id = ?;

-- 递增指定值
UPDATE user_counters 
SET page_views = page_views + 10
WHERE user_id = ?;

-- 多列递增
UPDATE user_counters 
SET login_count = login_count + 1,
    page_views = page_views + 5,
    purchase_count = purchase_count + 1
WHERE user_id = ?;

-- 递减1
UPDATE user_counters 
SET login_count = login_count - 1
WHERE user_id = ?;

-- 递减指定值
UPDATE user_counters 
SET page_views = page_views - 5
WHERE user_id = ?;

-- 批量更新计数器
BEGIN COUNTER BATCH
    UPDATE user_counters 
    SET login_count = login_count + 1
    WHERE user_id = ?;
    
    UPDATE global_counters 
    SET counter_value = counter_value + 1
    WHERE counter_name = 'total_logins';
APPLY BATCH;

-- 查询单个计数器
SELECT login_count FROM user_counters 
WHERE user_id = ?;

-- 查询多个计数器
SELECT login_count, page_views, purchase_count 
FROM user_counters 
WHERE user_id = ?;

-- 查询所有计数器
SELECT * FROM user_counters WHERE user_id = ?;

-- 按日期范围查询
SELECT * FROM daily_stats 
WHERE stat_date >= '2024-01-01' 
AND stat_date <= '2024-01-31';

-- 按类型查询
SELECT * FROM daily_stats 
WHERE stat_date = '2024-01-15' 
AND stat_type IN ('logins', 'page_views');

-- 用户行为计数
CREATE TABLE user_behavior_counters (
    user_id UUID,
    behavior_type TEXT,
    count COUNTER,
    PRIMARY KEY (user_id, behavior_type)
);

-- 更新
UPDATE user_behavior_counters 
SET count = count + 1
WHERE user_id = ? AND behavior_type = 'login';

-- 查询
SELECT * FROM user_behavior_counters 
WHERE user_id = ?;

-- 按天统计
CREATE TABLE daily_counters (
    counter_date DATE,
    counter_name TEXT,
    counter_value COUNTER,
    PRIMARY KEY (counter_date, counter_name)
);

-- 更新
UPDATE daily_counters 
SET counter_value = counter_value + 1
WHERE counter_date = '2024-01-15' 
AND counter_name = 'total_logins';

-- 查询
SELECT * FROM daily_counters 
WHERE counter_date = '2024-01-15';

-- 高并发计数器分桶
CREATE TABLE sharded_counters (
    counter_name TEXT,
    bucket INT,
    counter_value COUNTER,
    PRIMARY KEY (counter_name, bucket)
);

-- 更新（随机选择桶）
UPDATE sharded_counters 
SET counter_value = counter_value + 1
WHERE counter_name = 'page_views' 
AND bucket = ?;  -- 0-99随机

-- 查询总和
SELECT SUM(counter_value) 
FROM sharded_counters 
WHERE counter_name = 'page_views';

-- 推荐使用QUORUM
CONSISTENCY QUORUM;

UPDATE user_counters 
SET login_count = login_count + 1
WHERE user_id = ?;

-- 或LOCAL_QUORUM（多数据中心）
CONSISTENCY LOCAL_QUORUM;

计数精度考虑：

最终一致性
├── 计数器是最终一致的
├── 短期内可能有误差
└── 适合近似计数场景

强一致性
├── 使用QUORUM读写
├── 性能开销大
└── 适合精确计数场景

建议
├── 统计类：ONE即可
├── 业务类：QUORUM
└── 金融类：考虑其他方案

分桶策略：

目的
├── 分散热点
├── 提高并发能力
└── 减少锁竞争

实现
├── 确定桶数量（如100）
├── 随机选择桶更新
└── 查询时聚合

适用
├── 高并发计数
├── 全局计数器
└── 热点计数器

-- 使用COUNTER BATCH
BEGIN COUNTER BATCH
    UPDATE user_counters SET login_count = login_count + 1 WHERE user_id = uuid1;
    UPDATE user_counters SET login_count = login_count + 1 WHERE user_id = uuid2;
    UPDATE user_counters SET login_count = login_count + 1 WHERE user_id = uuid3;
APPLY BATCH;

计数器适用场景：

适合
├── 用户行为统计
├── 页面访问计数
├── 点赞/收藏数
├── 库存计数（非精确）
└── 实时统计

不适合
├── 精确金融计数
├── 需要回滚的计数
├── 需要历史记录
└── 需要事务保证

设计建议：

1. 独立计数器表
   └── 不要与业务数据混合

2. 合理选择一致性级别
   └── 根据精度需求

3. 高并发使用分桶
   └── 分散写入压力

4. 监控计数器性能
   └── 关注延迟和误差