java redis id生成器_基于redis的分布式ID生成器

项目地址

基于redis的分布式ID生成器。

准备

首先,要知道redis的EVAL,EVALSHA命令:

原理

利用redis的lua脚本执行功能,在每个节点上通过lua脚本生成唯一ID。

生成的ID是64位的:

使用41 bit来存放时间,精确到毫秒,可以使用41年。

使用12 bit来存放逻辑分片ID,最大分片ID是4095

使用10 bit来存放自增长ID,意味着每个节点,每毫秒最多可以生成1024个ID

比如GTM时间 Fri Mar 13 10:00:00 CST 2015 ,它的距1970年的毫秒数是 1426212000000,假定分片ID是53,自增长序列是4,则生成的ID是:

15981966696448054276 = 1426212000000 << 22 + 53 << 10 + 4

redis提供了TIME命令,可以取得redis服务器上的秒数和微秒数。因些lua脚本返回的是一个四元组。

1second, microSecond, partition, seq

客户端要自己处理,生成最终ID。

1((second * 1000 + microSecond / 1000) << (12 + 10)) + (shardId << 10) + seq;

集群实现原理

假定集群里有3个节点,则节点1返回的seq是:

10, 3, 6, 9, 12 ...

节点2返回的seq是

11, 4, 7, 10, 13 ...

节点3返回的seq是

12, 5, 8, 11, 14 ...

这样每个节点返回的数据都是唯一的。

单个节点部署

下载redis-script-node1.lua,并把它load到redis上。

1

2

3cd redis-directory/

wget https://raw.githubusercontent.com/hengyunabc/redis-id-generator/master/redis-script-node1.lua

./redis-cli script load "$(cat redis-script-node1.lua)"

获取lua脚本的sha1值,可能是:

1fce3758b2e0af6cbf8fea4d42b379cd0dc374418

在代码里,通过EVALSHA命令,传递这个sha1值,就可以得到生成的ID。

比如,通过命令行执行:

1./redis-cli EVALSHA fce3758b2e0af6cbf8fea4d42b379cd0dc374418 2 test 123456789

结果可能是:

1

2

3

41) (integer) 1426238286

2) (integer) 130532

3) (integer) 277

4) (integer) 4

集群部署

假定集群是3个节点,则分别对三个节点执行:

1

2

3./redis-cli -host node1 -p 6379 script load "$(cat redis-script-node1.lua)"

./redis-cli -host node2 -p 7379 script load "$(cat redis-script-node2.lua)"

./redis-cli -host node3 -p 8379 script load "$(cat redis-script-node3.lua)"

性能

redis默认配置。

1

2

3

4

5

6单节点,单线程:

time:0:00:00.959

speed:10427.52867570386

单节点,20线程:

time:0:00:06.710

speed:29806.259314456034

结论:

单节点,qps约3w

可以线性扩展,3个结点足以满足绝大部分的应用

java客户端封装

在redis-id-generator-java目录下,有example和benchmark代码。

在调用时,要传入两个参数

tag,即为哪一类服务生成ID

shardId,即分片由哪个ID生成,比如一个用户的订单,则分片ID应该由userId来生成

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21public class Example{

public static void main(String[] args){

String tab = "order";

long userId = 123456789;

IdGenerator idGenerator = IdGenerator.builder()

.addHost("127.0.0.1", 6379, "fce3758b2e0af6cbf8fea4d42b379cd0dc374418")

//.addHost("127.0.0.1", 7379, "1abc55928f37176cb934fc7a65069bf32282d817")

//.addHost("127.0.0.1", 8379, "b056d20feb3f89483b10c81027440cbf6920f74f")

.build();

long id = idGenerator.next(tab, userId);

System.out.println("id:" + id);

List result = IdGenerator.parseId(id);

System.out.println("miliSeconds:" + result.get(0) + ", partition:"

+ result.get(1) + ", seq:" + result.get(2));

}

}

多语言客户端

只要支持redis evalsha命令就可以了。

