扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 数据库 >详解如何利用Redis实现生成唯一ID
  • 452

0
分享到

详解如何利用Redis实现生成唯一ID

Redis生成唯一IDRedis 唯一ID 2022-11-19 06:11:33 452人浏览 安东尼
摘要

目录一、摘要二、方案实践2.1、引入 Redis 组件2.2、添加 redis 环境配置2.3、编写服务验证逻辑，通过 aop 代理方式实现2.4、在相关的业务接口上，增加SubmitLimit注解即可三、小结一、摘要

一、摘要

在上一篇文章中，我们详细的介绍了随着下单流量逐渐上升，为了降低数据库的访问压力，通过请求唯一ID+redis分布式锁来防止接口重复提交，流程图如下！

详解如何利用Redis实现生成唯一ID

每次提交的时候，需要先调用后端服务获取请求唯一ID，然后才能提交。

对于这样的流程，不少的同学可能会感觉到非常鸡肋，尤其是单元测试，需要每次先获取submitToken值，然后才能提交！

能不能不用这么麻烦，直接服务端通过一些规则组合，生成本次请求唯一ID呢？

答案是可以的！

今天我们就一起来看看，如何通过服务端来完成请求唯一 ID 的生成？

二、方案实践

我们先来看一张图，这张图就是本次方案的核心流程图。

详解如何利用Redis实现生成唯一ID

实现的逻辑，流程如下：

  • 1.用户点击提交按钮，服务端接受到请求后，通过规则计算出本次请求唯一ID值
  • 2.使用redis的分布式锁服务，对请求 ID 在限定的时间内尝试进行加锁，如果加锁成功，继续后续流程；如果加锁失败，说明服务正在处理，请勿重复提交
  • 3.最后一步，如果加锁成功后，需要将锁手动释放掉，以免再次请求时，提示同样的信息

引入缓存服务后，防止重复提交的大体思路如上，实践代码如下！

2.1、引入 redis 组件

本次 demo 项目是基于SpringBoot版本进行构建，添加相关的redis依赖环境如下：

<!--引入springboot-->
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.0.RELEASE</version>
</parent>

......

<!--Redis相关依赖包，采用jedis作为客户端-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<exclusions>
<exclusion>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</exclusion>
<exclusion>
<artifactId>lettuce-core</artifactId>
<groupId>io.lettuce</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

2.2、添加 redis 环境配置

在全局配置application.properties文件中，添加redis相关服务配置如下

#项目名
spring.application.name=springboot-example-submit

#Redis数据库索引（默认为0）
spring.redis.database=1
#Redis服务器地址
spring.redis.host=127.0.0.1
#Redis服务器连接端口
spring.redis.port=6379
#Redis服务器连接密码（默认为空）
spring.redis.passWord=
#Redis服务器连接超时配置
spring.redis.timeout=1000

#连接池配置
spring.redis.jedis.pool.max-active=8
spring.redis.jedis.pool.max-wait=1000
spring.redis.jedis.pool.max-idle=8
spring.redis.jedis.pool.min-idle=0
spring.redis.jedis.pool.time-between-eviction-runs=100

2.3、编写服务验证逻辑，通过 aop 代理方式实现

首先创建一个@SubmitLimit注解，通过这个注解来进行方法代理拦截！

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public@interfaceSubmitLimit{


intwaitTime()default1000;


String[]customerHeaders()default{};



StrinGCustomerTipMsg()default"";
}

编写方法代理服务，增加防止重复提交的验证，实现了逻辑如下！

