如何搭建redis扩展

如何搭建redis扩展

应用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（） + “’）”）；

if （！b）{
redisService.delKeyAndDecr（tbname, “Login:”+String.valueOf（login.getId（）））；
}
System.out.println（redisService.exists（“Login:”+String.valueOf（login.getId（））））；
System.out.println（redisService.get（tbname））；