当前位置: 首页 > article >正文

springboot多实例部署时,@Scheduled注释的方法重复执行

问题:springboot多实例部署时,@Scheduled注释的方法重复执行

在 Spring Boot 中要实现 Redis 的SET NX EX命令,可以借助 Spring Data Redis 来完成。SET NX EX命令用于在键不存在时设置键值对,并同时设置过期时间。

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
</dependencies>

当spring-boot-starter-data-redis依赖版本比较旧时,可以使用使用 Lua 脚本实现 SET NX EX,前提是不使用redis集群。
org.springframework.dao.InvalidDataAccessApiUsageException: EvalSha is not supported in cluster environment 异常时,这是因为在 Redis 集群环境下,EvalSha 命令存在一定限制,Spring Data Redis 在执行 Lua 脚本
时默认可能会尝试使用 EvalSha 命令,而该命令在集群环境中并不总是被支持。
或者分两步操作
先使用 SETNX 尝试设置键值对,若设置成功再使用 EXPIRE 设置过期时间。但这种方式不是原子操作,在 SETNX 和 EXPIRE 之间可能会出现异常,导致锁没有设置过期时间,造成死锁。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

@Service
public class RedisLockServiceV2 {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    public boolean setNXEX(String key, String value, long timeout, TimeUnit timeUnit) {
        Boolean setResult = redisTemplate.opsForValue().setIfAbsent(key, value);
        if (setResult != null && setResult) {
            redisTemplate.expire(key, timeout, timeUnit);
            return true;
        }
        return false;
    }
}

http://www.kler.cn/a/558217.html

相关文章:

  • 使用FFmpeg将PCMA格式的WAV文件转换为16K采样率的PCM WAV文件
  • Mybatis MyBatis框架的缓存 一级缓存
  • Spring使用三级缓存解决循环依赖的源码分析。
  • AI IDE - Trae -学习与实践
  • git使用-克隆远程项目、分支管理
  • 浅谈小程序内嵌h5分享
  • 【Mysql:数据库的基础操作】
  • Redis 缓存穿透、击穿、雪崩:问题与解决方案
  • 大语言模型:如何用AI快速定制技能,挖掘海量数据的“宝藏”?
  • MySQL存储引擎:选择与应用
  • 计算机毕业设计SpringBoot+Vue.js学生读书笔记共享(源码+LW文档+PPT+讲解+开题报告)
  • 食物照片识别卡路里(深度学习)
  • Java 中的 List 和 Map:全面解析与实际应用
  • 在 .NET 8/9 中使用 AppUser 进行 JWT 令牌身份验证
  • 加班限制了进步
  • 虚拟机从零实现机器人控制
  • Docker构建时,设定默认进入的工作目录的方法
  • QT之改变鼠标样式
  • 数据库管理-第295期 IT架构与爆炸半径(20250221)
  • 使用MyBatis映射器实现对数据库的增删改查操作