@Order(1)
@ASPect
@Component
publicclassSubmitLimitAspect{

privatestaticfinalLoggerLOGGER=LoggerFactory.getLogger(SubmitLimitAspect.class);


privatestaticfinalStringREDIS_SEPARATOR=":";


privatestaticfinalStringDEFAULT_LOCK_VALUE="DEFAULT_SUBMIT_LOCK_VALUE";


privatestaticfinalStringDEFAULT_TIP_MSG="服务正在处理，请勿重复提交！";


@Value("${spring.application.name}")
privateStringapplicationName;

@Autowired
privateRedisLockServiceredisLockService;



@Around(value="@annotation(com.example.submittoken.config.annotation.SubmitLimit)")
publicObjectdoAround(ProceedingJoinPointjoinPoint){
httpservletRequestrequest=getHttpServletRequest();
if(Objects.isNull(request)){
returnResResult.getSysError("请求参数不能为空！");
}
//获取注解配置的参数
SubmitLimitsubmitLimit=getSubmitLimit(joinPoint);
//组合生成key，通过key实现加锁和解锁
StringlockKey=buildSubmitLimiTKEy(joinPoint,request,submitLimit.customerHeaders());
//尝试在指定的时间内加锁
booleanlock=redisLockService.tryLock(lockKey,DEFAULT_LOCK_VALUE,Duration.ofMillis(submitLimit.waitTime()));
if(!lock){
StringtipMsg=StringUtils.isEmpty(submitLimit.customerTipMsg())?DEFAULT_TIP_MSG:submitLimit.customerTipMsg();
returnResResult.getSysError(tipMsg);
}
try{
//继续执行后续流程
returnexecute(joinPoint);
}finally{
//执行完毕之后，手动将锁释放
redisLockService.releaseLock(lockKey,DEFAULT_LOCK_VALUE);
}
}


privateObjectexecute(ProceedingJoinPointjoinPoint){
try{
returnjoinPoint.proceed();
}catch(CommonExceptione){
returnResResult.getSysError(e.getMessage());
}catch(Throwablee){
LOGGER.error("业务处理发生异常，错误信息：",e);
returnResResult.getSysError(ResResultEnum.DEFAULT_ERROR_MESSAGE);
}
}



privateHttpServletRequestgetHttpServletRequest(){
RequestAttributesra=RequestContextHolder.getRequestAttributes();
ServletRequestAttributessra=(ServletRequestAttributes)ra;
HttpServletRequestrequest=sra.getRequest();
returnrequest;
}


privateSubmitLimitgetSubmitLimit(JoinPointjoinPoint){
MethodSignaturemethodSignature=(MethodSignature)joinPoint.getSignature();
Methodmethod=methodSignature.getMethod();
SubmitLimitsubmitLimit=method.getAnnotation(SubmitLimit.class);
returnsubmitLimit;
}


privateStringbuildSubmitLimitKey(JoinPointjoinPoint,HttpServletRequestrequest,String[]customerHeaders){
//请求参数=请求头部+请求body
StringrequestHeader=getRequestHeader(request,customerHeaders);
StringrequestBody=getRequestBody(joinPoint.getArgs());
StringrequestParamSign=DigestUtils.sha1Hex(requestHeader+requestBody);
StringsubmitLimitKey=newStringBuilder()
.append(applicationName)
.append(REDIS_SEPARATOR)
.append(joinPoint.getSignature().getDeclaringType().getSimpleName())
.append(REDIS_SEPARATOR)
.append(joinPoint.getSignature().getName())
.append(REDIS_SEPARATOR)
.append(requestParamSign)
.toString();
returnsubmitLimitKey;
}



privateStringgetRequestHeader(HttpServletRequestrequest,String[]customerHeaders){
if(Objects.isNull(customerHeaders)){
return"";
}
StringBuildersb=newStringBuilder();
for(StringheaderKey:customerHeaders){
sb.append(request.getHeader(headerKey));
}
returnsb.toString();
}



privateStringgetRequestBody(Object[]args){
if(Objects.isNull(args)){
return"";
}
StringBuildersb=newStringBuilder();
for(Objectarg:args){
if(arginstanceofHttpServletRequest
||arginstanceofHttpServletResponse
||arginstanceofMultipartFile
||arginstanceofBindResult
||arginstanceofMultipartFile[]
||arginstanceofModelMap
||arginstanceofModel
||arginstanceofExtendedServletRequestDataBinder
||arginstanceofbyte[]){
continue;
}
sb.append(JacksonUtils.toJSON(arg));
}
returnsb.toString();
}
}

部分校验逻辑用到了redis分布式锁，具体实现逻辑如下：


@Component
publicclassRedisLockService{


privatestaticfinalLongDEFAULT_LOCK_EXPIRE_TIME=60L;

@Autowired
privateStringRedisTemplatestringRedisTemplate;


publicbooleantryLock(Stringkey,Stringvalue,Durationtimeout){
longwaitMills=timeout.toMillis();
longcurrentTimeMillis=System.currentTimeMillis();
do{
booleanlock=lock(key,value,DEFAULT_LOCK_EXPIRE_TIME);
if(lock){
returntrue;
}
try{
Thread.sleep(1L);
}catch(InterruptedExceptione){
Thread.interrupted();
}
}while(System.currentTimeMillis()<currentTimeMillis+waitMills);
returnfalse;
}


publicbooleanlock(Stringkey,Stringvalue,Longexpire){
StringluaScript="ifredis.call('setnx',KEYS[1],ARGV[1])==1thenreturnredis.call('expire',KEYS[1],ARGV[2])elsereturn0end";
RedisScript<Long>redisScript=newDefaultRedisScript<>(luaScript,Long.class);
Longresult=stringRedisTemplate.execute(redisScript,Collections.singletonList(key),value,String.valueOf(expire));
returnresult.equals(Long.valueOf(1));
}



publicbooleanreleaseLock(Stringkey,Stringvalue){
StringluaScript="ifredis.call('get',KEYS[1])==ARGV[1]thenreturnredis.call('del',KEYS[1])elsereturn0end";
RedisScript<Long>redisScript=newDefaultRedisScript<>(luaScript,Long.class);
Longresult=stringRedisTemplate.execute(redisScript,Collections.singletonList(key),value);
returnresult.equals(Long.valueOf(1));
}
}

