一、前言
最近测试提某些接口重复提交的问题，想了下应该不止是前端点击之后按钮不可点击的问题，后端应该根据登录token、操作方法、参数做多层的判断。
二、示例
切片代码
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 |
/** * 接口幂等切面 * @author Administrator */ @Slf4j @Aspect @Component public class ApiIdempotentAspect {
@Resource RedisUtil redisUtil; @Resource UserUtils userUtils;
@Pointcut ( "@annotation(com.xx.anno.ApiIdempotent)" ) private void pointCut() { }
@Before ( "pointCut()" ) public void doPoint(JoinPoint joinPoint) { String action = joinPoint.getSignature().getDeclaringTypeName() .substring(joinPoint.getSignature().getDeclaringTypeName().lastIndexOf( "." )+ 1 ) + "::" + joinPoint.getSignature().getName(); String args = JSON.toJSONString(joinPoint.getArgs()); String token = userUtils.getAuthToke().replace( "-" , "" ) .replace( "Bearer " , "" ); String idempotentKey = "api::idempotent::" +token+ "::" +action; //短时间内没进行相似操作 if (redisUtil.hasKey(idempotentKey)){ //接口参数是否一致 String idempotentValue = redisUtil.getCacheObject(idempotentKey); log.info( "idempotentValue : {}" ,idempotentValue); if (args.equals(idempotentValue)){ throw new BusinessException( "请勿重复操作" ); } } else { //30s内禁止重复操作 redisUtil.setCacheObject(idempotentKey,args, 30 , TimeUnit.SECONDS); }
}
} |
用到一个redisutil
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 |
@Component public class RedisUtil {
@Resource public RedisTemplate redisTemplate;
/** * 缓存基本的对象，Integer、String、实体类等 * * @param key 缓存的键值 * @param value 缓存的值 */ public <T> void setCacheObject( final String key, final T value) { redisTemplate.opsForValue().set(key, value); }
/** * 缓存基本的对象，Integer、String、实体类等 * * @param key 缓存的键值 * @param value 缓存的值 * @param timeout 时间 * @param timeUnit 时间颗粒度 */ public <T> void setCacheObject( final String key, final T value, final Integer timeout, final TimeUnit timeUnit) { redisTemplate.opsForValue().set(key, value, timeout, timeUnit); }
/** * 设置有效时间 * * @param key Redis键 * @param timeout 超时时间 * @return true=设置成功；false=设置失败 */ public boolean expire( final String key, final long timeout) { return expire(key, timeout, TimeUnit.SECONDS); }
/** * 设置有效时间 * * @param key Redis键 * @param timeout 超时时间 * @param unit 时间单位 * @return true=设置成功；false=设置失败 */ public boolean expire( final String key, final long timeout, final TimeUnit unit) { return redisTemplate.expire(key, timeout, unit); }
/** * 获得缓存的基本对象。 * * @param key 缓存键值 * @return 缓存键值对应的数据 */ public <T> T getCacheObject( final String key) { ValueOperations<String, T> operation = redisTemplate.opsForValue(); return operation.get(key); }
/** * 删除单个对象 * * @param key */ public boolean deleteObject( final String key) { return redisTemplate.delete(key); }
/** * 删除集合对象 * * @param collection 多个对象 * @return */ public long deleteObject( final Collection collection) { return redisTemplate.delete(collection); }
/** * 缓存List数据 * * @param key 缓存的键值 * @param dataList 待缓存的List数据 * @return 缓存的对象 */ public <T> long setCacheList( final String key, final List<T> dataList) { Long count = redisTemplate.opsForList().rightPushAll(key, dataList); return count == null ? 0 : count; }
/** * 获得缓存的list对象 * * @param key 缓存的键值 * @return 缓存键值对应的数据 */ public <T> List<T> getCacheList( final String key) { return redisTemplate.opsForList().range(key, 0 , - 1 ); }
/** * 缓存Set * * @param key 缓存键值 * @param dataSet 缓存的数据 * @return 缓存数据的对象 */ public <T> BoundSetOperations<String, T> setCacheSet( final String key, final Set<T> dataSet) { BoundSetOperations<String, T> setOperation = redisTemplate.boundSetOps(key); Iterator<T> it = dataSet.iterator(); while (it.hasNext()) { setOperation.add(it.next()); } return setOperation; }
/** * 获得缓存的set * * @param key * @return */ public <T> Set<T> getCacheSet( final String key) { return redisTemplate.opsForSet().members(key); }
/** * 缓存Map * * @param key * @param dataMap */ public <T> void setCacheMap( final String key, final Map<String, T> dataMap) { if (dataMap != null ) { redisTemplate.opsForHash().putAll(key, dataMap); } }
/** * 获得缓存的Map * * @param key * @return */ public <T> Map<String, T> getCacheMap( final String key) { return redisTemplate.opsForHash().entries(key); }
/** * 往Hash中存入数据 * * @param key Redis键 * @param hKey Hash键 * @param value 值 */ public <T> void setCacheMapValue( final String key, final String hKey, final T value) { redisTemplate.opsForHash().put(key, hKey, value); }
/** * 获取Hash中的数据 * * @param key Redis键 * @param hKey Hash键 * @return Hash中的对象 */ public <T> T getCacheMapValue( final String key, final String hKey) { HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash(); return opsForHash.get(key, hKey); }
/** * 获取多个Hash中的数据 * * @param key Redis键 * @param hKeys Hash键集合 * @return Hash对象集合 */ public <T> List<T> getMultiCacheMapValue( final String key, final Collection<Object> hKeys) { return redisTemplate.opsForHash().multiGet(key, hKeys); }
/** * 获得缓存的基本对象列表 * * @param pattern 字符串前缀 * @return 对象列表 */ public Collection<String> keys( final String pattern) { return redisTemplate.keys(pattern); }
/** * 判断key是否还在 * @param key * @return */ public boolean hasKey( final String key){ return redisTemplate.hasKey(key); } } |
到此这篇关于springboot幂等切片的实现的文章就介绍到这了,更多相关springboot幂等切片内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
原文链接：https://www.jianshu.com/p/4dd22cc109eb
查看更多关于springboot幂等切片的实现的详细内容...