Java中使用Redis缓存数据，通常通过Jedis或Lettuce等客户端库连接Redis，然后使用SET命令存储键值对，`jedis.
Java中Redis缓存数据的方法
在Java应用中，使用Redis进行数据缓存是一种常见的优化手段，可以显著提升系统性能,以下是详细的实现步骤和注意事项：
环境准备与依赖配置
| 步骤 | 操作说明 |
|---|---|
| 安装Redis | 从官网下载并安装Redis服务器，启动服务（默认端口6379）。 |
| Maven依赖配置 | 在pom.xml中添加Jedis或Lettuce客户端依赖： |
| “`xml | |
| “` |
连接池配置
为提高性能和资源复用,建议使用连接池管理Redis连接：
public class RedisConfig {
private static JedisPool jedisPool;
static {
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxTotal(128); // 最大连接数
poolConfig.setMaxIdle(32); // 最大空闲连接数
poolConfig.setMinIdle(8); // 最小空闲连接数
poolConfig.setTestOnBorrow(true);
jedisPool = new JedisPool(poolConfig, "localhost", 6379);
}
public static Jedis getJedis() {
return jedisPool.getResource();
}
public static void close(Jedis jedis) {
if (jedis != null) jedis.close();
}
}
缓存工具类实现
通过工具类封装缓存操作,支持序列化与过期管理：
public class RedisCacheUtil {
private static final ObjectMapper objectMapper = new ObjectMapper();
// 设置缓存（支持JSON序列化）
public static void set(String key, Object value, int expireSeconds) {
try (Jedis jedis = RedisConfig.getJedis()) {
String json = objectMapper.writeValueAsString(value);
jedis.set(key, json);
if (expireSeconds > 0) jedis.expire(key, expireSeconds);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
}
// 获取缓存（反序列化）
public static <T> T get(String key, Class<T> clazz) {
try (Jedis jedis = RedisConfig.getJedis()) {
String json = jedis.get(key);
return json == null ? null : objectMapper.readValue(json, clazz);
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
// 删除缓存
public static void delete(String key) {
try (Jedis jedis = RedisConfig.getJedis()) {
jedis.del(key);
}
}
}
缓存使用场景与策略
| 场景 | 实现方式 |
|---|---|
| 数据库查询缓存 | 先查Redis，命中则返回；未命中从数据库加载后写入Redis。 |
| 高频数据预加载 | 启动时将热点数据（如配置信息）预先存入Redis。 |
| 分布式会话存储 | 用Redis存储用户Session，实现多节点共享（键格式：session:{sessionId}）。 |
缓存策略设计
| 策略类型 | 说明 |
|---|---|
| 过期时间（TTL） | 通过expire设置键的存活时间（如jedis.setex("key", 3600, "value")）。 |
| LRU淘汰 | Redis默认使用LFU策略，可通过maxmemory-policy配置为allkeys-lru。 |
| 缓存穿透预防 | 缓存空值（如NULL），避免频繁查询数据库。 |
| 雪崩防护 | 给TTL加随机值（如3600 + Random(600)），防止集中失效。 |
高级功能扩展
| 功能 | 实现示例 |
|---|---|
| 哈希类型存储 | “`java |
| jedis.hset(“user:1001”, “name”, “Alice”); | |
| String name = jedis.hget(“user:1001”, “name”); | |
| “` | |
| 列表队列 | “`java |
| jedis.lpush(“taskQueue”, “task1”); // 推入队列 | |
| String task = jedis.rpop(“taskQueue”); // 弹出任务 | |
| “` | |
| 发布/订阅 | “`java |
| JedisPubSub pubsub = new JedisPubSub() { | |
| @Override public void onMessage(String channel, String msg) { | |
| System.out.println(“Received: ” + msg); | |
| jedis.subscribe(pubsub, “notifications”); | |
| “` |
FAQs（常见问题解答）
Q1：如何确保缓存与数据库数据一致性？
A1：采用以下策略：
- 读写穿透：读请求先查缓存，未命中时从数据库加载并更新缓存。
- 删除策略：数据变更时（如UPDATE/DELETE），删除对应缓存键。
- 消息监听：通过消息队列（如Redis Stream）监听数据变更事件,自动清理缓存。
Q2：如何选择Redis客户端（Jedis vs Lettuce）？
A2：根据需求选择：
- Jedis：轻量级，适合简单场景；单线程连接，易用性高。
原创文章，发布者：酷盾叔，转转请注明出处：https://www.kd.cn/ask/82254.html
