redis如何创建MYSQL数据库

redis如何创建MYSQL数据库,第1张

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

redis和mysql数据的同步,代码级别大致可以这样做: 读: 读redis->没有,读mysql->把mysql数据写回redis 写: 写mysql->成功,写redis!


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/8392890.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-04-16
下一篇 2023-04-16

发表评论

登录后才能评论

评论列表(0条)

保存