部分代码使用到了序列化相关类JacksonUtils，源码如下：

publicclassJacksonUtils{

privatestaticfinalLoggerLOGGER=LoggerFactory.getLogger(JacksonUtils.class);


privatestaticfinalObjectMapperobjectMapper=newObjectMapper();

static{
//对象的所有字段全部列入
objectMapper.setSerializationInclusion(jsonInclude.Include.ALWAYS);
//忽略未知的字段
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES,false);
//读取不认识的枚举时，当null值处理
objectMapper.configure(DeserializationFeature.READ_UNKNOWN_ENUM_VALUES_AS_NULL,true);
//序列化忽略未知属性
objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS,false);
//忽略字段大小写
objectMapper.configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES,true);

objectMapper.configure(JsonParser.Feature.AUTO_CLOSE_SOURCE,true);
SimpleModulemodule=newSimpleModule();
module.addSerializer(Long.class,ToStringSerializer.instance);
module.addSerializer(Long.TYPE,ToStringSerializer.instance);
objectMapper.reGISterModule(module);
}

publicstaticStringtoJson(Objectobject){
if(object==null){
returnnull;
}
try{
returnobjectMapper.writeValueAsString(object);
}catch(Exceptione){
LOGGER.error("序列化失败",e);
}
returnnull;
}

publicstatic<T>TfromJson(Stringjson,Class<T>classOfT){
if(json==null){
returnnull;
}
try{
returnobjectMapper.readValue(json,classOfT);
}catch(Exceptione){
LOGGER.error("反序列化失败",e);
}
returnnull;
}

publicstatic<T>TfromJson(Stringjson,TypetypeOfT){
if(json==null){
returnnull;
}
try{
returnobjectMapper.readValue(json,objectMapper.constructType(typeOfT));
}catch(Exceptione){
LOGGER.error("反序列化失败",e);
}
returnnull;
}
}

2.4、在相关的业务接口上，增加SubmitLimit注解即可

@RestController
@RequestMapping("order")
publicclassOrderController{

@Autowired
privateOrderServiceorderService;


@SubmitLimit(customerHeaders={"appId","token"},customerTipMsg="正在加紧为您处理，请勿重复下单！")
@PostMapping(value="confirm")
publicResResultconfirmOrder(@RequestBodyOrderConfirmRequestrequest){
//调用订单下单相关逻辑
orderService.confirm(request);
returnResResult.getSuccess();
}
}

其中最关键的一个步就是将唯一请求 ID  的生成，放在服务端通过组合来实现，在保证防止接口重复提交的效果同时，也可以显著的降低接口测试复杂度！

三、小结

本次方案相比于上一个方案，最大的改进点在于：将接口请求唯一 ID 的生成逻辑，放在服务端通过规则组合来实现，不需要前端提交接口的时候强制带上这个参数，在满足防止接口重复提交的要求同时，又能减少前端和测试提交接口的复杂度！

需要特别注意的是：使用redis的分布式锁，推荐单机环境，如果redis是集群环境，可能会导致锁短暂无效！

到此这篇关于详解如何利用Redis实现生成唯一ID的文章就介绍到这了,更多相关Redis生成唯一ID内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

您可能感兴趣的文档:

--结束END--

本文标题: 详解如何利用Redis实现生成唯一ID

