基于數(shù)據(jù)庫的分布式鎖

記一次分布式鎖-基于數(shù)據(jù)庫

1:分布鎖碱妆,我所了解的一共有三種方式

A:傳統(tǒng)的數(shù)據(jù)庫的全局鎖

B:基于緩存的全局鎖拓轻,如redis

C:基于zookeeper的分布式鎖

這三種方式的優(yōu)先機是 C > B > A洛心。因為公司架構問題乳讥,最終還是選擇了第一種實現(xiàn)方式考蕾。所以本文只講述關于數(shù)據(jù)庫的分布式鎖掖肋。以下提供相關知識的幾個鏈接甩苛,請自行查閱

分布式鎖的幾種實現(xiàn)方式

Redis分布式鎖的正確實現(xiàn)方式

分布式鎖與實現(xiàn)(二)——基于ZooKeeper實現(xiàn)

2:數(shù)據(jù)庫全局鎖的優(yōu)缺點

優(yōu)點:

簡單易實現(xiàn)

缺點:

A:存在數(shù)據(jù)庫一般是單點的蹂楣,一旦數(shù)據(jù)庫宕機。服務則不可用浪藻。

B:鎖沒有失效時間捐迫,一旦解鎖失敗則鎖一直存在,導致服務不可用爱葵、線程阻塞

C:鎖只能是非阻塞的施戴,鎖不可重入

3:數(shù)據(jù)庫全局鎖的解決方案

1:單點反浓?數(shù)據(jù)庫可以多搞個數(shù)據(jù)庫備份。

2:沒有失效時間赞哗?定時任務雷则,隔一段時間清理一次》舅瘢或者每次加鎖時月劈,插入一個期待的有效時間,下次加鎖時則先判斷當前時間是否大于有效時間以此判斷鎖是否失效藤乙。

3:非阻塞猜揪?開啟另個線程循環(huán)獲取

4:非重入,在加鎖時加入機器信息和線程信息坛梁,下次獲取時而姐,先判斷這兩個字段

4:代碼實例

@Component
public class ArchiveTask {
    
    private ThreadPoolTaskScheduler scheduler  = null;
    private ArchiveTaskDAO dao;
    private ScheduledFuture<?> future;
    private String clearDataDay = "90"; //默認遷移90天前的數(shù)據(jù)
    private String wfmProcedure = null;
    public static String stype = "TASK_SCHEDULER";
    public static String pkey = "WFM_ARCHIVE_TASK";
    public static String lock = "lock";   // 上鎖狀態(tài)
    public static String unLock = "unLock"; // 無鎖狀態(tài)
    public static String errorLock = "errorLock"; // 發(fā)生了錯誤
    public static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
    private boolean isLock = false;
    
    //private Logger logger = LoggerFactory.getLogger(ArchiveTask.class);
    
