Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >记一次有意思的业务实现 → 单向关注是关注,双向关注则成好友

记一次有意思的业务实现 → 单向关注是关注,双向关注则成好友

作者头像
青石路
发布于 2022-08-30 09:23:10
发布于 2022-08-30 09:23:10
8630
举报
文章被收录于专栏:开发技术开发技术

开心一刻

  有个问题一直困扰着我:许仙选择了救蛇,为什么杨过却选择救雕(而不救蛇)

  后面想想,其实杨过救神雕是有原因的,当年神雕和巨蛇打架的时候

  雕对杨过说:杀蛇,杀蛇,杀蛇!

  蛇对杨过说:杀雕,杀雕,杀雕!

  杨过果断选择了杀蛇

业务场景

  业务描述

  业务上有这样的需求,张三、李四两个用户,如果互相关注则成为好友

  设计上有两张表,关注关系表: tbl_follow

  朋友关系表: tbl_friend

  我们以张三关注李四为例,业务实现流程是这样的

    1、先查询李四有没有关注张三

    2、如果李四关注了张三,则成为好友,往 tbl_friend 插入一条记录;如果李四没有关注张三,则只是张三单向关注李四,往 tbl_follow 插入一条记录

  看似没问题,可如果我们从并发的角度来看,是不是还正常了?

  如果张三、李四同时关注对方,那么业务实现流程的第 1 步得到的结果可能就是双方都没有关注对方(加数据库的排他锁也没用,记录不存在,行锁无法生效)

  得到的结果就是张三关注李四、李四关注张三,但张三和李四没有成为朋友,这就导致了与业务需求不符!

  问题复现

  相关环境如下

MySQL : 5.7.21-log ,隔离级别 RR

Spring Boot : 2.1.0.RELEASE

MyBatis-Plus : 3.1.0

  核心代码如下

  完整代码见:mybatis-plus-demo

  我们来复现下问题

  正确结果应该是: tbl_follow 、 tbl_friend 中各插入一条记录

  但目前的结果是只往 tbl_follow 中插了两条记录

  该如何处理该问题,欢迎大家评论区留言

JVM 锁

  既然并发了,那就加锁呗

  JVM 自带的 synchronized 和 Lock 都有同步作用,我们以 synchronized 为例,来看看效果

tbl_follow 和 tbl_friend 中各插入一条记录,问题得到解决!

  但是完美吗?如果项目是集群部署,张三、李四关注对方的请求分别落在了集群中不同的节点上,不能成为好友的问题会不会出现?

分布式锁

  因为 JVM 锁只能控制同个 JVM 进程的同步,控制不了不同 JVM 进程间的同步,所有如果项目是集群部署,那么就需要用分布式锁来控制同步了

  关于分布式锁,我就不多说了,网上资料太多了,推荐一篇:再有人问你分布式锁,这篇文章扔给他

  如果用分布式锁去解决上述案例的问题,楼主就不去实现了,只是强调一个小细节:如何保证 张三关注李四 、 李四关注张三 它们申请同一把锁

  以 Redis 实现为例, key 的命名是有规范的,比如:业务名:方法名:资源名,具体到如上的案例中, key 的名称:user:follow:123:456

  如果 张三关注李四 申请的 user:follow:123:456 ,而 李四关注张三 申请的是 user:follow:456:123 ,那么申请的都不是同一把锁,自然也就没法控制同步了

  所以申请锁之前,需要进行一个小细节处理,将 followId 与 userId 进行排序处理,小的放前面,大的放后面,类似: user:follow:小id:大id

  那么就能保证它们申请的是同一把锁,自然就能控制同步了

唯一索引

  接下来要讲的实现方式不常见,但是挺有意思的,大家仔细看

  我们改造一下 tbl_follow ,另取名字 tbl_follow_plus

  注意字段看字段的描述

tbl_follow 中 user_id 固定为 被关注者 , tbl_follow 中 follower_id 固定为 关注者

