两年前接手公司的财务系统的开发和维护工作。在系统移交的初期，笔者和团队就发现，系统内有一张5000W+的大表。

跟踪代码发现，该表是用于存储资金流水的表格，关联着众多功能点，同时也有众多的下游系统在使用这张表的数据。

进一步的观察发现，这张表还在以每月600W+的数据持续增长，也就是说，不超过半年，这张表会增长到1个亿！

这个数据量，对于mysql数据库来说是绝对无法继续维护的了，因此在接手系统两个月后，我们便开起了大表拆分的专项工作。（两个月时间实际上主要用来熟悉系统、消化堆积需求了） 

1、拆表前系统状态

 

 

• 涉及到流水表流水的接口超时频发，部分接口基本不可用

• 每日新增流水缓慢，主要是插入数据库的时候非常慢

• 单表占用空间过大，DBA的数据库监控经常报警

• 无法对表进行变更，任何alter操作都会引起主从的高延迟和长时间锁表

2、拆表的目标 

• 将流水大表数据拆分至各个分表，保证每张分表数据在1000W左右（经验上看单表1000W的量对mysql来说没啥压力）

• 在拆表的前提下，针对不同接口的查询条件进行优化，保证各个对外、对内接口的可用性。彻底杀死mysql慢查询。

3、难点分析 

• 该表的数据可以说是整个财务系统最基础的数据，相关功能和下游系统非常多。这要求开发、测试和上线流程必须极其严密，任何小失误都会引起大问题。

• 涉及的场景非常多。统计下来，一共有26个场景，需要改造32个mapper方法，具体需要改造的方法就更加无计其数了。

• 数据量非常大，迁移数据的过程必须保证系统稳定。

• 用户较多且功能重要。分表功能上线时，必须尽量压缩系统无法使用时长，同时需要保证系统可用性。这要求团队必须设计完整可靠的上线流程、数据迁移方案、回滚方案、降级策略。

• 上文提到，表的拆分势必带来部分接口的变化，接口的变化又会带来其他系统的改造。如何推动其他系统进行改造，如何协调多方合作的开发、测试和上线是另一个难点。

4、整体过程 

 

4.1、分表中间件调研

分表插件：采用sharding-jdbc作为分表插件。

其优势如下：

1、支持多种分片策略，自动识别=或in判断具体在哪张分表里。

2、轻量级，作为maven依赖引入即可，对业务的侵入性极低。

为提升查询速度，在整个项目的初期，团队成员考虑引入ES存储流水以提升查询速度。

经过与ES维护团队的两轮讨论，发现公司提供的ES服务对于我们的业务场景并不匹配（见表），经过反复考量，最终我们放弃了引入ES的计划，直接从数据库查询数据，采用每张表设置一个查询线程的方式提升查询效率。

4.2、分表依据的选择

分表的方式有很多种，有纵向分表，有横向分表，有分为固定的几个表存储然后取模进行表拆分等等。总的来说，适合我们具体业务的分表方式只有横向分表。

因为对于资金流水这种特殊数据来说，是不能清理数据的，那么纵向分表和拆成固定的几个表都不能解决单表数据无限膨胀的问题。而横向分表，可以把每张表的数据量恒定，到一定时间后可以进行财务数据归档。

分表的依据一般都是根据表的某个或者某几个字段进行拆分，最终其实是对数据和业务分析综合出来的结果。总的来说，原则有这几个：

• 尽可能选择查询条件里最常出现的字段，这样能够减少方法改造的工程

• 需要考虑根据某个字段拆分数据是否能够均匀分布，是否能够满足单表1000W左右的要求

• 该字段必须是必现字段，不允许出现空值

综合分析我们的数据以及业务需要，“交易时间”这个分表依据就呼之欲出了。

首先，这个字段作为流水最重要的字段之一一定会出现；

第二，如果按照交易月份进行拆表，每张表大概也就是600W-700W的数据；

