-

1700000000000-0  → 时间戳：1700000000000ms，序号：0
1700000000000-1  → 同一毫秒内的第二条消息
1700000000001-0  → 下一毫秒的第一条消息

# 不指定 ID，由 Redis 自动生成
XADD mystream * field1 value1 field2 value2
# 返回: 1700000000000-0

// Redis 源码逻辑（简化）
function generateStreamID() {
    var ms = current_time_ms();
    var seq = get_sequence(ms);  // 获取当前毫秒的序列号

    if (ms < last_generated_ms) {
        // 时钟回拨处理：使用最后的毫秒+自增序列
        ms = last_generated_ms;
        seq = last_sequence + 1;
    } else if (ms == last_generated_ms) {
        // 同一毫秒：序列号 +1
        seq = last_sequence + 1;
    } else {
        // 新的毫秒：序列号从 0 开始
        seq = 0;
    }

    update_state(ms, seq);
    return format("%d-%d", ms, seq);
}

场景：系统时间从 1700000000100 回滚到 1699999999900

正常序列：1700000000100-0, 1700000000100-1
时钟回滚后试图生成：
1699999999900-0  → Redis 检测到时间戳小于最后生成的 ID
                 → 会使用 1700000000100-2 继续生成

# 即使时钟回滚，Redis 保证 ID 单调递增
XADD mystream * a 1  # 1700000000100-2（即使时钟已回滚）
XADD mystream * a 2  # 1700000000100-3

# 自定义 ID 必须满足：
# 1. 比 Stream 中上一条消息的 ID 大
# 2. 格式为 ms-seq

# 合法的自定义 ID
XADD mystream 1700000000000-0 a 1     # 从 0 开始

# 非法的自定义 ID
XADD mystream abc-def a 1              # 格式错误
# 或者在已有 ID 1700000000000-0 后使用 1699999999999-0
XADD mystream 1699999999999-0 a 2      # 错误：不能小于最新 ID

# 场景：导入旧系统的消息，保留原有顺序
old_messages = get_old_messages_sorted()
for i, msg in enumerate(old_messages):
    # 使用原有时间戳生成 ID
    custom_id = f"{msg['timestamp_ms']}-{i}"
    redis.xadd('migrated_stream', custom_id, msg['data'])

# 按 ID 范围查询
XRANGE mystream 1700000000000-0 1700000000000-100

# 获取 Stream 中的第一个和最后一个消息 ID
XLEN mystream               # 消息总数
XRANGE mystream - + COUNT 1 # 第一条消息
XRANGE mystream - + COUNT 1 DESC  # 最后一条消息

# 从指定 ID 之后开始读取
XREAD COUNT 10 BLOCK 0 STREAMS mystream 1700000000000-0

# 按时间范围查询非常高效（因为 ID 包含时间戳）
XRANGE mystream 1700000000000 1700001000000
# 等价于查询这段毫秒范围内的所有消息