Java通过redis管理你的集群定时任务

前言

早在实习的时候,笔者就接触了spring-task和quartz框架,相信任何java程序员都会有定时任务的需求,在单机上使用定时任务是非常简单的,但是在集群环境中就显得比较棘手:

  • 如何限定只有一台机器在执行定时任务
  • 某台服务宕机以后如何进行故障转移
  • 如何确定正在执行的是哪一台服务

此问题官方肯定有解决方案,资料也不少:quartz集群分布式(并发)部署解决方案-Spring
不过笔者是个比较懒的人,上述的解决方案需要配置不少的quartz表,并且业务里不需要动态配置定时任务,对quartz框架并无依赖,所以就考虑使用其他方式来实现定时任务的分布式调度。

初尝试Uncode-Schedule

Uncode-Schedule 是笔者在开源中国中看到的一个开源的分布式调度任务组件,与spring集成比较容易,使用方便,借助了zookeeper。在此我不多做评价,毕竟是个人的一个开源框架,使用过程中还是踩了一些坑,并且文档尚未齐全,用了一段时间后决定弃用了。有兴趣的同学可以了解下:分布式任务调度组件 Uncode-Schedule
所幸在填坑过程中对这个任务调度的过程有了一定了解,于是决定自己实现一个简单的任务调度器。

通过redis实现任务调度思路

实现功能之前,回顾下之前遇到的三个问题:单点执行,故障转移,服务状态。结合着redis的一些接口特性,解决思路如下:

  1. 使用redis作为任务调度中心,采用了redis的自动过期与分布式锁特性
  2. 每个服务的ip加项目名作为每台服务的唯一别名
  3. 通过redis中对应key值中的value来判定执行的是哪台服务: 如redis中key为 schedular_root:projectA, value为192.168.1.187. 意为项目projectA当前执行任务的节点为192.168.1.187这台机器上的服务
  4. 每次执行任务之前判定下redis中schedular_root:projectA是否为空,如果为空,则设置当前ip进去,设置一定时间的有效期,并执行定时任务;如果不为空,判断是否与本机ip相同,相同则执行定时任务,否则跳过
  5. 设置有效期是为了某台机器发生故障时能进行故障转移

核心流程代码

此解决方案非常简单,核心代码也十分容易集成,为了减少耦合度,我们采用了spring的aop进行实现。

核心AOP代码

@Aspect
@Component
@Log4j
public class QuartzAop {
    
    public boolean checkStatus(){
        String key = "schedular_root:projectA";
        try {
            // 这个接口必然是并发的,所以加分布式锁
            while (true) {
                // 一秒的超时时间
                boolean lock = RedisUtil.checkLock(key,1);
                if (lock) {
                    // 获取到锁,才能跳出
                    break;
                }
            }
            String ip = InetAddress.getLocalHost().getHostAddress();
            // 获取服务器上的工作ip
            String currentIp = RedisUtil.get(key);
            // 如果为空的时候,设置进去
            if(currentIp == null){
                RedisUtil.setex(key, ip, 10);
                return true;
            }
            // 就是当前机器,则返回true
            if(currentIp.equals(ip)){
                return true;
            }else{
                return false;
            }
        } catch (Exception e) {
            log.error(e);
            return false;
        } finally {
            RedisUtil.unLock(key);
        }
    }
    
    @Around("@annotation(org.springframework.scheduling.annotation.Scheduled)")
    public void around(ProceedingJoinPoint jp) throws Throwable{
        if(checkStatus()){
            String ip = InetAddress.getLocalHost().getHostAddress();
            log.info("现在正在执行"+jp.getSignature()+":"+ip);
            jp.proceed();
        }
    }
    
}

RedisUtil中的锁代码

public static boolean checkLock(String key,int second) {
  
  String lockKey = "lock:" + key;
  try {
   // 1表示之前不存在,设置成功
   if (setnx(lockKey, "lock") == 1) {
    // 设置有限期
    setExpiredTime(lockKey, second);
    return true;
   } else {
    // 50毫秒的延迟,避免过多请求
    try {
     Thread.sleep(50L);
    } catch (InterruptedException e) {
     log.error(e);
    }
    return false;
   }

  } catch (RedisException e) {
   log.error(e);
   return true;
  }
 }

核心代码已经全部放送,关于redis实现分布式锁,会在另外找个时间和大家分享,欢迎关注~

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,362评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,330评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,247评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,560评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,580评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,569评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,929评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,587评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,840评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,596评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,678评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,366评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,945评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,929评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,165评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,271评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,403评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,580评论 18 139
  • 《分布式任务调度平台XXL-JOB》 一、简介 1.1 概述 XXL-JOB是一个轻量级分布式任务调度框架,其核心...
    许雪里阅读 16,761评论 3 29
  • scheduler定时调度系统是大多行业项目都需要的,传统的spring-job模式,个人感觉已经out了,因为存...
    安琪拉_4b7e阅读 2,821评论 4 6
  • 今天2016年的第一天,本应欢乐的迎接,但却深藏着悲痛,那个从小疼爱我的人在2015年的年末离开了我们。那张...
    b044aaba37c4阅读 228评论 0 0
  • 大家好我叫张鑫哲,下面我来介绍一下我的银龙鱼。 我家的银龙鱼有四十厘米多长,她长着一个三角形的头,...
    张怀东_cef7阅读 513评论 0 0