设计一个评论系统

客户端 ──> 网关（鉴权、限流）──> 评论服务
                                   │ 读：Redis（首页评论、热评 ZSet、计数）→ 未命中查 MySQL
                                   │ 写：同步规则审核 → MySQL（按 subject_id 分库分表）→ 发 MQ 事件
                                   ▼
MQ ──> 审核服务（模型 + 人工，结果回写评论状态）
   ──> 计数服务（回复数、点赞数合并后批量落库，更新热度分）
   ──> 通知服务（"有人回复了你"）、搜索索引、数据统计

CREATE TABLE comment (
  id           BIGINT PRIMARY KEY,         -- 分布式 ID，趋势递增，按 id 排序约等于按时间排序
  subject_type TINYINT NOT NULL,
  subject_id   BIGINT NOT NULL,            -- 评论对象，也是分片键
  root_id      BIGINT NOT NULL DEFAULT 0,  -- 0 表示根评论；回复指向所属的根评论
  parent_id    BIGINT NOT NULL DEFAULT 0,  -- 直接回复的那一条
  user_id      BIGINT NOT NULL,
  content      VARCHAR(2000) NOT NULL,
  like_count   INT NOT NULL DEFAULT 0,
  reply_count  INT NOT NULL DEFAULT 0,     -- 只对根评论有意义
  status       TINYINT NOT NULL,           -- 1 可见，其他为待审核、隐藏、审核拒绝
  created_at   DATETIME NOT NULL,
  KEY idx_list (subject_id, root_id, status, id)
);
-- 另有 comment_subject（对象的评论总数、是否关闭评论）、comment_like（comment_id + user_id 唯一）

-- 第一页：最新的 20 条根评论；下一页加上 AND id < 上一页最后一条的 id
SELECT id, user_id, content, like_count, reply_count, created_at
FROM comment
WHERE subject_id = ? AND root_id = 0 AND status = 1
ORDER BY id DESC LIMIT 20;

-- 这一页根评论各自的前 3 条回复，用窗口函数一次查出，不用查 20 次
SELECT * FROM (
  SELECT c.*, ROW_NUMBER() OVER (PARTITION BY root_id ORDER BY id) AS rn
  FROM comment c
  WHERE subject_id = ? AND root_id IN (101, 102, 103) AND status = 1  -- IN 里是这一页的根评论 ID
) t WHERE rn <= 3;

// 热度分：点赞、回复越多越高，随时间衰减。权重和指数是示例值，要按业务数据调
export function hotScore({ likes, replies, createdAt }, now = Date.now()) {
  const hours = Math.max(0, (now - createdAt) / 3_600_000)
  return (likes + 2 * replies + 1) / (hours + 2) ** 1.5
}

// 一批点赞消息先按评论合并，写库次数从"每次点赞一次"降到"每批每条评论一次"
export function mergeLikeEvents(events) {
  const delta = new Map()
  for (const { commentId, type } of events) {
    delta.set(commentId, (delta.get(commentId) ?? 0) + (type === 'like' ? 1 : -1))
  }
  return [...delta].filter(([, d]) => d !== 0) // 点了又取消的互相抵消，不用写库
}

export async function flushLikes(conn, events) {
  for (const [id, d] of mergeLikeEvents(events)) {
    await conn.query('UPDATE comment SET like_count = GREATEST(like_count + ?, 0) WHERE id = ?', [d, id])
  }
}