redis运维之数据迁移_redis数据迁移

1.导出redis的aof和rdb文件

在Redis中，可以使用BGSAVE命令导出AOF日志，而使用SAVE命令导出RDB文件 
1

2.AOF和RDB日志的导出位置

打开redis.conf文件，找到如下配置

dir /path/to/your/directory
1

3.在导入过程中，确保Redis服务器已经停止运行。导入完成后，重新启动Redis服务器
将aof文件放在如上目录，导入AOF文件命令：

BGREWRITEAOF
1

4.在导入过程中，确保Redis服务器已经停止运行。导入完成后，重新启动Redis服务器
将rdb文件放在如上目录，导入RDB文件命令：

CONFIG SET dir /path/to/your/directory
CONFIG REWRITE
1
2

5.疑问
疑问1：导入的时候如果目录有多个.aof或者多个.rdb的文件，那么导入的数据是他们的并集吗？

Redis将按照它们的文件名顺序逐个导入，如果多个文件中存在相同键的操作，
后面的操作将覆盖前面的操作，即最终保留最新的操作，也就是最后导入的数据是他们的并集
1
2

疑问2：导入之后，客户方有的key而导入的文件没有这个key，那这类数据还会保留下来吗？

如果Redis服务器有一些键而导入文件中没有这些键的相关操作记录，那么这些键在导入后将不存在于目标
Redis服务器中
1
2

疑问3：如何想要达到Redis服务器原来的键得以保存，而不是导入文件没有的键就消失，该如何做呢？

自定义代码实现

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.io.FileWriter;
import java.io.IOException;

public class RedisExporter {
    public static void main(String[] args) {

        String redisHost = "";
        int redisPort = 6379;
        int redisTimeout = 5000;
        String redisPassword = "";

        String exportFilePath = "path/to/export/file.txt";


        JedisPoolConfig poolConfig = new JedisPoolConfig();
        JedisPool jedisPool = new JedisPool(poolConfig, redisHost, redisPort, redisTimeout, redisPassword);

        try {

            Jedis jedis = jedisPool.getResource();


            FileWriter writer = new FileWriter(exportFilePath);


            String cursor = "0";
            do {

                redis.clients.jedis.ScanResult<String> scanResult = jedis.scan(cursor);
                cursor = scanResult.getCursor();


                for (String key : scanResult.getResult()) {

                    String value = jedis.get(key);


                    writer.write(key + ":" + value + "\n");
                }
            } while (!cursor.equals("0"));


            writer.close();

            System.out.println("Redis数据导出完成！");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

            jedisPool.close();
        }
    }
}
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

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;

public class RedisImporter {
    public static void main(String[] args) {

        String redisHost = "";
        int redisPort = 6379;
        int redisTimeout = 5000;
        String redisPassword = "";

        String importFilePath = "path/to/import/file.txt";


        JedisPoolConfig poolConfig = new JedisPoolConfig();
        JedisPool jedisPool = new JedisPool(poolConfig, redisHost, redisPort, redisTimeout, redisPassword);

        try {

            Jedis jedis = jedisPool.getResource();


            BufferedReader reader = new BufferedReader(new FileReader(importFilePath));

            String line;
            while ((line = reader.readLine()) != null) {

                String[] parts = line.split(":");
                if (parts.length == 2) {
                    String key = parts[0];
                    String value = parts[1];

                    jedis.set(key, value);
                }
            }


            reader.close();

            System.out.println("Redis数据导入完成！");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {

            jedisPool.close();
        }
    }
}
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