当前位置: 首页 > news >正文

如何设计一个点赞系统

首先我们定义出一个点赞系统需要对外提供哪些接口:

1.用户对特定的消息进行点赞;
2.用户查看自己发布的某条消息点赞数量以及被哪些人赞过;
3.用户查看自己给哪些消息点赞过;

这里假设每条消息都有一个message_id, 每一个用户都有一个user_id, 从以上三个接口我们可以大概想到需要在存储层保存哪些数据:
1.消息点赞表, 形式如{message_id, user_id, timestamp ... }, 需要具备根据指定message_id 查找所有点赞人及点赞数量的能力;
2.用户点赞表,形式如{user_id, message_id, timestamp ... },需要具备根据user_id查找其所有点赞过的消息列表;
3.点赞计数表,形式如{message_id, count}

从以上几点来看,如果系统的用户规模不大比如用户小于1w人,如果用mysql来存储好像一张表就能搞定,用message_id做主键,然后在user_id上建立索引就可以很方便实现上面要求的三个接口:

select * from table where message_id=xxxx
select * from table where user_id=xxxxx
select count(*) from table where message_id=xxxx

但是如果用户数量很大比如向抖音这种过亿量级,单表行数量迅速膨胀,并且可能存在某些消息热门,短时间内大量用户点赞导致mysql挂掉(一般而言mysql能够支持的tps为10的三次级别,具体数值依赖与cpu 磁盘 内存性能)。
很自然我们想到分库分表,但是选择哪一个字段做分表列?如果选message_id 进行分库分表,那么如果要查询单个用户所有点赞的message, 就需要查询所有的库;反之用user_id进行分,那么查询指定message_id 查找所有点赞人就需要查询所有库;
从另一个方面来讲,上述方式构建表存在带量冗余信息(一条message 被1000人点赞, 那么就需要1000行来存储),这主要是收到mysql中关系型数据库模式的限制。

方案二:
上述方案在用户规模较大的情况下难以满足我们的需求,这里在提供一种以mogondb作为核心存储的可能方案。
mogondb与mysql不同,它天然支持分布式扩展并且他是无模式的,下面给出存储方案:
消息点赞表:

{"message_id":12345,"count": 3"user_List": [5555, 8888,9999 ....]
}

用户点赞表:

{"user_id":5555,"message_List": [12345...]
}

上面只列出核心字段,其他业务字段如时间戳等可以自行扩展;mogondb 可以对message_id 或者 user_id 进行索引查询,很方便的满足上面提出的三个接口。

这里还可以做一些特定的限制,如果一条消息被超过5000以上人点赞,那么我们是否有必要记录所有点赞过的用户呢?我个人觉得没有必要,不会有用户会去查询全量用户列表,因为假设客户端一屏幕展示20个点赞用户,那么5000/20=250,用户需要250此滑屏幕才能看完,不会有人这么干。
因此可以考虑,当点赞用户超过5000后,消息点赞表就只需要更新点赞数量,而不用将用户加到user_List列表里了。

但是如果某条消息上瞬间请求量大还是可能冲垮mogondb特定分片,从而导致服务不可用,如何解决呢?
这里我想到的是使用消息队列来削峰,具体的架构如下图所示:
在这里插入图片描述

https://docs.qq.com/flowchart-addon
用户点赞的流程:
1.首先业务网关层,这里提供身份校验、限流等通用能力;
2.业务逻辑层根据message id 进行哈希写入kafka分区;
3.消费者集群从kafka消费数据,写入mogondb;
如果是数据查询,那么业务逻辑层直接请求db拿到结果就可以返回;
以上就是我点赞系统的设计的一些思考。

相关文章:

  • Linux系统安装Dify结合内网穿透实现远程访问本地LLM开发平台
  • Redis 数据恢复及持久化策略分析
  • windows系统配置linux环境wsl
  • 深入探索Llama 2:下一代开源语言模型的革新与影响
  • Vue66-vue-默认插槽
  • 01 Shell 编程规范与变量
  • Sklearn之朴素贝叶斯应用
  • IDEA GIt 提交提示 “Contents are identica“
  • ORA-25153 错误处理
  • 乡村振兴的科技创新引领:加强农业科技研发,推广先进适用技术,提高农业生产效率,助力美丽乡村建设
  • CLIP-guided Prototype Modulating for Few-shot Action Recognition
  • Java序列化进阶:Java内置序列化的三种方式
  • python3获取显示器信息并计算出各个显示器是多少寸
  • Spring学习笔记(九)简单的SSM框架整合
  • Java 笔记:常见正则使用
  • 77. Combinations
  • canvas 高仿 Apple Watch 表盘
  • classpath对获取配置文件的影响
  • iOS帅气加载动画、通知视图、红包助手、引导页、导航栏、朋友圈、小游戏等效果源码...
  • macOS 中 shell 创建文件夹及文件并 VS Code 打开
  • Map集合、散列表、红黑树介绍
  • OSS Web直传 (文件图片)
  • React-redux的原理以及使用
  • Spark RDD学习: aggregate函数
  • vue2.0项目引入element-ui
  • vue从创建到完整的饿了么(18)购物车详细信息的展示与删除
  • web标准化(下)
  • 警报:线上事故之CountDownLatch的威力
  • 前端面试之CSS3新特性
  • 前端学习笔记之观察者模式
  • 三栏布局总结
  • 使用common-codec进行md5加密
  • 限制Java线程池运行线程以及等待线程数量的策略
  • 协程
  • 一些关于Rust在2019年的思考
  • k8s使用glusterfs实现动态持久化存储
  • ​secrets --- 生成管理密码的安全随机数​
  • ​批处理文件中的errorlevel用法
  • ​如何使用QGIS制作三维建筑
  • # C++之functional库用法整理
  • # 学号 2017-2018-20172309 《程序设计与数据结构》实验三报告
  • #我与Java虚拟机的故事#连载12:一本书带我深入Java领域
  • (+4)2.2UML建模图
  • (4)STL算法之比较
  • (PWM呼吸灯)合泰开发板HT66F2390-----点灯大师
  • (备份) esp32 GPIO
  • (更新)A股上市公司华证ESG评级得分稳健性校验ESG得分年均值中位数(2009-2023年.12)
  • (函数)颠倒字符串顺序(C语言)
  • (转)EXC_BREAKPOINT僵尸错误
  • (转)Oracle存储过程编写经验和优化措施
  • (转)从零实现3D图像引擎:(8)参数化直线与3D平面函数库
  • .net core 依赖注入的基本用发
  • .NET core 自定义过滤器 Filter 实现webapi RestFul 统一接口数据返回格式
  • .NET Framework、.NET Core 、 .NET 5、.NET 6和.NET 7 和.NET8 简介及区别
  • .net打印*三角形