入职第一天，MySQL就崩了...
前段时间我离职了，因为个人原因，在修整一段时间后，重新入职了一家新公司。
图片来自 Pexels
入职的第一天我就经历了一次生产事故，运维同学告警说线上 MySQL 负载压力大，直接就把主库 MySQL 压崩了（第一天这可不是好兆头）。
运维同学紧急进行了主从切换，在事后寻找导致生产事故的原因时，排查到是慢查询导致 MySQL 雪崩的主要原因。
在导出慢查询的 SQL 后，项目经理直接说吧这个 MySQL 优化的功能交给新来的吧！
我赶紧打开跳板机进行查看，不看不知道一看吓一跳：
单表的数据量已经达到了 5 亿级别！这尼玛肯定是历史问题一直堆积到现在才导致的啊，项目经理直接就把这个坑甩给了我，我心中想，我难道试岗期都过不了么？？🤣
好在我身经百战，赶快与项目经理与老同事进行沟通，了解业务场景，才发现导致现在的情况是这样的。
我所在的公司是主要做 IM 社交系统的，这个 5 亿级别的数据表是关注表，也是俗称的粉丝表，在类似与某些大 V、或者是网红，粉丝过百万是非常常见的。
在 A 关注 B 后会产生一条记录，B 关注 A 时也会产生一条记录，时间积累久了才达到今天这样的数据规模，项目经理慢悠悠的对我说，这个优化不用着急，先出方案吧！
我心中一万个草泥马经过，这上来就给了一块不好啃的骨头，看来是要试试我能力的深浅啊。
按照我之前经验，单表在达到 500W 左右的数据就应该考虑分表了，常见分表方案无非就是 hash 取模，或者 range 分区这两种方法。
但是这次的数据分表与迁移过程难度在于两方面：
数据平滑过度，在不停机的情况把单表数据逐步迁移。（老板说：敢宕机分分钟损失几千块，KPI 直接给你扣成负的）
数据分区，采用 hash 还是 range?（暂时不能使用一些分库分表中间件，无奈）
常规我们都是拿用户 id 进行取模，模到多少直接把数据塞进去就行了，简单粗暴。
但是假如说 user_id=128 与 user_id=257 再模 128 后都是对应 user_attention_1 这个表，他俩也恰好是网红，旗下粉丝过百万，那轻轻松松两个人就能把数据表撑满。
其他用户再进来数据的时候无疑 user_attention_1 这个表还会成为一张大表，这就是典型的数据热点问题，这个方案可以 PASS。
有的同学说可以 user_id 和 fans_id 组合进行取模进行分配，我也考虑过这个问题。
虽然这样子数据分配均匀了，但是会有一个致命的问题就是查询问题（因为目前没有做类似 MongoDB 与 DB2 这种高性能查询 DB，也没做数据同步，考虑到工作量还是查询现有的分表内的数据）。
//我关注了谁
select * from user_attention where user_id = #{userId}
//谁关注了我
select * from user_attention where fans_id = #{userId}
在我们进行 user_id 与 fans_id 组合后 hash 后，如果我想查询我关注的人与谁关注我的时候，那我将检索 128 张表才能得到结果。
这个也太恶心了，肯定不可取，并且考虑到以后扩容至少也要影响一半数据，实在不好用，这个方案 PASS。
Range 看起来也很简单，用户 id 在一定的范围时候就把他路由到一个表中。
例如用户 id=128，那就在 [0,10000] 这个区间中对应的是 user_attention_0 这个表，就直接把数据塞进去就可以了。
但是这样同样也会产生热点数据问题，看来简单的水平分区已经不能满足，这个方案也可以 PASS 了，还是要另寻他径啊。
经过我日夜奋战，深思熟虑之后，给出了三个解决方案：
第一种方案：range+一致性 hash 环组合（hash 环节点 10000）
想采用这个方案主要是因为：
扩容简单，影响范围小，只涉及 hash 环上单个节点影响。
数据迁移简单，每次扩容只需吧新增的节点与后置节点进行数据交互。
查询范围小，按照 range 与 hash 关系检索部分表分区。
在每个 range 区域后都对应着自己一套的环，我们可以根据实际情况进行扩容，比如在 [1,10000] 这个范围内只有 2 个大 V，那我们分三个表就够了，预留 1500 万的数据容量。
[10001,20000] 中有 4 个网红和大 V，hash 环上就给出实际 4 张表，我们的用户 id 可以顺时针顺序坐落到第一个物理表，数据进行入库。
凡事有利有弊，方案也要结合工时，实际可行性与技术评审之后才能决定，弊端咱也要列出来：
设计复杂，需要增加 range 区域与 hash 环关系。
系统内修改波及较多，查询关系复杂，多了一层路由表的概念，虽然尽量吧用户数据分配到一个区之内，但是想查询谁关注我，与我关注谁这样的逻辑时还是复杂。
第二种方案：range+hash 取模（hash 模 300）
这个其实就比较好理解了，就是一个简单的 range+hash 取模组合的形式，先 range 到一定的范围后，在这个范围内进行 hash 取模找到对应的表进行存储。
这个方案比方案一简单点，但是方案一存在的问题他也存在，并且他还有扩容数据影响范围广的问题。
但是实现起来就简单不少，从查询方面看根据不同场景可以控制取模的大小范围，根据实际情况每个分区的 hash 模采用不同的值。
最后一种方案：range userId 分区
例如 user_id=256 是个大 V，就把他单独提出来让他自成一表，在查询范围的时候优先查是否有自己单独对应的路由表。
而其他那些零碎用户还是路由到一个统一表内，这时候有的同学会说这样子数据不都又不均匀了么。
我也曾这样认为，但是分到绝对的均匀基本不太可能，只能做到相对，尽量把某些大 V 分出去，不占用公共资源。
当某个人突然成为大 V 后，再把这个人再单独分出去，不断演变这个过程，保证数据的平衡。
并且这样子处理之后很多原来的关联查询其实改动不大了，只要在数据迁移后对原来的所有包含 user_attention 进行动态的改造即可（使用个 mybatis 的拦截器就能搞定）。
PS：其实分析实际业务场景大部分的关注数据还是来源于那些零碎用户的。
//我关注了谁
select * from user_attention where user_id = #{userId}
//谁关注了我
select * from user_attention where fans_id = #{userId}
这样的方案，当我要查询我的粉丝有哪些时，这样就悲剧了，我还是要检索全表根据 fansid 找到我所有的粉丝，因为表内只记录了我关注了谁这样的数据。
考虑到这样的问题，我决定重新设计数据存储形式，使用空间换时间的思路，原来处理的方式是用户在关注对方的时候产生一条记录。
在用户 1 关注 2 后产生两条数据，state（1 代表我关注了，0 代表我被关注了，2 代表咱俩互关），采用这样的数据存储方式后，我所有的查询都可以从 user_id 进行出发了，不在逆向去推 fans_id 这样的方式。
数据库索引设计上，考虑好 user_id、fans_id、state 与 user_id、state 这样的结构即可，是不是感觉很简单，虽然数据量存储变多了，但是查询方便了好多。
分表和查询问题解决了，最后就是要考虑数据迁移的过程了，这一步也非常重要。搞不好就要被扣掉自己的 KPI 了（步步为营啊）！
数据迁移最需要考虑的问题就是个时效性，迁移程序必不可少，如何生产环境正常跑着，迁移脚本线下跑着数据互不影响呢？
答案就是经典套路数据双写，因为老的数据不是一下子就迁移到新表内的，现在和 user_attention 产生的数据还是要保持的，在产生老表数据的同时，根据路由规则，直接存到新表内一份。
线下的迁移程序多开几台服务慢慢跑呗，不过可要控制好数据量，别占满 IO 影响生产环境，线下的模拟和演练也是必不可少的，谁都不能保证会不会出啥问题呢。
迁移脚本和线上做好 user_id 和 fans_id 的唯一索引就行，在某些极端情况下，数据会存在新表内写入数据，但是老表内数据还没更新的可能这个做好版本号控制和日志记录就可以了，这些都比较简单。
truncate table user_attention;
干掉这个 5 亿数据量的定时炸弹了。好了，今天分享就结束了，看来我不仅能挺过试岗期也能挺过试用期了，不说了下班回家抱娃去了😚。
编辑：陶家龙
精彩文章推荐：