1. 程式人生 > >mysql保障資料一致性:redis與mysql資料同步(二)

mysql保障資料一致性:redis與mysql資料同步(二)

應用Redis實現資料的讀寫,同時利用佇列處理器定時將資料寫入mysql,此種情況存在的問題主要是如何保證mysql與redis的資料同步,二者資料同步的關鍵在於mysql資料庫中主鍵,方案是在redis啟動時區mysql讀取所有表鍵值存入redis中,往redis寫資料是,對redis主鍵自增並進行讀取,若mysql更新失敗,則需要及時清除快取及同步redis主鍵。

<span style="white-space:pre">	</span>String tbname = "login";           
        //獲取mysql表主鍵值--redis啟動時  
        long id = MySQL.getID(tbname);  
        //設定redis主鍵值--redis啟動時  
        redisService.set(tbname, String.valueOf(id));  

        System.out.println(id);  
        long l = redisService.incr(tbname);  
        System.out.println(l);  
        Login login = new Login();  
        login.setId(l);  
        login.setName("redis");  
        redisService.hmset(String.valueOf(login.getId()), login);  
  
        boolean b = MySQL.insert("insert into login(id,name) values(" + login.getId()  
                + ",'" + login.getName() + "')");  
        /** 
         *  
         * 佇列處理器更新mysql失敗: 
         *  
         * 清除快取資料,同時主鍵值自減 
         */  
        if (!b)  
            {  
            redisService.delKeyAndDecr  
                (tbname, "Login:"+String.valueOf(login.getId()));  
            //  redisService.delete("Login:"+String.valueOf(login.getId()));  
                //redisService.decr(tbname);  
            }  
        System.out.println(redisService.exists("Login:"+String.valueOf(login.getId())));  
        System.out.println(redisService.get(tbname));  
原文:http://blog.csdn.net/hpb21/article/details/7905352