    public void init(){
        
        scheduler = new ThreadPoolTaskScheduler();
        dao = (ArchiveTaskDAO) BaseDAOFactory.getDAO(ArchiveTaskDAO.class.getName());
        wfmProcedure = Optional.ofNullable(dao.getConfigByType("ORDER", "HIS_SAVE_ORDERHIS_BY_ORDERID"))
                .orElse("HIS_SAVE_ORDERHIS_BY_ORDERID");
        
    
        
    }
    public void schedule(){
        
        scheduler.initialize();
        future = scheduler.schedule(()->{
            // 執(zhí)行任務
            runTask();
            
        }, new Trigger(){
            // 先執(zhí)行 Trigger,在執(zhí)行 Runnable
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                // TODO Auto-generated method stub
                Date nextExecDate = null;
                try {
                    //查詢定時計劃
                    Map<String,Object> taskMap = dao.getTaskSchedulerCron();
                    String cron = MapUtils.getString(taskMap, "cron", "");
                    if(cron.equals("")) {
                        return null;
                    } 
                    // 定時任務觸發(fā)划咐,可修改定時任務的執(zhí)行周期拴念。數(shù)據(jù)庫修改即可,不用重啟應用褐缠。
                    CronTrigger trigger = new CronTrigger(cron);
                    nextExecDate = trigger.nextExecutionTime(triggerContext);
                    //計算時間差
                    Long timeDiffSecond =  (nextExecDate.getTime() - new Date().getTime())/1000;
                    dao.updateTaskNextTimeDiff(timeDiffSecond.toString());
                }catch (Exception e) {
                    e.printStackTrace();
                }
                return nextExecDate;
            }
            
        });
    }
    public void stop(){
        future.cancel(true);
    }
    
    public void reStart(){
        future.cancel(true);
        schedule();
    }
    
    public void test(){ //  不通過定時任務,測試
        scheduler.initialize();
        scheduler.execute(()->{
            runTask();
        }); 
    }
    
    private  void runTask(){
        try{
            Map<String,Object> taskMap = dao.getTaskSchedulerCron();
            //0) 功能開關政鼠,如果關閉則直接跳過
            String openStatus = MapUtils.getString(taskMap, "openStatus","");
            if(!openStatus.equals("open")){
                return;
            }
            //1)查詢鎖的有效時間
            boolean lockValid = true; // 判斷之前的加鎖時間是否有效
            String timeDiffSecondStr = MapUtils.getString(taskMap, "timeDiffSecond","");
            String modifyDay = MapUtils.getString(taskMap, "modifyDay", ""); // 最近修改鎖時間
            if(modifyDay.equals("")||timeDiffSecondStr.equals("")){
                lockValid = false;
            }else{
                Long timeDiffSecond = Long.parseLong(timeDiffSecondStr);
                Date modifyDate = sdf.parse(modifyDay);
                Calendar  tmpCal = Calendar.getInstance();
                tmpCal.setTime(modifyDate);
                tmpCal.add(Calendar.SECOND, timeDiffSecond.intValue());
                Date curDateForValid = tmpCal.getTime(); //鎖的有效時間
                Date curDate = new Date();
                if(curDate.after(curDateForValid)){ //鎖失效
                    lockValid = false;
                }
            }
            
            //2) 先判斷是否已有其他線程、進程在執(zhí)行數(shù)據(jù)遷移任務了,數(shù)據(jù)庫鎖
            synchronized (ArchiveTask.class) {
                int flag = dao.taskSchedulerLock(lockValid);
                if(flag < 1){ // 無法加鎖队魏,已被其他任務鎖住了
                    return;
                }
                isLock = true;
            }
            

            //3)查詢需要遷移的數(shù)據(jù)
            Calendar  cal = Calendar.getInstance();
            String dayStr = MapUtils.getString(taskMap, "day", clearDataDay);
            Integer dayI = Integer.parseInt(dayStr);
            cal.add(Calendar.DAY_OF_YEAR, - dayI.intValue());
            Date endDate = cal.getTime();  //  截止日期
            Map<String,Object> params = new HashMap<String, Object>();
            params.put("endDate", endDate);
            params.put("iomBaseDataName", iomBaseDataName);
            //4) (邏輯處理)
           
            
            //更新鎖狀態(tài)
            dao.updateTaskSchedulerLock(unLock);
            isLock = false;
        }catch(Exception ex){
            ex.printStackTrace();
            //如果出錯 則更新數(shù)據(jù)庫鎖 為 出錯狀態(tài)
            dao.updateTaskSchedulerLock(errorLock);
            isLock = false;
        }
    }
    
    public void releaseLock(){
        if(isLock==true){
            dao.updateTaskSchedulerLock(unLock);
        }
    }
    
}
最后編輯于
?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末公般,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子器躏,更是在濱河造成了極大的恐慌俐载,老刑警劉巖蟹略,帶你破解...
    沈念sama閱讀 211,194評論 6 490
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件登失,死亡現(xiàn)場離奇詭異,居然都是意外死亡挖炬,警方通過查閱死者的電腦和手機揽浙,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,058評論 2 385
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來意敛,“玉大人馅巷,你說我怎么就攤上這事〔菀觯” “怎么了钓猬?”我有些...
    開封第一講書人閱讀 156,780評論 0 346
  • 文/不壞的土叔 我叫張陵,是天一觀的道長撩独。 經(jīng)常有香客問我敞曹,道長账月,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,388評論 1 283
  • 正文 為了忘掉前任澳迫,我火速辦了婚禮局齿,結果婚禮上,老公的妹妹穿的比我還像新娘橄登。我一直安慰自己抓歼,他們只是感情好,可當我...
    茶點故事閱讀 65,430評論 5 384
  • 文/花漫 我一把揭開白布拢锹。 她就那樣靜靜地躺著谣妻,像睡著了一般。 火紅的嫁衣襯著肌膚如雪卒稳。 梳的紋絲不亂的頭發(fā)上拌禾,一...
    開封第一講書人閱讀 49,764評論 1 290
  • 那天,我揣著相機與錄音展哭,去河邊找鬼湃窍。 笑死,一個胖子當著我的面吹牛匪傍,可吹牛的內(nèi)容都是我干的您市。 我是一名探鬼主播,決...
    沈念sama閱讀 38,907評論 3 406
  • 文/蒼蘭香墨 我猛地睜開眼役衡,長吁一口氣:“原來是場噩夢啊……” “哼茵休!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起手蝎,我...
    開封第一講書人閱讀 37,679評論 0 266
  • 序言:老撾萬榮一對情侶失蹤榕莺,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后棵介,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體钉鸯,經(jīng)...
    沈念sama閱讀 44,122評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,459評論 2 325
  • 正文 我和宋清朗相戀三年邮辽,在試婚紗的時候發(fā)現(xiàn)自己被綠了唠雕。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,605評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡吨述,死狀恐怖岩睁,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情揣云,我是刑警寧澤捕儒,帶...
    沈念sama閱讀 34,270評論 4 329
  • 正文 年R本政府宣布,位于F島的核電站邓夕,受9級特大地震影響刘莹,放射性物質(zhì)發(fā)生泄漏亿笤。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 39,867評論 3 312
  • 文/蒙蒙 一栋猖、第九天 我趴在偏房一處隱蔽的房頂上張望净薛。 院中可真熱鬧,春花似錦蒲拉、人聲如沸肃拜。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,734評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽燃领。三九已至,卻和暖如春锦援,著一層夾襖步出監(jiān)牢的瞬間猛蔽,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,961評論 1 265
  • 我被黑心中介騙來泰國打工灵寺, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留曼库,地道東北人。 一個月前我還...
    沈念sama閱讀 46,297評論 2 360
  • 正文 我出身青樓略板,卻偏偏與公主長得像毁枯,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子叮称,可洞房花燭夜當晚...
    茶點故事閱讀 43,472評論 2 348