Java实现Redis持久化到数据库的关键方法
import java.util.Date;
import java.util.Iterator;
import java.util.Set;
import redis.clients.jedis.Jedis;
import com.redis.entity.RedisTable;
public class RedisPersistence {
/**
* 存储所有的redis对象方法
*/
public static void saveAllRedis(final String redisIp,final int redisPort,final String appCode) {
Jedis redis = new Jedis(redisIp, redisPort);// 连接redis
// redis.auth("redis");//验证密码
// KEY操作
Set keys = redis.keys("*");// 列出所有的key，查找特定的key如：redis.keys("foo")
Iterator t1 = keys.iterator();
while (t1.hasNext()) {
Object obj1 = t1.next();
saveRedisObject(redis, obj1 + "", redisIp, redisPort + "", appCode);
}
}
/**
* 存储单个对象
* @param redis
* @param redisKey
* @param macIp
* @param port
* @param appCode
*/
private static void saveRedisObject(final Jedis redis,final String redisKey,final String macIp,final String port,final String appCode) {
String redisType = redis.type(redisKey);
RedisTable redisTable = new RedisTable();
redisTable.setAppCode(appCode);
redisTable.setCreateTime(new Date());
redisTable.setMacIp(macIp);
redisTable.setPort(port);
redisTable.setRedisKey(redisKey);
redisTable.setRedisType(redisType);
redisTable.setRemark("");
redisTable.setUpdateTime(new Date());
//set集合
if("set".equalsIgnoreCase(redisType)){
Set<string> setStrings = redis.smembers(redisKey);//获取key的所有set集合
if(null != setStrings && !setStrings.isEmpty()){
Iterator setIterator = setStrings.iterator() ;
while(setIterator.hasNext()){
Object obj1 = setIterator.next();
redisTable.setRedisValue(obj1+"");
printRedis(redisTable);//保存每一个set记录
}
}
//hash集合
}else if("hash".equalsIgnoreCase(redisType)){
Set<string> hashSets = redis.hkeys(redisKey);
if(null != hashSets && !hashSets.isEmpty()){
Iterator setIterator = hashSets.iterator() ;
while(setIterator.hasNext()){
String objectName = setIterator.next()+"";
redisTable.setObjectName(objectName);
redisTable.setRedisValue(redis.hget(redisKey, objectName));
printRedis(redisTable);//保存每一个set记录
}
}
//list集合
}else if("list".equalsIgnoreCase(redisType)){
Long listLen = redis.llen(redisKey);
for (Long i = 0L; i < listLen; i++) {
redisTable.setRedisValue(redis.lindex(redisKey, i));
printRedis(redisTable);
}
//sortedset集合
}else if("sortedset".equalsIgnoreCase(redisType)){
// Long redisLenth = redis.zcard(redisKey); Set<string> sortedsets = redis.zrange(redisKey, 0, -1);
if(null != sortedsets && !sortedsets.isEmpty()){
Iterator setIterator = sortedsets.iterator() ;
while(setIterator.hasNext()){
String sortedMember = setIterator.next() +"";
redisTable.setRedisValue(sortedMember);
redisTable.setScore("" +redis.zscore(redisKey, sortedMember));
printRedis(redisTable);//保存每一个sortedset记录
}
}
//string集合
}else if("string".equalsIgnoreCase(redisType)){
redisTable.setRedisValue(redis.get(redisKey));
printRedis(redisTable);//保存记录
}else{
System.out.println("UnknowRedisType-----redisType: " +redisType+" objValue: "+redis.get(redisKey));
}
}
//打印输出
public static void printRedis (RedisTable redisTable) {
System.out.println("redisType:"+redisTable.getRedisType()
+ " redisKey:"+redisTable.getRedisKey()
+ " ObjectName:"+redisTable.getObjectName()
+ " redisValue:"+redisTable.getRedisValue()
+ " redisScore:"+redisTable.getScore()
);
}
public static void main(String[] args) {
String redisIp = "127.0.0.1";//redis的IP地址
int redisPort = 6379;//redis的端口号
String appCode = "FUYOU";//根据不同的应用区分的appcode
saveAllRedis(redisIp,redisPort,appCode);
}
}</string></string></string>其中的appCode是不需要的，这里只是为了针对于不同的应用，可以使用同一个redis进行持久化备份而已（通过appcode来区分）。
其中使用的RedisTable实例如下：
import java.util.Date;
public class RedisTable {
private Long redisId; //保存redis的主键ID
private String redisType;//redis的类型如：set/list/hash/sortedset/string
private String redisKey;//保存redis时使用的key
private String objectName;//此属性主要用于hash数据结构时，保存member的
private String redisValue;//存储的redis的值
private String keyToken;//保存Token时，为区分拼接的字符串
private String score;//此属性为sortedset数据结构时，保存的score值
private Date createTime;//创建时间
private Date updateTime;//更新时间
private String macIp;//redis的IP地址 当然此处也可以存储mac地址
private String port;//redis使用的端口号
private String appCode;//应用区分码
private String remark;//备注
private String isModify;//是否修改。此属性可以用于增量备份时，即在每个redis存储时可以更具key多存储一个属性isModify。 如果有修改，则置为 Y,否则为N.
///////////////////////此处省略 setter and getter 方法////////////////////////}