Aop注解+Redis解决SpringBoot接口幂等性(源码自取)

package com.example.redisidempotence.aspect; import com.example.redisidempotence.annotation.Idempotent; import com.example.redisidempotence.compent.RedisIdempotentStorage; import com.example.redisidempotence.vo.RequestData; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; import org.aspectj.lang.annotation.Aspect; import org.aspectj.lang.annotation.Pointcut; import org.aspectj.lang.reflect.MethodSignature; import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.lang.reflect.Method; import java.util.Map; @Aspect @Component public class IdempotentAspect { @Resource private RedisIdempotentStorage redisIdempotentStorage; @Pointcut("@annotation(com.example.redisidempotence.annotation.Idempotent)") public void idempotent() { } @Around("idempotent()") public Object methodAround(ProceedingJoinPoint joinPoint) throws Throwable { MethodSignature signature = (MethodSignature) joinPoint.getSignature(); Method method = signature.getMethod(); Idempotent idempotent = method.getAnnotation(Idempotent.class); String field = idempotent.field(); String name = idempotent.name(); Class clazzType = idempotent.type(); String token = ""; Object object = clazzType.newInstance(); Map<String, Object> paramValue = AopUtils.getParamValue(joinPoint); if (object instanceof RequestData) { RequestData idempotentEntity = (RequestData) paramValue.get(name); token = String.valueOf(AopUtils.getFieldValue(idempotentEntity.getHeader(), field)); } if (redisIdempotentStorage.delete(token)) { return joinPoint.proceed(); } if(token.isEmpty()){ return "token校验失败,token不可为空"; } return "不能重复请求"; } }