Redis的主从同步问题的一些解决方法

# 主服务器的 redis.conf 配置示例

# 启动主服务器
port 6379

# 从服务器的 redis.conf 配置示例

# 启动从服务器
port 6380

# 配置主服务器的IP和端口
replicaof 127.0.0.1 6379

import redis.clients.jedis.Jedis;

public class RedisReplicationSetup {
    public static void main(String[] args) {
        try (Jedis jedis = new Jedis("localhost", 6380)) {
            // 设置从服务器连接到主服务器
            jedis.slaveof("127.0.0.1", 6379);
        }
    }
}

# 主服务器的 redis.conf 配置示例

# 复制缓冲区大小
repl-backlog-size 256mb

# 主服务器的 redis.conf 配置示例

# 复制积压缓冲区大小
repl-backlog-size 256mb

import redis.clients.jedis.Jedis;

public class RedisReplicationDelayMonitor {
    public static void main(String[] args) {
        try (Jedis jedis = new Jedis("localhost", 6380)) {
            // 获取从服务器的复制延迟信息
            String info = jedis.info("replication");
            System.out.println(info);
        }
    }
}

# Sentinel配置文件 sentinel.conf

port 26379

# Sentinel监控的主服务器名称及地址和端口
sentinel monitor mymaster 127.0.0.1 6379 2

# 主服务器被认为不可用的时间（毫秒）
sentinel down-after-milliseconds mymaster 5000

# 故障转移的超时时间（毫秒）
sentinel failover-timeout mymaster 60000

# 并行同步的从服务器数量
sentinel parallel-syncs mymaster 1

redis-sentinel /path/to/sentinel.conf

# 主服务器的 redis.conf 配置示例

# 磁盘写入策略
save 900 1
save 300 10
save 60 10000

# 压缩RDB文件
rdbcompression yes

# 主服务器的 redis.conf 配置示例

# 复制积压缓冲区大小
repl-backlog-size 256mb

# 复制超时
repl-timeout 60

# Sentinel配置文件 sentinel.conf

# Sentinel监控的主服务器名称及地址和端口
sentinel monitor mymaster 127.0.0.1 6379 2

# 主服务器被认为不可用的时间（毫秒）
sentinel down-after-milliseconds mymaster 5000

# 故障转移的超时时间（毫秒）
sentinel failover-timeout mymaster 60000

# 并行同步的从服务器数量
sentinel parallel-syncs mymaster 1

# 设置网络分区时的故障转移策略
sentinel config-epoch mymaster 0
sentinel leader-epoch mymaster 0

import redis.clients.jedis.Jedis;

public class RedisClientRetry {
    public static void main(String[] args) {
        int maxRetries = 3;
        int attempt = 0;
        boolean connected = false;
        Jedis jedis = null;

        while (attempt < maxRetries && !connected) {
            try {
                attempt++;
                jedis = new Jedis("localhost", 6380);
                // 执行Redis操作
                jedis.set("key", "value");
                System.out.println("Value for 'key': " + jedis.get("key"));
                connected = true;
            } catch (Exception e) {
                System.err.println("Attempt " + attempt + " failed: " + e.getMessage());
            } finally {
                if (jedis != null) {
                    jedis.close();
                }
            }

            if (!connected) {
                try {
                    Thread.sleep(2000);  // 等待2秒后重试
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        }

        if (!connected) {
            System.err.println("Failed to connect to Redis after " + maxRetries + " attempts.");
        }
    }
}

import redis.clients.jedis.Jedis;

public class RedisReplicationMonitor {
    public static void main(String[] args) {
        try (Jedis jedis = new Jedis("localhost", 6380)) {
            // 获取从服务器的复制状态信息
            String info = jedis.info("replication");
            System.out.println(info);
        }
    }
}