Java实现Redis持久化到数据库的关键方法

时间  2019-11-26
标签 java 实现 redis 持久 数据库 关键 方法 栏目 Java 繁體版
原文   原文链接

项目中有些使用的redis存储，当对redis进行rehash的时候感受是比较麻烦的。因而写了个简单的读取redis到数据库的关键方法。仅供参考。html

?java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
package com.redis.web;
 
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来区分）。web

其中使用的RedisTable实例以下：redis

?数据库

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
package com.redis.entity;
 
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 方法////////////////////////
 
 
}




以上方法能够扩充用于redis备份中心。数据结构

在使用redis增量备份时，请根据rediskey在数据块中查找是否存在。根据更新值返回的0或者是1,进行更新或者新增的操做。app

固然数据库的表结构目前只是一张表，若是数据量很大的状况下，能够将端口、IP、appCode信息存储到单独的一张表，减小数据冗余。优化

以上的时间复杂度以及效率上并无优化。若是要求比较高，请自行优化。spa


但愿各位大侠给出建议，共同进步！code

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程