设计一个类似微博、朋友圈的 Feed 流

发帖：客户端 → 帖子服务
        1 写 posts 表（帖子 ID 用雪花 ID，按时间递增）
        2 发"新帖子"消息 → 分发服务（异步）
             普通用户：分批读粉丝列表，写入活跃粉丝的收件箱
             大 V（粉丝数超过阈值）：不分发，帖子留在自己的发件箱
读时间线：客户端（带游标）→ Feed 服务
        1 读自己的收件箱：游标之前的 N 条帖子 ID
        2 读关注的大 V 的发件箱：各取游标之前的 N 条
        3 按帖子 ID 倒序合并，取前 N 条（见代码示例）
        4 批量查帖子内容（缓存），过滤已删除、不可见的 → 返回内容和新游标

CREATE TABLE posts (
  id         BIGINT PRIMARY KEY,           -- 雪花 ID，越大越新
  author_id  BIGINT NOT NULL,
  content    TEXT NOT NULL,
  visibility TINYINT NOT NULL,             -- 0 公开，1 仅粉丝，2 仅自己
  status     TINYINT NOT NULL DEFAULT 0,   -- 0 正常，1 已删除
  KEY idx_author (author_id, id)           -- 发件箱：按作者倒序取帖子
);
CREATE TABLE follows (                      -- 我关注了谁，按 follower_id 分片
  follower_id BIGINT NOT NULL,
  followee_id BIGINT NOT NULL,
  created_at  DATETIME NOT NULL,
  PRIMARY KEY (follower_id, followee_id)
);
-- "谁关注了我"另建一张反向的粉丝表，按 followee_id 分片，分发时分页读取

// lists：自己的收件箱 + 关注的每个大 V 的发件箱，每个都是按 ID 倒序的帖子 ID（雪花 ID，越大越新）
// cursor：上一页最后一条的 ID，第一页传 null；返回本页的 ID 和下一页的游标
function mergeFeed(lists, cursor, size) {
  // 每个列表跳到游标之后的位置（真实系统里这一步是带游标的 Redis 或数据库查询）
  const pos = lists.map((list) => {
    const i = cursor === null ? 0 : list.findIndex((id) => id < cursor)
    return i < 0 ? list.length : i
  })
  const items = []
  while (items.length < size) {
    let best = -1 // 在各列表的当前头部里挑最新的一条
    for (let k = 0; k < lists.length; k++) {
      if (pos[k] < lists[k].length && (best < 0 || lists[k][pos[k]] > lists[best][pos[best]])) best = k
    }
    if (best < 0) break // 所有列表都取完了
    const id = lists[best][pos[best]++]
    if (items.at(-1) !== id) items.push(id) // 同一条帖子可能同时在收件箱和发件箱里，去重
  }
  return { items, nextCursor: items.length === size ? items.at(-1) : null }
}

const inbox = [9n, 7n, 4n, 2n] // 普通用户推过来的
const bigV = [8n, 7n, 3n] // 拉取的大 V 发件箱（7n 是他成为大 V 之前推过来的，重复）
console.log(mergeFeed([inbox, bigV], null, 3)) // { items: [ 9n, 8n, 7n ], nextCursor: 7n }
console.log(mergeFeed([inbox, bigV], 7n, 3)) // { items: [ 4n, 3n, 2n ], nextCursor: 2n }