Chinaunix首页 | 论坛 | 博客
  • 博客访问: 5119055
  • 博文数量: 921
  • 博客积分: 16037
  • 博客等级: 上将
  • 技术积分: 8469
  • 用 户 组: 普通用户
  • 注册时间: 2006-04-05 02:08
文章分类

全部博文(921)

文章存档

2020年(1)

2019年(3)

2018年(3)

2017年(6)

2016年(47)

2015年(72)

2014年(25)

2013年(72)

2012年(125)

2011年(182)

2010年(42)

2009年(14)

2008年(85)

2007年(89)

2006年(155)

分类: NOSQL

2015-09-10 12:28:00

应用Redis实现数据的读写,同时利用队列处理器定时将数据写入mysql,此种情况存在的问题主要是如何保证mysql与redis的数据同步,二者数据同步的关键在于mysql数据库中主键,方案是在redis启动时区mysql读取所有表键值存入redis中,往redis写数据是,对redis主键自增并进行读取,若mysql更新失败,则需要及时清除缓存及同步redis主键。

  1. String tbname = "login";
  2.         
  3. //获取mysql表主键值--redis启动时
  4. long id = MySQL.getID(tbname);
  5. //设置redis主键值--redis启动时
  6. redisService.set(tbname, String.valueOf(id));

  7. System.out.println(id);
  8. long l = redisService.incr(tbname);
  9. System.out.println(l);
  10. Login login = new Login();
  11. login.setId(l);
  12. login.setName("redis");
  13. redisService.hmset(String.valueOf(login.getId()), login);

  14. boolean b = MySQL.insert("insert into login(id,name) values(" + login.getId() + ",'" + login.getName() + "')");
  15. /**
  16.  *
  17.  * 队列处理器更新mysql失败:
  18.  *
  19.  * 清除缓存数据,同时主键值自减
  20.  */
  21. if (!b){
  22.     redisService.delKeyAndDecr(tbname, "Login:"+String.valueOf(login.getId()));
  23. }
  24. System.out.println(redisService.exists("Login:"+String.valueOf(login.getId())));
  25. System.out.println(redisService.get(tbname));
原文链接

阅读(2569) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~