spring schedule + redisson實現分散式系統任務排程
阿新 • • 發佈:2019-01-08
Redisson是架設在Redis基礎上的一個Java駐記憶體資料網格(In-Memory Data Grid)。【Redis官方推薦】
適用場景
主要適用於以下幾種場景:
分散式應用,快取,分散式會話,分散式任務/服務/延遲執行服務,Redis客戶端
redisson初始化:
@Component @Slf4j public class RedissonManager { private Config config = new Config(); private Redisson redisson = null; public Redisson getRedisson() { return redisson; } private static String redis1Ip = PropertiesUtil.getProperty("redis1.ip"); private static Integer redis1Port = Integer.parseInt(PropertiesUtil.getProperty("redis1.port")); private static String redis2Ip = PropertiesUtil.getProperty("redis2.ip"); private static Integer redis2Port = Integer.parseInt(PropertiesUtil.getProperty("redis2.port")); @PostConstruct private void init(){ try { config.useSingleServer().setAddress(new StringBuilder().append(redis1Ip).append(":").append(redis1Port).toString()); redisson = (Redisson) Redisson.create(config); log.info("初始化Redisson結束"); } catch (Exception e) { log.error("redisson init error",e); } } }
redisson分散式鎖實戰
這裡面wait_time有個小坑,通常lock.tryLock後面的第一個引數我們會設定為 0,(0秒)這樣可以避免 叢集環境下兩個執行緒同時拿到鎖。@Scheduled(cron="0 */1 * * * ?") public void closeOrderTaskV4(){ RLock lock = redissonManager.getRedisson().getLock(Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK); boolean getLock = false; try { if(getLock = lock.tryLock(0,50, TimeUnit.SECONDS)){ log.info("Redisson獲取到分散式鎖:{},ThreadName:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,Thread.currentThread().getName()); int hour = Integer.parseInt(PropertiesUtil.getProperty("close.order.task.time.hour","2")); // iOrderService.closeOrder(hour); }else{ log.info("Redisson沒有獲取到分散式鎖:{},ThreadName:{}",Const.REDIS_LOCK.CLOSE_ORDER_TASK_LOCK,Thread.currentThread().getName()); } } catch (InterruptedException e) { log.error("Redisson分散式鎖獲取異常",e); } finally { if(!getLock){ return; } lock.unlock(); log.info("Redisson分散式鎖釋放鎖"); } }