文史百科 redis如何创建MYSQL数据库

Posted 队列

篇首语:没有失败,只有暂时停止成功。本文由小常识网(cha138.com)小编为大家整理,主要介绍了文史百科 redis如何创建MYSQL数据库相关的知识,希望对你有一定的参考价值。

redis如何创建MYSQL数据库  以下文字资料是由(本站网www.cha138.com)小编为大家搜集整理后发布的内容,让我们赶快一起来看一下吧!

应用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));

System.out.println(redisService.exists("Login:"+String.valueOf(login.getId)));

System.out.println(redisService.get(tbname));

相关参考