admin管理员组

文章数量:1130349

产品需求：

对接腾讯云实时音视频，实时拉取腾讯云最新的视频并使用Ffmpeg视频合成。

遇到问题：

由于服务都是集群部署，定时任务会在各个服务器上重复执行，轻则浪费服务器资源，重则造成数据紊乱。

解决方案：

quartz定时任务提供了集群方式，但还需为其创建数据库表。spring schedule可以实现简单轻量级的定时任务，但无法保证只执行一次。
通过和架构师探讨得知，可以使用redis的分布式锁保证spring schedule集群只执行一次。
redis分布式锁是通过setnx命令实现的。该命令的作用是，当往redis中存入一个值时，会先判断该值对应的key是否存在，如果存在则返回0，如果不存在，则将该值存入redis并返回1。根据这个特性，我们在程序中，每次都调用setIfAbsent(该方法是setnx命令的实现)方法，来模拟是否获取到锁，如果返回true，则说明该key值不存在，表示获取到锁；如果返回false，则说明该key值存在，已经有程序在使用这个key值了，从而实现了类似加锁的功能。

@Component
@Configuration
@EnableScheduling
public class AutoConvertTask {
   
   
    private static final Logger logger = LoggerFactory.getLogger(AutoConver

产品需求：

对接腾讯云实时音视频，实时拉取腾讯云最新的视频并使用Ffmpeg视频合成。

遇到问题：

由于服务都是集群部署，定时任务会在各个服务器上重复执行，轻则浪费服务器资源，重则造成数据紊乱。

解决方案：

quartz定时任务提供了集群方式，但还需为其创建数据库表。spring schedule可以实现简单轻量级的定时任务，但无法保证只执行一次。
通过和架构师探讨得知，可以使用redis的分布式锁保证spring schedule集群只执行一次。
redis分布式锁是通过setnx命令实现的。该命令的作用是，当往redis中存入一个值时，会先判断该值对应的key是否存在，如果存在则返回0，如果不存在，则将该值存入redis并返回1。根据这个特性，我们在程序中，每次都调用setIfAbsent(该方法是setnx命令的实现)方法，来模拟是否获取到锁，如果返回true，则说明该key值不存在，表示获取到锁；如果返回false，则说明该key值存在，已经有程序在使用这个key值了，从而实现了类似加锁的功能。

@Component
@Configuration
@EnableScheduling
public class AutoConvertTask {
   
   
    private static final Logger logger = LoggerFactory.getLogger(AutoConver

本文标签： 分布式集群redisscheduleSpring

版权声明：本文标题：使用redis分布式锁解决spring schedule集群部署重复执行问题 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://it.en369.cn/jiaocheng/1755004435a2752384.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。