请选择 进入手机版 | 继续访问电脑版

湖南新梦想

 找回密码
 立即注册
搜索
热搜: 活动 交友 discuz
查看: 374|回复: 0

瞬间几千次的重复提交,我用SpringBoot+Redis扛住了!(上)

[复制链接]

1917

主题

2295

帖子

8233

积分

论坛元老

Rank: 8Rank: 8

积分
8233
发表于 2021-1-6 17:07:47 | 显示全部楼层 |阅读模式
前言
在实际的开发项目中,一个对外暴露的接口往往会面临很多次请求,我们来解释一下幂等的概念:任意多次执行所产生的影响均与一次执行的影响相同。按照这个含义,最终的含义就是 对[url=]数据库[/url]的影响只能是一次性的,不能重复处理。如何保证其幂等性,通常有以下手段:
数据库建立唯一性索引,可以保证最终插入数据库的只有一条数据
token机制,每次接口请求前先获取一个token,然后再下次请求的时候在请求的header体中加上这个token,后台进行验证,如果验证通过删除token,下次请求再次判断token
悲观锁或者乐观锁,悲观锁可以保证每次for update的时候其他sql无法update数据(在数据库引擎是innodb的时候,select的条件必须是唯一索引,防止锁全表)
先查询后判断,首先通过查询数据库是否存在数据,如果存在证明已经请求过了,直接拒绝该请求,如果没有存在,就证明是第一次进来,直接放行。
搭建redis的服务Api
首先是搭建redis服务器。
引入springboot中到的redis的stater,或者Spring封装的jedis也可以,后面主要用到的api就是它的set方法和exists方法,这里我们使用springboot的封装好的redisTemplate


   /**
  * redis工具类
  */
  @Component
  public class RedisService {
  @Autowired
  private RedisTemplate redisTemplate;
  /**
  * 写入缓存
  * @param key
  * @param value
  * @return
  */
  public boolean set(final String key, Object value) {
  boolean result = false;
  try {
  ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
  operations.set(key, value);
  result = true;
  } catch (Exception e) {
  e.printStackTrace();
  }
  return result;
  }
  /**
  * 写入缓存设置时效时间
  * @param key
  * @param value
  * @return
  */
  public boolean setEx(final String key, Object value, Long expireTime) {
  boolean result = false;
  try {
  ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
  operations.set(key, value);
  redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);
  result = true;
  } catch (Exception e) {
  e.printStackTrace();
  }
  return result;
  }
  /**
  * 判断缓存中是否有对应的value
  * @param key
  * @return
  */
  public boolean exists(final String key) {
  return redisTemplate.hasKey(key);
  }
  /**
  * 读取缓存
  * @param key
  * @return
  */
  public Object get(final String key) {
  Object result = null;
  ValueOperations<Serializable, Object> operations = redisTemplate.opsForValue();
  result = operations.get(key);
  return result;
  }
  /**
  * 删除对应的value
  * @param key
  */
  public boolean remove(final String key) {
  if (exists(key)) {
  Boolean delete = redisTemplate.delete(key);
  return delete;
  }
  return false;
  }
  }


自定义注解AutoIdempotent
自定义一个注解,定义此注解的主要目的是把它添加在需要实现幂等的方法上,凡是某个方法注解了它,都会实现自动幂等。后台利用反射如果扫描到这个注解,就会处理这个方法实现自动幂等,使用元注解ElementType.METHOD表示它只能放在方法上,etentionPolicy.RUNTIME表示它在运行时


   @Target({ElementType.METHOD})
  @Retention(RetentionPolicy.RUNTIME)
  public @interface AutoIdempotent {
  }


token创建和检验
token服务接口:我们新建一个接口,创建token服务,里面主要是两个方法,一个用来创建token,一个用来验证token。创建token主要产生的是一个字符串,检验token的话主要是传达request对象,为什么要传request对象呢?主要作用就是获取header里面的token,然后检验,通过抛出的Exception来获取具体的报错信息返回给前端


   public interface TokenService {
  /**
  * 创建token
  * @return
  */
  public  String createToken();
  /**
  * 检验token
  * @param request
  * @return
  */
  public boolean checkToken(HttpServletRequest request) throws Exception;
  }



回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|Archiver|手机版|小黑屋|湖南新梦想 ( 湘ICP备18019834号-2 )

GMT+8, 2022-1-20 14:32 , Processed in 0.041063 second(s), 20 queries .

Powered by Discuz! X3.4 Licensed

Copyright © 2001-2020, Tencent Cloud.

快速回复 返回顶部 返回列表