SpringBoot AOP Redis如何实现延时双删功能

在SpringBoot中，我们可以使用AOP（面向切面编程）和Redis来实现延时双删功能，具体步骤如下：

1、引入依赖

在项目的pom.xml文件中添加SpringBoot AOP和Redis相关依赖：

<dependencies>
    <!Spring Boot AOP >
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>springbootstarteraop</artifactId>
    </dependency>
    <!Redis >
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>springbootstarterdataredis</artifactId>
    </dependency>
</dependencies>

2、配置Redis

在application.properties文件中配置Redis连接信息：

spring.redis.host=localhost
spring.redis.port=6379

3、创建Redis工具类

创建一个Redis工具类，用于操作Redis：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
public class RedisUtil {
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    /**
     * 设置键值对并设置过期时间
     * @param key 键
     * @param value 值
     * @param time 过期时间（秒）
     * @return true表示设置成功，false表示设置失败
     */
    public boolean set(String key, String value, long time) {
        try {
            stringRedisTemplate.opsForValue().set(key, value);
            stringRedisTemplate.expire(key, time, TimeUnit.SECONDS);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }
}

4、创建AOP切面类

创建一个AOP切面类，用于处理延时双删逻辑：

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.concurrent.*;
@Aspect
@Component
public class DelayDoubleDeleteAspect {
    @Autowired
    private RedisUtil redisUtil;
    private static final ExecutorService executor = Executors.newSingleThreadExecutor(); // 单线程执行器，模拟延时任务队列
    private static final ConcurrentHashMap<String, Future<?>> futureMap = new ConcurrentHashMap<>(); // 存储延时任务的Future对象，用于取消任务和获取任务结果
    private static final int DELAY_TIME = 5000; // 延时时间（毫秒），根据实际需求调整
    private static final int RETRY_COUNT = 3; // 重试次数，根据实际需求调整
    private static final long RETRY_DELAY_TIME = 1000; // 重试间隔时间（毫秒），根据实际需求调整
    private static final long REMOVE_TIMEOUT = 10000; // 删除超时时间（毫秒），根据实际需求调整
    private static final String REMOVE_SUCCESS_KEY = "REMOVE_SUCCESS"; // 删除成功的标识键，可以根据实际需求修改
    private static final String REMOVE_FAILURE_KEY = "REMOVE_FAILURE"; // 删除失败的标识键，可以根据实际需求修改
    private static final String FAILURE_REASON_KEY = "FAILURE_REASON"; // 失败原因的标识键，可以根据实际需求修改
    private static final String FAILURE_COUNTER_KEY = "FAILURE_COUNTER"; // 失败次数的标识键，可以根据实际需求修改
    private static final String FAILURE_COUNTER_PREFIX = "FAILURE_COUNTER:"; // 失败次数前缀，可以根据实际需求修改
    private static final String FAILURE_REASONS = "FAILURE_REASONS"; // 失败原因列表的标识键，可以根据实际需求修改，可以是一个JSON字符串或者一个列表等数据结构来存储多个失败原因信息，如果使用JSON字符串，可以使用Jackson库来解析；如果使用列表，可以使用Java内置的List类型。