我爱模板

当前位置: 我爱模板网 > 网络编程 > Mysql数据库教程 > Discourse 通知系统的设计与实现

Discourse 通知系统的设计与实现

来源:冰山日志 作者:小奔奔

最近在为一个论坛开发一套站内的消息通知系统,参考过 Coding.net 和 知乎 的消息机制,以及简书上 《消息系统设计与实现》 的系列文章,下面我的设计和具体实现内容。

消息类型

系统中包含三种消息类型,本文只针对前两种通知类型,关于私信的详细内容请访问《Discourse 私信系统的设计与实现》。

  • 系统通知
  • 动态提醒
    1. 我关注的内容
    2. 我关注的用户
  • 私信

用户订阅

考虑到数据量规模,系统使用拉方式按需拉取用户订阅的通知。

用户和内容动态,包含三个基础属性

行为 action
对象类型 entityType
对象 ID entityId

比如您发表了一个主题,那么您会订阅该主题的[回复]、[点赞]、[投票]等行为;您发表了一个回复,可能仅仅只会订阅该回复是否有被[点赞]就可以了。

数据库设计

系统通知与动态提醒在数据结构上是一致的。

通知系统 ERD

  • users
    原有系统的用户信息表,主键 uid
  • users_follows
    用户关系表,保存用户与用户之间的关注关系
  • notifications
    通知信息表,每一条系统通知和用户动态都在该表中保存一行
  • users_subscriptions
    用户订阅表,用户所关注主题或回复的行为,如 关注了某某主题的评论、关注了某某回复的点赞
  • users_notifications
    用户与通知关联表,保存用户与通知的关系以及已读状态
  • users_notifications_updated
    用户通知拉取时间表,记录最近一次用户的拉取时间

 业务流程

  • 订阅和通知生成
    通知系统流程图1
  • 系统通知和用户关注动态拉取
    process2

代码实现

  • 订阅
    • 函数原型
       
      1
      function userSubscribe (uid, entityType, entityId, action)
    • 关键 SQL
       
      1
      INSERT IGNORE INTO `users_subscriptions` (`uid`, `entity_type`, `entity_id`, `action`, `created`) VALUES (...)
    • 例子
       
      1
      userSubscribe(1, 'topic', 1, 'reply')  // 订阅主题1的[回复]行为
  • 新通知
    • 函数原型
       
      1
      function newStatus (uid, action, entityType, entityId, content, data)
    • 关键 SQL
       
      1
      INSERT INTO `notifications` (`uid`, `entity_type`, `entity_id`, `action`, `content`, `data`, `created`) VALUES (...)
    • 例子
       
      1
      newStatus(2, 'topic', 1, 'reply', '%sender% 回复了主题 %topic%', { reply: replyId })  // 回复了主题1
  • 获取拉取时间
    • 关键 SQL
       
      1
      SELECT `notifications_updated` FROM `users_notifications_updated` WHERE `uid` = ?
  • 拉取系统通知
    • 关键 SQL
       
      1
      INSERT INTO `users_notifications` (`no_id`, `action`, `uid`, `status`, `created`) SELECT n.no_id, n.action, [用户ID], 0, UNIX_TIMESTAMP() FROM `notifications` n WHERE `action` = 'announce' AND n.created >= [最后拉取时间] AND n.created < [当前时间]
  • 拉取关注的对象动态
    • 关键 SQL
       
      1
      INSERT INTO `users_notifications` (`no_id`, `action`, `uid`, `status`, `created`) SELECT n.no_id, n.action, [用户ID], 0, UNIX_TIMESTAMP() FROM `users_subscriptions` us INNER JOIN `notifications` n ON us.entity_id = n.entity_id AND us.entity_type = n.entity_type AND us.action = n.action AND us.uid <> n.uid WHERE us.uid = [用户ID] AND n.created >= [最后拉取时间] AND n.created < [当前时间]
  • 拉取关注的用户动态
    • 关键 SQL
       
      1
      INSERT INTO `users_notifications` (`no_id`, `action`, `uid`, `status`, `created`) SELECT n.no_id, n.action, [用户ID], 0, UNIX_TIMESTAMP() FROM `users_follows` uf INNER JOIN `notifications` n ON uf.follow_uid = n.uid WHERE uf.uid = [用户ID] AND n.created >= [最后拉取时间] AND n.created < [当前时间]
  • 更新拉取时间
    • 关键 SQL
       
      1
      REPLACE INTO `users_notifications_updated` SET `uid` = [用户ID], notifications_updated = [当前时间]

推荐继续阅读的文章