二者数据同步的关键在于mysql数据库中主键,方案是在redis启动时区mysql读取所有表键值存入redis中,往redis写数据是,对redis主键自增并进行读取,若mysql更新失败,则需要及时清除缓存及同步redis主键参考代码如下:,今天小编就来聊一聊关于如何将redis数据同步到mysql?接下来我们就一起去研究一下吧!
如何将redis数据同步到mysql
二者数据同步的关键在于mysql数据库中主键,方案是在redis启动时区mysql读取所有表键值存入redis中,往redis写数据是,对redis主键自增并进行读取,若mysql更新失败,则需要及时清除缓存及同步redis主键。参考代码如下:
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())));