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+"天"); } }
上一篇: gradle 高版本配置lombok插件
下一篇: MySql 汉字转拼音首字母