分布式架构系统生成全局唯一序列号的一个思路
资讯
0
2423
2020-08-13 12:04:22
<p> </p>
<div class="active aw-upload-img-list"><a href="https://www.21cto.com/uploads/article/20200813/1285e832a06c7be401cad5e1be56a64a.jpg" rel="lightbox" target="_blank"><img alt="amazon-aws-codeguru-code-reviewer-github-developer_(1).jpg" class="img-polaroid" src="https://www.21cto.com/uploads/article/20200813/1285e832a06c7be401cad5e1be56a64a.jpg" title="amazon-aws-codeguru-code-reviewer-github-developer_(1).jpg" /></a></div>
<p><br />
<br />
<strong>一、相关背景</strong><br />
<br />
分布式架构下,唯一序列号生成是我们在设计一个系统,尤其是数据库使用分库分表的时候常常会遇见的问题。当分成若干个sharding表后,如何能够快速拿到一个唯一序列号,是经常遇到的问题。<br />
<br />
在携程账号数据库迁移MySql过程中,我们对用户ID的生成方案进行了新的设计,要求能够支撑携程现有的新用户注册体量。<br />
<br />
本文通过携程用户ID生成器的实现,希望能够对大家设计分库分表的唯一id有一些新的思路。<br />
<br />
<strong>二、特性需求</strong><br />
</p>
<p> </p>
<ul>
<li>全局唯一</li>
<li>支持高并发</li>
<li>能够体现一定属性</li>
<li>高可靠,容错单点故障</li>
<li>高性能</li>
</ul>
<p><br />
<br />
<strong>三、业内方案</strong><br />
<br />
生成ID的方法有很多,来适应不同的场景、需求以及性能要求。<br />
<br />
常见方式有:<br />
<br />
1、利用数据库递增,全数据库唯一。<br />
<br />
优点:明显,可控。<br />
缺点:单库单表,数据库压力大。<br />
<br />
2、UUID, 生成的是length=32的16进制格式的字符串,如果回退为byte数组共16个byte元素,即UUID是一个128bit长的数字,一般用16进制表示。<br />
<br />
优点:对数据库压力减轻了。<br />
缺点:但是排序怎么办?<br />
此外还有UUID的变种,增加一个时间拼接,但是会造成id非常长。<br />
<br />
3、twitter在把存储系统从MySQL迁移到Cassandra的过程中由于Cassandra没有顺序ID生成机制,于是自己开发了一套全局唯一ID生成服务:Snowflake。<br />
<br />
1 ) 41位的时间序列(精确到毫秒,41位的长度可以使用69年)<br />
2 ) 10位的机器标识(10位的长度最多支持部署1024个节点) <br />
3 )12位的计数顺序号(12位的计数顺序号支持每个节点每毫秒产生4096个ID序号) 最高位是符号位,始终为0。<br />
<br />
优点:高性能,低延迟;独立的应用;按时间有序。<br />
缺点:需要独立的开发和部署。<br />
<br />
4、Redis生成ID<br />
<br />
当使用数据库来生成ID性能不够要求的时候,我们可以尝试使用Redis来生成ID。这主要依赖于Redis是单线程的,所以也可以用生成全局唯一的ID。可以用Redis的原子操作INCR和INCRBY来实现。<br />
<br />
可以使用Redis集群来获取更高的吞吐量。假如一个集群中有5台Redis。可以初始化每台Redis的值分别是1,2,3,4,5,然后步长都是5。各个Redis生成的ID为:</p>
<p>
<p>
<p> </p>
</p>
</p>
<pre>
A:1,6,11,16,21
B:2,7,12,17,22
C:3,8,13,18,23
D:4,9,14,19,24
E:5,10,15,20,25</pre>
<p><br />
比较适合使用Redis来生成每天从0开始的流水号。比如订单号=日期+当日自增长号。可以每天在Redis中生成一个Key,使用INCR进行累加。<br />
<br />
优点:<br />
不依赖于数据库,灵活方便,且性能优于数据库。<br />
数字ID天然排序,对分页或者需要排序的结果很有帮助。<br />
使用Redis集群也可以防止单点故障的问题。<br />
<br />
缺点:<br />
如果系统中没有Redis,还需要引入新的组件,增加系统复杂度。<br />
需要编码和配置的工作量比较大,多环境运维很麻烦,<br />
在开始时,程序实例负载到哪个redis实例一旦确定好,未来很难做修改。<br />
<br />
5. Flicker的解决方案<br />
<br />
因为MySQL本身支持auto_increment操作,很自然地,我们会想到借助这个特性来实现这个功能。<br />
Flicker在解决全局ID生成方案里就采用了MySQL自增长ID的机制(auto_increment + replace into + MyISAM)。<br />
<br />
6.还有其他一些方案,比如京东淘宝等电商的订单号生成。因为订单号和用户id在业务上的区别,订单号尽可能要多些冗余的业务信息,比如:<br />
<br />
滴滴:时间+起点编号+车牌号<br />
淘宝订单:时间戳+用户ID<br />
其他电商:时间戳+下单渠道+用户ID,有的会加上订单第一个商品的ID。<br />
<br />
而用户ID,则要求含义简单明了,包含注册渠道即可,尽量短。<br />
<br />
<strong>四、最终方案</strong><br />
<br />
最终我们选择了以flicker方案为基础进行优化改进。具体实现是,单表递增,内存缓存号段的方式。<br />
<br />
首先建立一张表,像这样:</p>
<pre>
SEQUENCE_GENERATOR_TABLE
id stub
1 192.168.1.1</pre>
<p><br />
其中id是自增的,stub是服务器ip。<br />
<br />
因为新数据库采用mysql,所以使用mysql的独有语法 replace to来更新记录来获得唯一id,例如这样:<br />
</p>
<pre>
REPLACE INTO SEQUENCE_GENERATOR_TABLE (stub) VALUES ("192.168.1.1");
</pre>
<p>再用:<br />
</p>
<pre>
<code class="language-sql">SELECT id FROM SEQUENCE_GENERATOR_TABLEWHERE stub = "192.168.1.1";
</code></pre>
<p>把它拿回来。<br />
<br />
到上面为止,我们只是在单台数据库上生成ID,从高可用角度考虑,接下来就要解决单点故障问题。<br />
<br />
这也就是为什么要有这个机器ip字段呢?就是为了防止多服务器同时更新数据,取回的id混淆的问题。<br />
<br />
所以,当多个服务器的时候,这个表是这样的:</p>
<pre>
id stub
5 192.168.1.1
2 192.168.1.2
3 192.168.1.3
4 192.168.1.4</pre>
<p>每台服务器只更新自己的那条记录,保证了单线程操作单行记录。这时候每个机器拿到的分别是5,2,3,4这4个id。<br />
<br />
至此,我们似乎解决这个服务器隔离,原子性获得id的问题,也和flicker方案基本一致。<br />
<br />
但是追根溯源,在原理上,方案还是依靠数据库的特性,每次生成id都要请求db,开销很大。我们对此又进行优化,把这个id作为一个号段,而并不是要发出去的序列号,并且这个号段是可以配置长度的,可以1000也可以10000,也就是对拿回来的这个id放大多少倍的问题。<br />
<br />
OK,我们从DB一次查询操作的开销,拿回来了1000个用户id到内存中了。<br />
<br />
现在的问题就是要解决同一台服务器在高并发场景,让大家顺序拿号,别拿重复,也别漏拿。<br />
<br />
这个问题简单来说,就是个保持这个号段对象隔离性的问题。<br />
AtomicLong是个靠谱的办法。<br />
当第一次拿回号段id后,扩大1000倍,然后赋值给这个变量atomic,这就是这个号段的第一个号码。</p>
<pre>
atomic.set(n * 1000);
</pre>
<p> <br />
并且内存里保存一下最大id,也就是这个号段的最后一个号码<br />
</p>
<pre>
currentMaxId = (n + 1) * 1000;
</pre>
<p> <br />
一个号段就形成了。<br />
<br />
此时每次有请求来取号时候,判断一下有没有到最后一个号码,没有到,就拿个号,走人。</p>
<pre>
Long uid = atomic.incrementAndGet();
</pre>
<p> <br />
如果到达了最后一个号码,那么阻塞住其他请求线程,最早的那个线程去db取个号段,再更新一下号段的两个值,就可以了。<br />
<br />
这个方案,核心代码逻辑不到20行,解决了分布式系统序列号生成的问题。<br />
<br />
这里有个小问题,就是在服务器重启后,因为号码缓存在内存,会浪费掉一部分用户ID没有发出去,所以在可能频繁发布的应用中,尽量减小号段放大的步长n,能够减少浪费。<br />
<br />
经过实践,性能的提升远远重要于浪费一部分id。<br />
<br />
如果再追求极致,可以监听spring或者servlet上下文的销毁事件,把当前即将发出去的用户ID保存起来,下次启动时候再捞回内存即可。<br />
<br />
<strong>五、上线效果</strong><br />
<br />
运行5个多月,十分稳定。<br />
<br />
SOA服务平均响应时间 0.59毫秒;<br />
<br />
客户端调用平均响应时间2.52毫秒;<br />
<br />
<br />
附流程图:<br />
</p>
<div class="active aw-upload-img-list"><a href="https://www.21cto.com/uploads/article/20200813/7d985ce3e797b669d8cae56d64415f73.png" rel="lightbox" target="_blank"><img alt="id-gen-map.png" class="img-polaroid" src="https://www.21cto.com/uploads/article/20200813/7d985ce3e797b669d8cae56d64415f73.png" title="id-gen-map.png" /></a></div>
<p> </p>
<p><br />
</p>
<p> </p>
<p> </p>
<p> </p>
<blockquote>
<p><span style="font-size:14px">作者:丁宜人。</span><br />
<span style="font-size:14px">10年Java开发经验。携程技术中心基础业务研发部用户中心资深Java工程师,负责携程账号的基础服务和相关框架组件研发。之前在惠普公司供职6年,负责消息中间件产品研发。</span><br />
<span style="font-size:14px">来源:携程技术公众号</span></p>
</blockquote>
<p> </p>
<p> </p>
本文为 @ 21CTO 创作并授权 21CTO 发布,未经许可,请勿转载。
内容授权事宜请您联系 webmaster@21cto.com或关注 21CTO 公众号。
该文观点仅代表作者本人,21CTO 平台仅提供信息存储空间服务。