其它

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/550824.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java自动切表_java_Mybatis自动创建表和更新表结构,最近有小伙伴问我mybatis有没有 - phpStudy...

Mybatis自动创建表和更新表结构最近有小伙伴问我mybatis有没有自动创建表结构的功能&#xff0c;因为他们之前一直使用hibernate用习惯了&#xff0c;理所当然的认为&#xff0c;在实体类上配置下注解或者写写映射文件&#xff0c;系统启动后就可以自动创建表。我只能很遗憾的告…

java byte 正数最大_关于JAVA中Byte类型的取值范围的推论(*零为正数,-128在计算机中的表示方法...)...

先看一段推理124:0111 1100  -124:1000 0100125:0111 1101  -125:1000 0011126:0111 1110  -126:1000 0010127:0111 1111  -127:1000 0001128:0 1000 0000 -128:1000 0000从上述过程对比可以看出:128是在127的基础上加1得到,但是会造成溢出(java中byte的大小为一个字…

java不同类间调用数组_请问:JAVA中两个类中的方法都需要调用另一个类的数组进行对数组的初始化和调用。...

匿名用户1级2013-09-14 回答import java.util.ArrayList;import java.util.Iterator;import java.util.List;/*** 测试类* author Administrator**/public class Test02 {public static void main(String[] args) {MovieStore movieStore new MovieStore();DVDManage.initDVD(…

java函数只有参数类不一样_java的函数参数传递

java中只有一种参数传递方式&#xff1a;传值&#xff1b;这点和c不一样&#xff0c;c中有传值和引用两种方式。虽然java只有传值这一种传递方式&#xff0c;但是根据参数类型的不同&#xff0c;函数对参数的影响也会不一样。可以这么说&#xff1a;形参是实参的一份拷贝&#…

java缓存回收_java缓存应用 - 阿亮ing的个人空间 - OSCHINA - 中文开源技术交流社区...

缓存回收策略1.基于空间设置缓存的存储空间&#xff0c;超过容量限制按照一定的规则去移除。2.基于容量当缓存条数超过规定容量按照一定的规则去移除旧数据。3.基于时间(存活时间空闲时间)TTl(Time To Live):存活期&#xff0c;缓存数据最后更新时间到指定时间如果没有更新或创…

java mvc中重复提交_SpringMVC之——防止重复提交表单的方法(一)

这篇博文介绍第一种方法&#xff1a;判断session或其他缓存中保存的token&#xff0c;这里以session为例&#xff0c;具体大家也可以自行扩展以其他的缓存实现。这种方式比较麻烦&#xff0c;每次在提交表单时都必须传入上次的token。而且当一个页面使用ajax时&#xff0c;多个…

三层加过的注释java_spring框架中三层架构相关的注解

做了这么多年的C&#xff0c;再去学Java&#xff0c;确实发现&#xff0c;语言都是相通的&#xff0c;即使是Java的那么多生态&#xff0c;理解起来也并不费劲Spring 框架目前还在学习中&#xff0c;处于 Tourist 阶段&#xff0c;目前只求会做&#xff0c;不求原理&#xff0c…

尤其是java程序员(转载)_JAVA程序员 学习任务(转载)

1. 你需要精通面向对象分析与设计(OOA/OOD)、涉及模式(GOF&#xff0c;J2EEDP)以及综合模式。你应该了解UML&#xff0c;尤其是class、object、interaction以及statediagrams。2. 你需要学习Java语言的基础知识以及它的核心类库(collections、serialization、streams、networki…

java setfilter_Java – setFileFilter问题

我正在JFileChooser上构建一个JFileFilter,但是如果我有代码setFileFilter并且我的IDE提供了信息’JFileChooser类型中的方法setFileFilter(FileFilter)不适用于参数(new FileFilter(){},则会发生错误)”.不过我确信我之前已经用这种格式完成了它并且一切都很好.任何人都可以帮…

mysql指南_MySQL入门指南

MySQL入门指南,希望对大家用处&#xff01;&#xff01;一、SQL速成以下是一些重要的SQL快速参考&#xff0c;有关SQL的语法和在标准SQL上增加的特性&#xff0c;请查询MySQL手册。1&#xff0e;创建表表是数据库的最基本元素之一&#xff0c;表与表之间可以相互独立&#xff0…

java单线程上锁_关于Java多线程编程锁优化的深入学习

正文并发环境下进行编程时&#xff0c;需要使用锁机制来同步多线程间的操作&#xff0c;保证共享资源的互斥访问。加锁会带来性能上的损坏&#xff0c;似乎是众所周知的事情。然而&#xff0c;加锁本身不会带来多少的性能消耗&#xff0c;性能主要是在线程的获取锁的过程。如果…

java test circle_TestCircle.java

import java.util.Scanner;public class TestCircle {public static void main(String[] args) {// TODO Auto-generated method stubScanner sc new Scanner(System.in);/*Circle c1 new Circle();System.out.print("第一个圆已经生成, 它的半径是:");System.out.…

蓝桥杯小朋友排队java_[蓝桥杯][历届试题]小朋友排队 (C++代码)

#include#define maxn 100010struct data{int num,cnt;}A[maxn],temp[maxn];int n;//long long ans;long long ANS[100];void merge(int L1,int R1,int L2,int R2){int k0,iL1,jL2;while(i<R1 && j<R2){if(A[i].num<A[j].num)//如果A[i].num{A[i].cntj-L2;tem…

android 换行乱_Android自动换行布局

public class FlowLayout extends ViewGroup {/*** 所有子控件的容器*/private List> lineList new ArrayList<>();/*** 每行的高度*/private List lineHeightList new ArrayList<>();/*** 防止多次测量*/private boolean measureFlag true;public FlowLayou…

php数组常用_PHP常用数组总结

header("Content-type:text/html;charsetutf8");//1. array_shift&#xff1a;将数组开头的元素移出数组 出栈 影响原数组$arrarray(1,2,3,4,5,6,7,8,9);echo array_shift($arr);echo "";//2. array_unshift&#xff1a;向数组开头添加一个或更多个元素,所…

php 生成打印送货单,PHP输出PDF打印HTML5+CSS3打印格式控制

ERP系统进入尾声&#xff0c;各种送货单、退货单、合同、对账单等等一系列的东东排着队调打印格式。HTML5CSS3已经这样流行&#xff0c;然则眼下&#xff0c;基于CSS3的打印控制&#xff0c;居然还处于原始部落阶段&#xff0c;Chrome、Firefox、Edge等连简单的page都支持得不完…

备案php代码,备案查询API PHP代码

在线演示http://tool.ayangw.com/beian/?urlqq.com使用方法1.创建一个php文件&#xff0c;比如beian.php&#xff0c;将下方代码复制2.访问接口域名/beian.php?urlqq.comPHP代码<?php /*** 0en.cn*/error_reporting(0);$u $_GET[url];var_dump();if(!isset($u)){echo ?…

php转盘中奖率,PHP大转盘中奖概率算法实例_PHP

本文实例讲述了PHP大转盘中奖概率算法的实现方法&#xff0c;分享给大家供大家参考。具体如下&#xff1a;大转盘是最近很多线上网动中一个比较有意思的东西了&#xff0c;下面我们就来看看这个大转盘中奖概率算法与例子&#xff0c;希望对各位有所帮助。这是一个APP客户端有大…

php 发送delete请求,PHP中使用CURL实现GET、POST、PUT、DELETE请求

/*** param $url* param $data* param string $method* param string $type* return bool|string*/function curlData($url,$data,$method GET,$typejson){//初始化$ch curl_init();$headers [form-data > [Content-Type: multipart/form-data],json > [Content-Type:…

帝国cms php替换,帝国CMS内容关键字替换图片标签解决方法

1、在 e/class/userfun.php 里面增加//替换正文IMG里的ALT内容functionuser_imgalt($mid,$f,$isadd,$isq,$value,$cs){$title$_POST[title];$htmls$value;$pattern "/]>/";preg_match_all($pattern, $htmls, $matches);for($i0; $i<count($matches[0]); $i) {p…