本文链接: https://lsjlt.com/news/173115.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • 详解如何利用Redis实现生成唯一ID
    目录一、摘要二、方案实践2.1、引入 Redis 组件2.2、添加 redis 环境配置2.3、编写服务验证逻辑，通过 aop 代理方式实现2.4、在相关的业务接口上，增加SubmitLimit注解即可三、小结一、摘要 ...
    99+
    2022-11-19
    Redis生成唯一ID Redis 唯一ID
  • Redis唯一ID生成器如何实现
    这篇“Redis唯一ID生成器如何实现”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“Redis唯一ID生成器如何实现”文章吧...
    99+
    2023-07-02
  • Redis唯一ID生成器的实现
    ID的组成部分： 符号位：1bit，永远为0时间戳：31bit，以秒为单位，可以使用69年序列号：32bit，秒内的计数器，支持每秒产生2^32个不同ID 生成代码： public class RedisIdWorker...
    99+
    2022-07-05
    Redis唯一ID生成器 Redis生成唯一ID
  • Redis生成全局唯一ID的实现方法
    目录简介:特性：生成规则： ID生成类：测试类：简介: 全局唯一ID生成器是一种在分布式系统下用来生成全局唯一ID的工具 特性： 唯一性高性能安全性高可用递增性 生成规则：...
    99+
    2024-04-02
  • 如何在php中生成唯一ID
    这篇文章将为大家详细讲解有关如何在php中生成唯一ID，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。php有什么用php是一个嵌套的缩写名称，是英文超级文本预处理语言，它的语法混合了C、Ja...
    99+
    2023-06-14
  • Redis生成分布式系统全局唯一ID的实现
    目录分布式系统全局唯一ID基于Redis INCR 命令生成分布式全局唯一ID采用Redis生成商品全局唯一ID分布式系统全局唯一ID 在互联网系统中，并发越大的系统，数据就越大，数...
    99+
    2024-04-02
  • PHP利用雪花(SnowFlake)算法生成唯一ID
    目录一、雪花算法原理解析1. 分布式ID常见生成策略2. 雪花算法的结构二、PHP源码实现案例1.demo12.demo2这个算法的好处很简单可以在每秒产生约400W个不同的16位数...
    99+
    2024-04-02
  • springboot集成redis并使用redis生成全局唯一索引ID
    部署redis Windows下搭建Reids本地集群，可参考https://www.jb51.net/article/242520.htm springboot集成 redis p...
    99+
    2024-04-02
  • PHP怎么利用雪花算法生成唯一ID
    这篇文章主要讲解了“PHP怎么利用雪花算法生成唯一ID”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“PHP怎么利用雪花算法生成唯一ID”吧！一、雪花算法原理解析1. 分布式ID常见生成策略分...
    99+
    2023-06-30
  • redis如何生成唯一订单号
    在Redis中生成唯一订单号可以使用Redis的自增命令INCR来实现。 具体的步骤如下： 在Redis中设置一个自增的键，作为订...
    99+
    2023-10-24
    redis
  • java如何使用预分配法生成唯一ID
    小编给大家分享一下java如何使用预分配法生成唯一ID，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！在项目中经常有生成唯一ID的业务需求。作为唯一标识方便后续查找...
    99+
    2023-06-05
  • 利用Redis实现分布式全局ID生成
    利用Redis实现分布式全局ID生成随着互联网的发展，分布式系统的应用场景越来越多，如何生成全局唯一的ID成为了一个非常重要的问题。传统的自增ID，由于单点数据源的限制，无法满足分布式系统的需要。利用Redis作为分布式系统的全局ID生成器...
    99+
    2023-11-08
    分布式 redis ID生成
  • Redis全局ID生成器如何实现
    今天小编给大家分享一下Redis全局ID生成器如何实现的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。全局ID生成器，是一种在...
    99+
    2023-06-30
  • 使用redis生成唯一编号及原理示例详解
    在系统开发中，保证数据的唯一性是至关重要的一件事，目前开发中常用的方式有使用数据库的自增序列、UUID生成唯一编号、时间戳或者时间戳+随机数等。 在某些特定业务场景中，可能会要求我们...
    99+
    2024-04-02
  • 利用Java.util.UUID来生成唯一ID(用来做数据库主键好用)
    UUID(Universally Unique Identifier)全局唯一标识符,是指在一台机器上生成的数字，它保证对在同一时空中的所有机器都是唯一的。按照开放软件基金会(OSF)制...
    99+
    2024-04-02
  • Go实现分布式唯一ID的生成之雪花算法
    目录背景：特性:雪花算法:分布式唯一ID的生成 背景： 在分布式架构下,唯一序列号生成是我们在设计一个尤其是数据库使用分库分表的时候会常见的一个问题 特性: 全局唯一,这是基本要求,...
    99+
    2024-04-02
  • 利用java如何实现一个验证码生成功能
    利用java如何实现一个验证码生成功能？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。1、serialVersionUID    private...
    99+
    2023-05-31
    java 验证码 ava
  • 如何利用Javascript生成平滑曲线详解
    目录前言贝塞尔曲线简介二次贝塞尔曲线三次贝塞尔曲线贝塞尔曲线计算函数拟合算法附录：Vector2D相关的代码总结前言 平滑曲线生成是一个很实用的技术 很多时候，我们都需要通过绘制一...
    99+
    2024-04-02
  • 如何利用java实现生成PDF文件
    目录1.PDF文件简介2.生成PDF2.1 基于freemarker框架实现HTML转PDF2.1.1 引入jar包依赖:2.1.2 创建html模板test_template：2....
    99+
    2022-11-13
    java生成pdf文档 java生成pdf文件表格 java生成pdf
  • 基于雪花算法实现增强版ID生成器详解
    目录基于雪花算法的增强版ID生成器快速开始配置解析目前提供两个配置类详情生产推荐使用方式JMH 性能测试测试机硬件情况Sequence 配置参数JMH参数测试结果Tip基于雪花算法的...
    99+
    2022-11-13
    雪花算法实现ID生成器 雪花算法 ID生成
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作