redis与mysql数据同步

liukun2009

　　应用Redis实现数据的读写，同时利用队列处理器定时将数据写入mysql，此种情况存在的问题主要是如何保证mysql与redis的数据同步，二者数据同步的关键在于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())));
  
• 　　System.out.println(redisService.get(tbname));