Mybatis-Plus雪花id的使用以及解析机器ID和数据标识ID实现

2023-07-18 00:21:03 180

概述

分布式系统中，有一些需要使用全局唯一ID的场景，这种时候为了防止ID冲突可以使用36位的UUID，但是UUID有一些缺点，首先他相对比较长，另外UUID一般是无序的。

有些时候我们希望能使用一种简单一些的ID，并且希望ID能够按照时间有序生成。

而twitter的snowflake解决了这种需求，最初Twitter把存储系统从MySQL迁移到Cassandra，因为Cassandra没有顺序ID生成机制，所以开发了这样一套全局唯一ID生成服务。

结构

snowflake的结构如下(每部分用-分开):

0-00000000000000000000000000000000000000000-00000-00000-000000000000

第一位为未使用，接下来的41位为毫秒级时间(41位的长度可以使用69年)，然后是5位datacenterId和5位workerId(10位的长度最多支持部署1024个节点），最后12位是毫秒内的计数（12位的计数顺序号支持每个节点每毫秒产生4096个ID序号）

一共加起来刚好64位，为一个Long型。(转换成字符串后长度最多19)

snowflake生成的ID整体上按照时间自增排序，并且整个分布式系统内不会产生ID碰撞（由datacenter和workerId作区分），并且效率较高。经测试snowflake每秒能够产生26万个ID。

源码

/**
*Twitter_Snowflake

*SnowFlake的结构如下(每部分用-分开):

*0-00000000000000000000000000000000000000000-00000-00000-000000000000

*1位标识，由于long基本类型在Java中是带符号的，最高位是符号位，正数是0，负数是1，所以id一般是正数，最高位是0

*41位时间截(毫秒级)，注意，41位时间截不是存储当前时间的时间截，而是存储时间截的差值（当前时间截-开始时间截)
*得到的值），这里的的开始时间截，一般是我们的id生成器开始使用的时间，由我们程序来指定的（如下下面程序IdWorker类的startTime属性）。41位的时间截，可以使用69年，年T=(1L<<41)/(1000L*60*60*24*365)=69

*10位的数据机器位，可以部署在1024个节点，包括5位datacenterId和5位workerId

*12位序列，毫秒内的计数，12位的计数顺序号支持每个节点每毫秒(同一机器，同一时间截)产生4096个ID序号

*加起来刚好64位，为一个Long型。

*SnowFlake的优点是，整体上按照时间自增排序，并且整个分布式系统内不会产生ID碰撞(由数据中心ID和机器ID作区分)，并且效率较高，经测试，SnowFlake每秒能够产生26万ID左右。
*/
publicclassSnowflakeIdWorker{

//==============================Fields===========================================
/**开始时间截(2015-01-01)*/
privatefinallongtwepoch=1420041600000L;

/**机器id所占的位数*/
privatefinallongworkerIdBits=5L;

/**数据标识id所占的位数*/
privatefinallongdatacenterIdBits=5L;

/**支持的最大机器id，结果是31(这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数)*/
privatefinallongmaxWorkerId=-1L^(-1L<maxWorkerId||workerId<0){
thrownewIllegalArgumentException(String.format("workerIdcan'tbegreaterthan%dorlessthan0",maxWorkerId));
}
if(datacenterId>maxDatacenterId||datacenterId<0){
thrownewIllegalArgumentException(String.format("datacenterIdcan'tbegreaterthan%dorlessthan0",maxDatacenterId));
}
this.workerId=workerId;
this.datacenterId=datacenterId;
}

//==============================Methods==========================================
/**
*获得下一个ID(该方法是线程安全的)
*@returnSnowflakeId
*/
publicsynchronizedlongnextId(){
longtimestamp=timeGen();

//如果当前时间小于上一次ID生成的时间戳，说明系统时钟回退过这个时候应当抛出异常
if(timestamp
以上资料转载自该博客，点我！
Mybatis-Plus使用雪花id
注意：以下配置是在SpringBoot2.1.4版本以及在mybatis已经可以使用的基础上做的升级配置！
1.引入Mybatis-Plus依赖（3.1.1版本目前有些问题，建议使用3.1.0版本）

com.baomidou
mybatis-plus-boot-starter
3.1.0
	

2.在application.yml配置文件中增加如下配置项
mybatis-plus:
#mapper-locations:classpath:mybatis/**/*Mapper.xml
#在classpath前添加星号可以使项目热加载成功
mapper-locations:classpath*:mybatis/**/*Mapper.xml
#实体扫描，多个package用逗号或者分号分隔
typeAliasesPackage:com.nis.project
global-config:
#主键类型0:"数据库ID自增",1:"用户输入ID",2:"全局唯一ID(数字类型唯一ID)",3:"全局唯一IDUUID";
id-type:3
#机器ID部分(影响雪花ID)
workerId:1
#数据标识ID部分(影响雪花ID)(workerId和datacenterId一起配置才能重新初始化Sequence)
datacenterId:18
#字段策略0:"忽略判断",1:"非NULL判断"),2:"非空判断"
field-strategy:2
#驼峰下划线转换
db-column-underline:true
#刷新mapper调试神器
refresh-mapper:true
#数据库大写下划线转换
#capital-mode:true
#序列接口实现类配置
#key-generator:com.baomidou.springboot.xxx
#逻辑删除配置（下面3个配置）
logic-delete-value:0
logic-not-delete-value:1
#自定义SQL注入器
#sql-injector:com.baomidou.mybatisplus.mapper.LogicSqlInjector
#自定义填充策略接口实现
#meta-object-handler:com.baomidou.springboot.xxx
configuration:
map-underscore-to-camel-case:true
cache-enabled:false
#这个配置会将执行的sql打印出来，在开发或测试的时候可以用
log-impl:org.apache.ibatis.logging.stdout.StdOutImpl

3.原有的mapper接口增加继承BaseMapper接口
publicinterfaceUserMapperextendsBaseMapper

4.实体类增加注解
在User实体类上添加@TableId的注解用来标识实体类的主键，以便插件在生成主键雪花Id的时候找到哪个是主键。
@TableId
@JsonFormat(shape=JsonFormat.Shape.STRING)
privateLonguserId;
5.分页配置
5.1添加mybatis的一个配置类（不添加，则分页数据中的page参数会异常）
packagecom.nis.framework.config;

importcom.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
importorg.mybatis.spring.annotation.MapperScan;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.transaction.annotation.EnableTransactionManagement;

/**
*Mybatis-Plus插件配置类
*
*@authorlwj
*/
@EnableTransactionManagement
@Configuration
@MapperScan({"com.nis.project.*.mapper","com.nis.project.*.*.mapper"})
publicclassMybatisPlusConfig{

/**
*分页插件
*/
@Bean
publicPaginationInterceptorpaginationInterceptor(){
returnnewPaginationInterceptor();
}
}
5.2java代码示例
Controller类中添加page分页对象。
@GetMapping("/list")
@ResponseBody
publicMsglist(Useruser,HttpServletRequestrequest){
Mapparams=MapDataUtil.convertDataMap(request);
user.getParams().putAll(params);
Pagepage=startMybatisPlusPage(user);
IPageuserIPage=userService.selectUserList(page,user);
returnMsg.success(userIPage);
}

ServiceImpl中的具体方法
@Override
@DataScope(tableAlias="b")
publicIPageselectUserList(Pagepage,Useruser){
returnUserMapper.selectUserList(page,user);
}

mapper接口中的代码
IPageselectUserList(@Param("pg")Pagepage,@Param("ps")Useruser);

mybaits的xml文件中写的sql代码

select
a.user_id,
a.dept_id,
a.login_name,
a.user_name,
a.email,
a.phone_number,
a.sex,
a.avatar,
a.status,
a.login_ip,
a.login_date,
a.order_num,
b.dept_name
fromsys_usera
leftjoinsys_deptbonb.dept_id=a.dept_id
where1=1
anda.login_namelikeconcat('%',#{ps.loginName},'%')
anda.user_namelikeconcat('%',#{ps.userName},'%')
andb.dept_id=#{ps.deptId}
anda.email=#{ps.email}
anda.phone_numberlikeconcat('%',#{ps.phoneNumber},'%')
andfind_in_set(a.dept_id,#{ps.params.deptIds})
anda.status=#{ps.status}

${ps.params.dataScope}
orderbyb.ancestors,a.order_num


生成雪花ID以及解析雪花ID的机器ID和数据中心ID
1.生成雪花ID
这里不再阐述，直接贴上生成的一个雪花ID；1146667501642584065
2.解析雪花ID的机器ID和数据中心ID
SELECT(1146667501642584065>>12)&0x1fasworkerId,(1146667501642584065>>17)&0x1fasdatacenterId;

结果图：









到此这篇关于Mybatis-Plus雪花id的使用以及解析机器ID和数据标识ID实现的文章就介绍到这了,更多相关Mybatis-Plus雪花id内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

Mybatis-Plus雪花id的使用以及解析机器ID和数据标识ID实现

热门推荐

随机推荐