tbl_follow_plus 中 one_side_id 和 other_side_id 没有固定谁是 关注者 ,谁是 被关注者 ,而是通过 relation_ship 的值来指明谁关注谁

  业务实现

  当 one_side_id 关注 other_side_id 的时候,比较它俩的大小

  若 one_side_id < other_side_id ,执行如下逻辑

  若 one_side_id > other_side_id ,则执行如下逻辑

  不太容易看懂,我们直接看代码实现

  执行效果如下

  我们分析下结果

tbl_follow_plus 只插入了一条记录

relation_ship = 3 表示双向关注

tbl_friend 插入了一条记录

同时关注 这个业务就实现了

  有小伙伴就有疑问了:楼主你只分析了 one_side_id 关注 other_side_id 的情况,没分析 other_side_id 关注 one_side_id 的情况呀

  大家注意看 tbl_follow_plus 表中各个列名的注释, one_side_id 和 other_side_id 并不是具体的 关注者 和 被关注者 ,两者的业务含义是等价的

  至于是谁关注谁,是通过 relation_ship 的值来确定的,所以 one_side_id 关注 other_side_id 和 other_side_id 关注 one_side_id 是一样的

  至于适不适用单向关注的情况,大家自行去验证

  原理分析

  虽然业务需求是实现了,但却难以理解,让我们一步一步往下分析

  1、为什么要比较 one_side_id 和 other_side_id 的大小?

tbl_follow_plus 有个唯一索引 UNIQUE KEY uk\_one\_other (one\_side\_id,other\_side\_id)

    比较大小的目的就是保证 tbl_follow_plus 的 one_side_id 记录的是小值,而 other_side_id 记录的是大值

    例如 123 关注 456 , one_side_id = 123 , other_side_id = 456 , relation_ship = 1

456 关注 123 , one_side_id = 123 , other_side_id = 456 ,但 relation_ship = 2

    那这有什么用?

    还记得我在上面的 分布式锁 实现方案中强调的那个细节吗

    这里比较大小的作用也是为了保证 123 关注 456 与 456 关注 123 在唯一索引上竞争的是用一把行锁

  2、insert … on duplicate key update

    其作用简单点说就是:数据库表中存在某个记录时,执行这个语句会更新,而不存在这条记录时,就会插入

    有个前置条件:只能基于唯一索引或主键使用;具体细节可查看:记录不存在则插入,存在则更新 → MySQL 的实现方式有哪些?

insert ... on duplicate 确保了在事务内部,执行了这个 SQL 语句后,就占住了这个行锁(先占锁,再执行 SQL)

    确保了之后查询 relation_ship 的逻辑是在行锁保护下的读操作

  3、relation_ship=relation_ship | 1(relation_ship=relation_ship | 2)

    这个写法就有点巧妙了,这里的 | 指的是 按位或运算

relation_ship 的值是在业务代码中指定的,只能是 1 或者 2

    因为在 MySQL 层面有个唯一索引的 行锁 ,所以 123 关注 456 和 456 关注 123 的事务之间存在锁竞争,必定是串行的

    3.1 若先执行 123 关注 456 的事务, relation_ship 传入的值是 1,事务执行完之后, relation_ship 的值等于 1 | 1 = 1 ;

      再执行 456 关注 123 的事务, relation_ship 传入的值是 2,事务执行完之后, relation_ship 的值等于 1 | 2 = 3

    3.2 若先执行 456 关注 123 的事务, relation_ship 传入的值是 2,事务执行完之后, relation_ship 的值等于 2 | 2 = 2 ;

      再执行 123 关注 456 的事务, relation_ship 传入的值是 1,事务执行完之后, relation_ship 的值等于 2 | 1 = 3

    这里也可以看出 relation_ship 的枚举值也不是随意的,当然也可以选择其他的,但是需要满足如上的位运算逻辑

  4、insert ignore into friend

    其作用简单点说就是:数据库表中存在该记录时忽略,不存在时插入

    同样也是基于主键或唯一索引使用

  另外,在重复调用时,按位或(|)和 insert ignore 可以保证幂等性

