redis 哨兵模式 写数据 java

在 Redis 哨兵模式下写数据，需要先获取 Redis 客户端连接，然后使用 Jedis 对象进行数据写入操作。在写入数据时，需要注意以下几点：

1. 需要使用 Jedis 对象的 `set` 方法进行数据写入。
2. 如果 Redis 主节点发生故障，哨兵会自动将从节点升级为主节点，此时需要重新获取 Redis 客户端连接。
3. 在写入数据时，可以选择是否设置过期时间。

以下是一个简单的 Java 代码示例：

Jedis jedis = new Jedis("sentinel-host", 26379);
jedis.auth("password");
String masterName = "mymaster";
HostAndPort master = jedis.sentinelGetMasterAddrByName(masterName);
Jedis masterJedis = new Jedis(master.getHost(), master.getPort());
masterJedis.auth("password");
masterJedis.set("key", "value");

相关问题

用Java写个demo测试redis哨兵模式

好的，以下是一个简单的 Java Demo，用于测试 Redis 哨兵模式：

import redis.clients.jedis.*;

import java.util.HashSet;
import java.util.Set;

public class RedisSentinelDemo {

    public static void main(String[] args) {
        // 哨兵节点信息
        Set<String> sentinels = new HashSet<>();
        sentinels.add("192.168.0.1:26379");
        sentinels.add("192.168.0.2:26379");
        sentinels.add("192.168.0.3:26379");

        // Redis 实例名称
        String sentinelMasterName = "mymaster";

        // 创建 Redis Sentinel 客户端
        JedisSentinelPool pool = new JedisSentinelPool(sentinelMasterName, sentinels);

        // 获取 Redis 实例连接
        Jedis jedis = pool.getResource();

        // 存储数据
        jedis.set("key", "value");

        // 获取数据
        String value = jedis.get("key");
        System.out.println("value = " + value);

        // 关闭连接池
        pool.close();
    }
}

这个 Demo 首先需要引入 Redis 客户端库 jedis，然后创建一个 JedisSentinelPool 对象，传入哨兵节点信息和 Redis 实例名称，即可获取 Redis 实例连接。最后可以使用 jedis 对象进行数据操作，操作完成后需要关闭连接池。

redis 哨兵模式的Springboot配置

在 Spring Boot 中配置 Redis 哨兵模式，可以按照以下步骤进行：

1. 添加 Redis 相关依赖

在 `pom.xml` 文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.6.1</version>
</dependency>

其中，`spring-boot-starter-data-redis` 是 Spring Boot 提供的 Redis Starter，`jedis` 是 Redis 官方的 Java 客户端库。

2. 配置 Redis 哨兵节点

在 `application.properties` 或 `application.yml` 文件中添加以下配置项：

spring.redis.sentinel.master=your_master_name
spring.redis.sentinel.nodes=node1:26379,node2:26379,node3:26379

其中，`your_master_name` 表示 Redis 哨兵模式的主节点名称，`node1:26379` 到 `node3:26379` 表示多个 Redis 哨兵节点的地址和端口号，需要根据实际情况进行调整。

3. 配置 Redis 连接池

在 `application.properties` 或 `application.yml` 文件中添加以下配置项：

spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0

其中，`max-active` 表示最大连接数，`max-wait` 表示最大等待时间，`max-idle` 表示最大空闲连接数，`min-idle` 表示最小空闲连接数。需要根据实际情况进行调整。

4. 配置 Redis 访问密码（可选）

如果 Redis 哨兵模式启用了认证机制，需要在 `application.properties` 或 `application.yml` 文件中添加以下配置项：

spring.redis.password=your_password

其中，`your_password` 表示 Redis 哨兵模式的访问密码。

5. 使用 RedisTemplate 访问 Redis

通过以上步骤，就可以在 Spring Boot 中配置 Redis 哨兵模式。在使用 Redis 时，可以使用 `RedisTemplate` 对象进行访问。例如：

@Autowired
private RedisTemplate<String, String> redisTemplate;

public void setValue(String key, String value) {
    redisTemplate.opsForValue().set(key, value);
}

public String getValue(String key) {
    return redisTemplate.opsForValue().get(key);
}

以上代码中，`redisTemplate` 对象是通过 `@Autowired` 注解自动注入的，可以直接使用。在实际使用中，可以根据需要选择不同的 Redis 数据类型，例如 `opsForValue()` 方法用于访问 Redis 字符串类型。