千家信息网

全局id生成器试用之Leaf

发表于:2024-12-03 作者:千家信息网编辑
千家信息网最后更新 2024年12月03日,数据量上来后,单库单表承受不住的时候,我们就需要引入分库分表。 但是分库分表后,主键id就不能依赖于MySQL,需要从外部去获取id。目前我们生产环境在用的DBLE作为中分库分表中间件, 其自带了类似
千家信息网最后更新 2024年12月03日全局id生成器试用之Leaf

数据量上来后,单库单表承受不住的时候,我们就需要引入分库分表。 但是分库分表后,主键id就不能依赖于MySQL,需要从外部去获取id。


目前我们生产环境在用的DBLE作为中分库分表中间件, 其自带了类似snowflake方案的全局id生成器,也可以基于数据库来实现。


但是,在一个大点的公司里面, 全局id 是一个用处很广泛的服务,通常会独立作为一个公共服务对外提供。


这里我们就以 美团点评出的 Leaf为例,看下它的效果。


相关文档:

https://tech.meituan.com/2019/03/07/open-source-project-leaf.html

https://tech.meituan.com/2017/04/21/mt-leaf.html

https://blog.csdn.net/bskfnvjtlyzmv867/article/details/90175306 源码详解


官方的2篇文档,介绍的很详细了,我们就不啰嗦了。



下面的演示,是基于数据库做id分发 (数据库的SLA可以使用MHA、pxc或mgr来保证)



0 环境

OS版本: CentOS7

node1 IP: 192.168.20.10

node2 IP: 192.168.20.17

MySQL地址: 192.168.20.10


1 创建数据库表等

CREATE DATABASE leaf ;use leaf ;CREATE TABLE `leaf_alloc` (  `biz_tag` varchar(128)  NOT NULL DEFAULT '', -- your biz unique name  `max_id` bigint(20) NOT NULL DEFAULT '1',  `step` int(11) NOT NULL,  `description` varchar(256)  DEFAULT NULL,  `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,  PRIMARY KEY (`biz_tag`)) ENGINE=InnoDB;-- 插入几条需要分发id的服务的标识(我这里在默认的基础上,加了 卡券id、帖子id 这2个例子)insert into leaf_alloc(biz_tag, max_id, step, description) values('leaf-segment-test', 1, 2000, 'Test leaf Segment Mode Get Id');insert into leaf_alloc(biz_tag, max_id, step, description) values('coupon', 1, 2000, 'Get coupon Id');insert into leaf_alloc(biz_tag, max_id, step, description) values('tid', 1, 1000, 'Get tiezi id');select * from leaf_alloc ;+-------------------+--------+------+-------------------------------+---------------------+| biz_tag           | max_id | step | description                   | update_time         |+-------------------+--------+------+-------------------------------+---------------------+| coupon            |      1 | 2000 | Get coupon Id                 | 2019-10-12 17:47:23 || leaf-segment-test |      1 | 2000 | Test leaf Segment Mode Get Id | 2019-10-12 17:47:00 || tid               |      1 | 1000 | Get tiezi id                  | 2019-10-12 17:48:21 |+-------------------+--------+------+-------------------------------+---------------------+3 rows in set (0.001 sec)-- 创建独立的数据库账号create user leaf@'%' identified by 'leaf1234';grant select,update,delete,insert on leaf.* to leaf@'%';



2 编译leaf-server

注意:需要在node1和node2上单独执行编译和启动的操作,编译+启动 依赖到 maven 和 oracle-jdk

cd /usr/local/git clone https://github.com/Meituan-Dianping/Leaf.gitcd leafmvn clean install -DskipTestscd leaf-server


vim leaf-server/src/main/resources/leaf.properties 修改配置文件中数据库的连接方式

leaf.name=com.sankuai.leaf.opensource.testleaf.segment.enable=trueleaf.jdbc.url=jdbc:mysql://192.168.20.10:3306/leaf?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8leaf.jdbc.username=leafleaf.jdbc.password=leaf1234leaf.snowflake.enable=false#leaf.snowflake.zk.address=#leaf.snowflake.port=


3 启动leaf-server:

cd /usr/local/leaf/leaf-servermvn spring-boot:run


4 测试

测试我上面插入的3个biz_tag的发号器情况:

curl http://192.168.20.10:8080/api/segment/get/leaf-segment-test

curl http://192.168.20.10:8080/api/segment/get/coupon

curl

http://192.168.20.10:8080/api/segment/get/tid


5 其它

号段模式自带了个监控界面:

http://192.168.20.10:8080/cache


测试id的生成效果:

for i in {1..2000}; do  curl http://192.168.20.17:8080/api/segment/get/coupon; donefor i in {1..2000}; do  curl http://192.168.20.10:8080/api/segment/get/coupon; done


然后,我们在for循环获取id的时候,人为的把MySQL关闭掉,可以看到如下的,可以看到刚开始leaf因为号段+双buffer的存在,可以继续发号,但是当预分配的id都用光后,就会报错了:


只要我们的MySQL数据库故障切换的时候不要太久,并且配合设置不同biz_tag以不同大小的step,通不会对对leaf服务造成影响。



下面是双buffer在web界面上的体现:




0