总结

  1、就文中这个业务而言,唯一索引的实现可读性太差,不推荐大家使用

  2、 insert into on duplicate key update 和 insert ignore into 还是比较常见的,最好掌握它们

参考

  《MySQL 实战 45 讲》

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-06-06,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
MySQL深入学习第十五篇-日志和索引相关问题
我在第 2 篇文章《MySQL深入学习第二篇 - 一条SQL更新语句是如何执行的?》中,和你讲到 binlog(归档日志)和 redo log(重做日志)配合崩溃恢复的时候,用的是反证法,说明了如果没有两阶段提交,会导致 MySQL 出现主备数据不一致等问题。
越陌度阡
2020/11/26
4440
MySQL深入学习第十五篇-日志和索引相关问题
完全弄懂Redis各种业务场景下的使用
Redis作为一种内存型的非关系型的数据库,不管在互联网大厂,小厂,大项目和小项目中,几乎都会被使用。为什么Redis会受到如此青睐呢?关于这个问题,可能很多的程序员只是看着别人用而用,缺乏对Redis一个全面的了解。
兔云小新LM
2022/11/21
2.4K0
完全弄懂Redis各种业务场景下的使用
有关于MySQL的面试题
​#问题1:1月每笔消费均大于20元的用户的总消费金额#条件:1月+大于20 sum(order_amt
用户10196776
2022/11/22
1.1K0
有关于MySQL的面试题
记一次神奇的Mysql死锁排查
说起Mysql死锁,之前写过一次有关Mysql加锁的基本介绍,对于一些基本的Mysql锁或者死锁都有一个简单的认识,可以看下这篇文章为什么开发人员需要了解分布式锁。有了上面的经验之后,本以为对于死锁都能手到擒来,没想到再一个阳光明媚的下午报出了一个死锁,但是这一次却没想象的那么简单。
用户5397975
2019/10/13
1.2K0
记一次线上问题 → Deadlock 的分析与优化
MySQL8.0.30 ,隔离级别是默认的,也就是 REPEATABLE-READ
青石路
2023/10/16
1720
记一次线上问题 → Deadlock 的分析与优化
IGNORE,REPLACE,ON DUPLICATE KEY UPDATE在避免重复插入记录时存在的问题及最佳实践
在实际业务场景中,经常会有这样的需求:插入一条记录,如果数据表中已经存在该条记录则更新它的部分字段,比如更新update_time或者在某些列上执行累加操作等。参考博客1中介绍了三种在MySQL中避免重复插入记录的方法,本文将在简单介绍这三种用法的基础上,深入分析这其各自存在的问题,最后给出在实际生产环境中对该业务场景的最佳实践。
saintyyu
2021/11/22
2.8K1
IGNORE,REPLACE,ON DUPLICATE KEY UPDATE在避免重复插入记录时存在的问题及最佳实践
技术分享 | 关于 MySQL 自增 ID 的事儿
当我们使用 MySQL 进行数据存储时,一般会为一张表设置一个自增主键,当有数据行插入时,该主键字段则会根据步长与偏移量增长(默认每次+1)。
爱可生开源社区
2022/02/09
4.4K0
Mysql死亡笔记的死锁记录
MySQL如果检测到两个事务发生了死锁,会回滚其中一个事务,让另一个事务执行成功。很明显,我们这条insert语句被回滚了。
杨不易呀
2023/10/06
4570
Mysql死亡笔记的死锁记录
大胆假设小心求证:MySQL双写+双向复制实战
导语双主架构在MySQL中使用比较普遍,因为有故障后恢复方便的优点。但双写+双向复制的架构业界极少采用,这种架构下可能有什么问题?如何规避这种架构下的数据风险?本文根据实践经验做出了总结。
DBA成江东
2023/07/20
2.2K1
大胆假设小心求证:MySQL双写+双向复制实战
TiDB 在转转的业务实战
世界级的开源分布式数据库 TiDB 自 2016 年 12 月正式发布第一个版本以来,业内诸多公司逐步引入使用,并取得广泛认可。
PingCAP
2019/01/17
9130
Redis常用数据类型和使用场景分析与总结
Redis是一款基于内存的非关系型数据库,一般我们会用在缓存业务数据的情况,来提高应用的高可用。使用Redis的业务可以自建服务,也开始使用第三方的云服务。如腾讯云的Redis服务,使用云服务的好处就是可以减少自建服务器的成本,同时对于Redis服务的管理也是少很多精力。
兔云小新LM
2021/01/17
1.8K0
Redis常用数据类型和使用场景分析与总结
面试官:mysql如何重置自增id
面试官:咱们聊聊mysql的自增id。mysql自增id给我们的自增主键定义带来了很大的方便,但是经常mysql的自增id会有不连续情况,能说说什么场景下mysql的id会产生不连续吗我:我以一张表为例来解释一下,我先创建一张表zh_person,这张表包括4个字段,自增id,姓名name,性别sex和身份证号id_no,id_no上有唯一索引,sql如下 CREATE TABLE `zh_person` ( `id` MEDIUMINT(11) NOT NULL AUTO_INCREMENT, `
jinjunzhu
2020/08/20
8K1
Mysql 夺命连环 13 问,你能抗住多少题?
想进大厂,Mysql 不会那可不行,来接受 Mysql 面试挑战吧,看看你能坚持到哪里?
小林coding
2020/10/30
1.1K0
Mysql 夺命连环 13 问,你能抗住多少题?
MySQL 事务和 MVCC 机制
了解事务之前,先来看看数据库为什么需要有事务,假设没有事务会有什么影响?假设我们有一个银行账户系统,表结构如下:
Se7en258
2021/07/01
5380
【Redis我可以讲一个小时】
我进入了张三的主页 查看共同关注的人(李四),取出我关注的人和张三关注的人,二个集合取交集得出结果是李四,就是通过SINTER交集实现的。 查看我可能认识的人(王五),取出我关注的人和张三关注的人,二个集合取并集得出结果是(张三,李四,王五),拿我关注的人(张三,李四)减去并集里的元素,剩下的王五就是我可能认识的人,可以通过并集和差集实现。 查看我关注的人也关注了他(王五),取出我关注的人他们关注的人,(李四,王五)(我,王五)的交集,就是王五。
Java廖志伟
2022/03/14
4300
【Redis我可以讲一个小时】
MySQL之锁总结。(再也不怕面试官提问了)
不少人在开发的时候,应该很少会注意到这些锁的问题,也很少会给程序加锁(除了库存这些对数量准确性要求极高的情况下)
秃头哥编程
2019/06/11
1.8K0
MySQL之锁总结。(再也不怕面试官提问了)
进阶数据库系列(十四):PostgreSQL 事务与并发控制
当多个事务并发执行时, 即使每个单独的事务都正确执行, 数据库的一致性也可能被破坏.。
民工哥
2023/08/22
2.4K0
进阶数据库系列(十四):PostgreSQL 事务与并发控制
mongodb学习(一)
通过 MongoDB Shell(mongosh)是用于与 MongoDB 交互的命令行界面
落幕
2025/05/27
2120
mongodb学习(一)
MySQL MVCC实现原理
MVCC (Multiversion Concurrency Control),多版本并发控制。顾名思义,MVCC是通过数据行的多个版本管理实现数据库的并发控制。这项技术使得在InnoDB的事务隔离级别下执行一致性读操作有了保证。换言之,就是为了查询一些正在被另一个事务更新的行,并且可以看到它们被更新之前的值,这样在做查询的时候就不用等待另一个事务释放锁。
得物技术
2023/03/21
8860
MySQL  MVCC实现原理
【MySql】多版本并发控制MVCC前置知识——隐藏字段、undo日志与Read View
1.每个事务都要有自己的事务ID,可以根据事务ID的大小,来决定事务到来的先后顺序
平凡的人1
2023/10/15
5450
【MySql】多版本并发控制MVCC前置知识——隐藏字段、undo日志与Read View
推荐阅读
相关推荐
MySQL深入学习第十五篇-日志和索引相关问题
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档