产品需求:要求定时扫描超过10天,对抓中奖品进行处理的游戏记录,系统自动转换成娃娃币,同时在消费明细和消息中心提醒用户。
由于服务都是集群部署,定时任务会在各个服务器上重复执行,轻则浪费服务器资源,重则造成数据紊乱。
quartz定时任务提供了集群方式,但还需为其创建数据库表。spring schedule可以实现简单轻量级的定时任务,但无法保证只执行一次。
通过和架构师探讨得知,可以使用redis的分布式锁保证spring schedule集群只执行一次。
redis分布式锁是通过setnx命令实现的。该命令的作用是,当往redis中存入一个值时,会先判断该值对应的key是否存在,如果存在则返回0,如果不存在,则将该值存入redis并返回1。根据这个特性,我们在程序中,每次都调用setIfAbsent(该方法是setnx命令的实现)方法,来模拟是否获取到锁,如果返回true,则说明该key值不存在,表示获取到锁;如果返回false,则说明该key值存在,已经有程序在使用这个key值了,从而实现了类似加锁的功能。
logger
redisTemplate
LOCK
KEY
cron
lock
lock redisTemplateKEY LOCK
logger lock
lock
historyList historyService
history historyList
history
logger
lock
redisTemplateKEY
logger
logger
还没有评论,来说两句吧...