MySQL之水平分表取模算法

在我们业务中,在并发很高的IO下,往往是需要水平分表(分库)或者是垂直分表(分库)。
本文,就详细介绍水平分表之取模算法:

假设一个场景,APP需要手机号登录或者注册,而一张用户表中已经有千万级的数据,单表的IO读写已经很吃力,需要迫切的分表,那么该如何分表,以什么形式去分

分表方法:
1.取模算法
2.哈希算法
3.范围分表

本文针对水平分表的取模算法来分析:

1.取模实际上就是对被除数进行取余的操作 A%B=余数
2.利用用户手机尾号进行求余的操作
3.假如我们水平分表5张表,那么求余公式则为尾号/5=余数
4.这个余数就是我们的表名,进而得出该用户信息应该在哪张表
5.业务直接去以余数命名的该表查询信息

原始业务图解:


WechatIMG489.jpeg

将要实现的:


WechatIMG490.jpeg

开始实践:

我们将用户表设计为5张表 从user_0....user_4;

表结构如下:

WechatIMG488.jpeg

字段name即为手机号

在上期中,我们了解了负载均衡与消息队列,我们这次将请求还是与之前的结合起来

producer项目里创建controller

public function AddUser():void {
        $data['name'] = time();
        $json = json_encode($data);
        dispatch(new UserJob($json))->onQueue('User');
    }

`
将当前时间戳模拟为用户手机号,并推入到RabbitMQ

consumer项目的队列消费者进程开始消费

public function handle(){
        $data = json_decode($this->data,true);
        $table = 'User_'.$data['name']%5;
        $tableObj = $this->tableObj($table);
        $tableObj->name = $data['name'];
        $tableObj->save();
    }

    /**
     * 通过反射返回Model对象
     * @param $class_name
     * @return object
     * @author mjShu
     * @throws \ReflectionException
     */
    private function tableObj($class_name){
        $class_name = 'App\Http\Model\\'.$class_name;
        $class = new \ReflectionClass($class_name);
        $obj = $class->newInstance();
        return $obj;
    }

handle方法里,我们通过对producer生产的数据中的模拟手机号进行求余
得到余数,通过字符串拼接得到表名,表名等于User_余数

进而通过PHP的反射机制实例化Model类,将其保存进表

启动AB测试
ab -c 100 -n 2000 http://192.168.2.101/user

RabbitMQ消费后通过Lumen队列插入数据库
启动horizon,应该如图

WechatIMG485.jpeg

RabbitMQ ACK确认完毕后,我们来查看下表:

WechatIMG486.jpeg

由此可见,我们的数据均是是被水平均匀的拆分到5张表中,怎么样,是不是很简单呢,原理就是通过求余来确定数据的落表地点,进而直接查询该表,均匀打散了数据,并且有规律可循,避免了单表的压力过大,相同理论,该分表方法也可以运用到其他方面,本文只是做一下探讨,实际上求余的操作,都是由中间件完成,不应该放在业务中,因为太繁琐,比如查询某个日期的数据,必须每张表都要执行查询最终合并结果集返回

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。