写一个 集群版与单机版 redis springboot java 客户端
时间: 2024-02-24 08:58:57 浏览: 189
springboot整合redis(单机 集群).pdf
好的,以下是一个同时支持 Redis 集群版与单机版的 Spring Boot Java 客户端的示例代码:
首先,你需要引入 Redis 客户端库 jedis:
```xml
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.5.3</version>
</dependency>
```
然后,你可以创建一个 RedisClient 类,实现连接池的初始化、数据操作等功能:
```java
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import redis.clients.jedis.*;
import javax.annotation.PostConstruct;
import java.util.HashSet;
import java.util.Set;
@Component
public class RedisClient {
private JedisPool jedisPool;
private JedisCluster jedisCluster;
@Value("${spring.redis.host}")
private String host;
@Value("${spring.redis.port}")
private int port;
@Value("${spring.redis.password}")
private String password;
@Value("${spring.redis.timeout}")
private int timeout;
@Value("${spring.redis.pool.max-active}")
private int maxActive;
@Value("${spring.redis.pool.max-idle}")
private int maxIdle;
@Value("${spring.redis.pool.max-wait}")
private long maxWaitMillis;
@Value("${spring.redis.pool.min-idle}")
private int minIdle;
@Value("${spring.redis.cluster.nodes}")
private String clusterNodes;
@Value("${spring.redis.cluster.max-redirects}")
private int maxRedirects;
@PostConstruct
public void init() {
if (clusterNodes == null || clusterNodes.isEmpty()) {
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(maxActive);
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
jedisPoolConfig.setMinIdle(minIdle);
jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout, password);
} else {
Set<HostAndPort> jedisClusterNodes = new HashSet<>();
for (String node : clusterNodes.split(",")) {
String[] parts = node.split(":");
jedisClusterNodes.add(new HostAndPort(parts[0], Integer.parseInt(parts[1])));
}
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(maxActive);
jedisPoolConfig.setMaxIdle(maxIdle);
jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
jedisPoolConfig.setMinIdle(minIdle);
jedisCluster = new JedisCluster(jedisClusterNodes, timeout, timeout, maxRedirects, password, jedisPoolConfig);
}
}
public String get(String key) {
if (jedisPool != null) {
try (Jedis jedis = jedisPool.getResource()) {
return jedis.get(key);
}
} else {
return jedisCluster.get(key);
}
}
public void set(String key, String value) {
if (jedisPool != null) {
try (Jedis jedis = jedisPool.getResource()) {
jedis.set(key, value);
}
} else {
jedisCluster.set(key, value);
}
}
public void del(String key) {
if (jedisPool != null) {
try (Jedis jedis = jedisPool.getResource()) {
jedis.del(key);
}
} else {
jedisCluster.del(key);
}
}
// 其他操作...
public void close() {
if (jedisPool != null) {
jedisPool.close();
} else {
jedisCluster.close();
}
}
}
```
在这个示例中,我们增加了一个 init() 方法用来初始化 Redis 连接池,根据配置文件中是否配置了 Redis 集群节点信息来选择使用 JedisPool 还是 JedisCluster。然后,我们可以在 RedisClient 中实现 Redis 的各种操作方法,例如 get、set、del 等。
最后,我们可以在 Spring Boot 应用程序中使用 RedisClient 来连接 Redis,例如:
```java
@Autowired
RedisClient redisClient;
redisClient.set("key", "value");
String value = redisClient.get("key");
System.out.println(value);
redisClient.del("key");
redisClient.close();
```
这是一个同时支持 Redis 集群版与单机版的 Spring Boot Java 客户端示例,你可以根据实际需求进行扩展和优化。
阅读全文