最后，有70%的查询都附带“交易时间”作为查询条件。

5、技术难点

5.1、多数据源事务问题

sharding-jdbc在使用的时候是需要用自己的独立数据源的，那么就难免出现多数据源事务问题。

这个我们通过自定义注解，自定义切面开启事务，通过方法栈逐层回滚or提交的方式解决的。出于保密原则，具体代码细节不再展开。

5.2、多表的分页问题

拆表一定会引起分页查询的难度增加。由于各个表查出来的数据量不等，原始的sql语句limit不再适用，需要设计一个新方法便捷的获取分页信息。

在此介绍一个分页的思路供大家参考（团队共同的成果，笔者不敢私自占有）：

综合考虑业务实际与开发的复杂程度，项目团队决定在出现跨表查询的情况下，每一张表采用一个线程进行查询，以提高查询效率。

这个方案的难点在于分页规则的转换。例如，页面传入的offset和pageSize分别为8和20。各分表中符合条件的数量分别为10,10,50。那么我们需要将总的分页条件转化为三个分表各自的分页条件，如图

通过上图可以看到，大分页条件(offset=8,pageSize=20)，转换为(offset=8,pageSize=2)，(offset=0.pageSize=10)，(offset=0,pageSize=8)三个条件。

整个计算过程如下：

1)      多线程查询各个分表中满足条件的数据数量

2)      将各个表数量按照分表的先后顺序累加，形成图 8的数轴

3)      判断第一条数据和最后一条数据所在的表

4)      除第一条和最后一条数据所在表外，其他表offset=0，pageSize=总数量

5)      计算第一条数据的offset，pageSize

计算最后一条数据的pageSize，同时将该表查询条件的offset设置为0

5.3、数据迁移方案

在数据迁移前，团队讨论过两套迁移方案：

1)请DBA迁移数据；

2)手写代码迁移数据，他们各有自己的优缺点：

综合考虑时间成本和对线上数据库的影响，团队决定采用两种方案结合的方式：

• 交易时间为三个月前的冷数据，由于更新几率不大，采用代码的方式迁移，人为控制每次迁移数量，少量多次，蚂蚁搬家；

• 交易时间为三个月内的热数据，由于会在上线前频繁出现更新操作，则在上线前停止写操作，而后由DBA整体迁移。这样将时间成本平摊到平时，上线前只有约2个小时左右迁移数据时系统无法使用。

• 同时，除了最后一次DBA迁移数据外，能够人为控制每次迁移的数据量，整体避免数据库实例级别的高延迟。

5.4、整体上线流程

为保证新表拆分功能的稳定性和大表下线的稳定，团队将整个项目分为三个阶段：

• 第一阶段：建立分表，大表数据迁移分表，线上数据新表老表双写，所有查询走分表（验证观察）

• 第二阶段：停止写老数据表，其他业务直连数据库改为资金提供对外接口（验证观察）

• 第三阶段：大表下线

 

6、总结 

• 应再进一步调研分表相关中间件。由于项目分表依据的特殊性，导致sharding-jdbc的很多功能无法利用，其对于简化查询逻辑的帮助低于预期。并且sharding-jdbc独立数据源的特性，引发了多数据源事务问题，反而增加了开发的工作量。

• 多线程需要仔细分析线程池核心线程的大小，同时分析多线程池同时存在的时候是否会引起核心线程数过多，避免机器线程打满。

• 如果是一个已有的项目，在进行分表改造时，一定要将各种场景都罗列清楚，将各个场景细化到程序中的每个类、每个方法中，将所有业务场景都覆盖到。

• 在迁移历史数据时，一定要做好迁移数据方案，以及应对出现数据不一致时的处理方案。要综合考虑时间成本、数据准确性、对线上功能的影响等诸多因素。

• 在上线一个比较复杂的方案时，一定要提前设计好回滚方案和降级措施，能够极大保证稳定性。