Redis优化与应用

Redis性能调优

- Redis的性能调优是一个比较复杂的过程，需要从多个方面进行优化，如内存使用、命令使用等。
- 案例：减少不必要的持久化操作。

默认情况下，Redis会执行RDB和AOF两种持久化方式。如果不需要持久化，或者可以接受一定的数据丢失风险，可以关闭其中一种或两种持久化方式。

Java代码：关闭RDB和AOF持久化。

// 设置Redis配置文件路径  
String redisConfig = "/path/to/redis.conf";  // 使用Jedis连接Redis  
Jedis jedis = new Jedis("localhost", 6379);  // 关闭RDB持久化  
jedis.configSet("save", "");  // 关闭AOF持久化  
jedis.configSet("appendonly", "no");  // 同步配置  
jedis.configSet("appendfsync", "no");  // 注意：这些设置会影响数据持久性，仅在确定不需要持久化或可接受数据丢失时使用。

Redis分布式锁

- Redis可以通过分布式锁实现分布式环境下的锁定机制，避免多个客户端同时对同一个资源进行操作。

import redis.clients.jedis.Jedis;  public class RedisDistributedLock {  private static final String LOCK_SUCCESS = "OK";  private static final String SET_IF_NOT_EXIST = "NX";  private static final String SET_WITH_EXPIRE_TIME = "PX";  /**  * 尝试获取分布式锁  * @param jedis Redis客户端  * @param lockKey 锁  * @param requestId 请求标识  * @param expireTime 预期锁的有效时间  * @return 是否获取成功  */  public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {  String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);  return LOCK_SUCCESS.equals(result);  }  // 其他方法，如释放锁等...  
}

Redis缓存应用

- Redis可以作为缓存使用，可以将热点数据缓存在Redis中，提高系统的访问速度。
- 案例：使用Redis缓存热门商品列表。

import redis.clients.jedis.Jedis;  public class RedisCacheApplication {  public static void main(String[] args) {  Jedis jedis = new Jedis("localhost", 6379);  // 假设商品ID为12345的热门商品信息  String popularProductInfo = "Product 12345, Price: $99.99";  // 将商品信息存入Redis缓存，设置过期时间为1小时  jedis.setex("popularProduct:12345", 3600, popularProductInfo);  // 从Redis获取商品信息  String cachedProductInfo = jedis.get("popularProduct:12345");  System.out.println("Cached Product Info: " + cachedProductInfo);  // 关闭连接  jedis.close();  }  
}

Redis实战案例

- Redis在实际应用中有很多应用场景，如秒杀、排名、购物车等。
- 案例：通过lua脚本实现秒杀系统中的库存扣减。

import redis.clients.jedis.Jedis;  public class SeckillSystemWithLua {  private static final String STOCK_KEY = "product:stock";  private static final String LUA_SCRIPT =   "if redis.call('get', KEYS[1]) == false then " +  "  return nil;" +  "end;" +  "local stock = tonumber(redis.call('get', KEYS[1]))" +  "if stock <= 0 then " +  "  return 0;" +  "end;" +  "redis.call('decrby', KEYS[1], 1)" +  "return stock;";  public static void main(String[] args) {  Jedis jedis = new Jedis("localhost", 6379);  // 设置初始库存  jedis.set(STOCK_KEY, "100");  // 模拟多个用户同时发起秒杀请求  for (int i = 0; i < 1000; i++) {  new Thread(() -> {  try {  Long stockLeft = jedis.eval(LUA_SCRIPT, 1, STOCK_KEY);  if (stockLeft != null && stockLeft > 0) {  System.out.println("秒杀成功，剩余库存：" + stockLeft);  } else {  System.out.println("秒杀失败，库存不足！");  }  } catch (Exception e) {  e.printStackTrace();  }  }).start();  }  // 关闭连接（在实际应用中，应该使用连接池来管理连接）  jedis.close();  }  
}