欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

redis 模拟quartz sharding

程序员文章站 2022-05-28 16:14:11
...
// 支持动态扩容 
    private static String ip="192.168.1.3";

    //获取所有任务
    @Test
    public void execute() throws InterruptedException {
        CacheUtil cacheUtil01=context.getBean("cacheUtil01",CacheUtil.class);
        cacheUtil01.lPush("ipList",ip); // 优化点  注册的成功后 获取返回的索引(分片Id)
        //int sheardId=1;
        //根据 分片id 获取任务
        //List<Integer> jobs=getJobs(sheardId);
        for(int i=0;i<365;i++){
            List<String> list=cacheUtil01.hMget("ipList-Map",String.valueOf(i));
            if(CollectionUtils.isEmpty(list) || list.get(0) == null) {
                Thread.sleep(1000);
                executeTask(i, "110");
            }
        }
    }

//执行任务
    public void executeTask(int day,String shopguid){
        CacheUtil cacheUtil01=context.getBean("cacheUtil01",CacheUtil.class);
        //list llen
        List<String> ips=cacheUtil01.lRange("ipList",0,10);
        int mode=day%ips.size();
        if(ips.get(mode).equals(ip)){
            cacheUtil01.hAdd("ipList-Map",String.valueOf(day),ip);
            System.out.println(ip+":"+shopguid+"-第"+day+"天");
        }
    }