mysql和redis数据一致性

sequenceDiagram
participant A as 线程A（执行双删）
participant B as 线程B/C（读请求）
participant Cache
participant DB

    A->>DB: 1. 更新数据库
    A->>Cache: 2. 删除缓存
    activate B
    B->>Cache: 3. 读缓存（未命中）
    B->>DB: 4. 查询新数据
    DB-->>B: 返回新数据
    B->>Cache: 5. 写入新数据到缓存
    deactivate B
    A-->>A: 等待延迟时间（例如1秒）
    A->>Cache: 6. 再次删除缓存
    Note over A,Cache: 极端情况：若缓存过期，线程C可能写入旧数据，但会被二次删除覆盖

@Data
@Entity
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String name;
    private String email;
}

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // 获取用户信息（含缓存逻辑）
    public User getUser(Long userId) {
        String cacheKey = "user:" + userId;
        User user = (User) redisTemplate.opsForValue().get(cacheKey);
        if (user == null) {
            user = userRepository.findById(userId).orElse(null);
            if (user != null) {
                redisTemplate.opsForValue().set(cacheKey, user, 30, TimeUnit.MINUTES);
            }
        }
        return user;
    }

    // 更新用户信息（延时双删实现）
    @Transactional
    public void updateUser(User user) {
        Long userId = user.getId();
        String cacheKey = "user:" + userId;
        
        // 1. 标记缓存失效（设置5秒过期时间）
        redisTemplate.opsForValue().set(cacheKey, null, 5, TimeUnit.SECONDS);
        
        // 2. 更新数据库
        userRepository.save(user);
        
        // 3. 延时删除缓存（利用Redis过期机制）第1步骤已经实现
    }
}

redisTemplate.opsForValue().set(cacheKey, null, 5, TimeUnit.SECONDS);

userRepository.save(user);