
中的每一个数据库,都由一个
redisDb
的结构存储。其中,redisDb.id
存储着
redis
数据库以整数表示的号码。redisDb.dict
存储着该库所有的键值对数据。redisDb.expires
保存着每一个键的过期时间。
2、当redis
服务器初始化时,会预先分配
16
个数据库(该数量可以通过
配置文件
配置),所有数据库保存到结构
redisServer
的一个成员
redisServer.db
数组中。当我们选择数据库
select
number
时,程序直接通过
redisServer.db[number]
来切换数据库。有时候当程序需要知道自己是在哪个数据库时,直接读取
redisDb.id
即可。
应用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))
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)