Redis 是一种基于内存的高性能键值存储系统。 Redis 的核心概念、五种数据类型、持久化机制及高可用架构。重点讲解了在 Java 项目中集成 Redis 的两种主流方式：Spring Data Redis 和 Redisson，并通过商品缓存、分布式锁、限流器等实际案例展示了具体应用。最后提供了生产环境的性能优化建议与运维监控指南，帮助开发者全面掌握 Redis 技术栈。
Redis（Remote Dictionary Server）是一个基于内存的高性能键值存储系统，以其卓越的读写性能、丰富的数据结构和强大的功能特性，成为现代分布式系统中不可或缺的基础设施。本文将系统讲解 Redis 的核心知识，并结合 Java 项目实践，帮助读者从理论到实战全面掌握 Redis。
Redis 是一种由 C 语言开发的 NoSQL 数据库，将所有数据存储在内存中，因此读写速度极快（可达每秒数万到数十万次操作）。它支持数据持久化、多种数据结构、高可用集群等特性，被广泛应用于缓存、会话存储、实时分析等场景。
Redis 支持五种基本数据类型，每种类型都有对应的操作命令。
| 类型 | 存储内容 | 常用命令 | 应用场景 |
|---|---|---|---|
| String（字符串） | 字符串、整数、浮点数、二进制数据 | SET/GET, INCR/DECR, MSET/MGET, SETEX | 缓存数据、计数器、分布式锁 |
| Hash（哈希） | 键值对集合（适合存储对象） | HSET/HGET, HMSET/HMGET, HGETALL, HDEL | 用户信息、商品详情 |
| List（列表） | 有序可重复的字符串列表 | LPUSH/RPUSH, LPOP/RPOP, LRANGE, LLEN | 消息队列、最新消息列表 |
| Set（集合） | 无序不重复的字符串集合 | SADD, SMEMBERS, SISMEMBER, SINTER | 标签系统、共同好友 |
| ZSet（有序集合） | 带分数的有序集合（唯一元素 + 分数排序） | ZADD, ZRANGE, ZREVRANGE, ZSCORE | 排行榜、延迟队列 |
常用命令：
SET user:1 "zhangsan" # 设置值
GET user:1 # 获取值
INCR view_count # 计数器+1
SETEX token 3600 "xyz" # 设置值并指定过期时间
常用命令：
HSET user:1 name "zhangsan" age 25 # 设置多个字段
HGET user:1 name # 获取单个字段
HGETALL user:1 # 获取所有字段
HMSET user:2 name "lisi" age 30 # 批量设置
常用命令：
LPUSH messages "hello" # 从左侧插入
RPUSH messages "world" # 从右侧插入
LRANGE messages 0 -1 # 获取所有元素
LPOP messages # 左侧弹出
常用命令：
SADD tags "java" "redis" # 添加元素
SMEMBERS tags # 获取所有元素
SISMEMBER tags "java" # 判断是否存在
SINTER set1 set2 # 交集运算
常用命令：
ZADD leaderboard 100 "tom" # 添加元素及分数
ZRANGE leaderboard 0 -1 # 按分数从小到大获取
ZREVRANGE leaderboard 0 -1 # 按分数从大到小获取
ZSCORE leaderboard "tom" # 获取元素分数
在 Java 生态中，操作 Redis 主要有两种客户端选择：
| 客户端 | 特点 | 适用场景 |
|---|---|---|
| Jedis | 轻量级，API 与 Redis 命令高度一致 | 简单操作，无需高级功能 |
| Redisson | 功能丰富，内置分布式锁、集合、限流器等高级抽象 | 分布式系统、复杂业务场景 |
| Spring Data Redis | Spring 官方集成，统一模板操作 | Spring Boot 项目 |
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
spring:
redis:
host: localhost
port: 6379
password: # 可选
database: 0 # 默认数据库索引
timeout: 3000ms
lettuce:
pool:
max-active: 8 # 连接池最大连接数
max-idle: 8 # 最大空闲连接
min-idle: 0 # 最小空闲连接
@Autowired
private StringRedisTemplate redisTemplate;
// 字符串操作
public void setValue(String key, String value) {
redisTemplate.opsForValue().set(key, value);
}
public String getValue(String key) {
return redisTemplate.opsForValue().get(key);
}
// 计数器
public Long increment(String key) {
return redisTemplate.opsForValue().increment(key);
}
// Hash 操作
public void setHash(String key, String field, String value) {
redisTemplate.opsForHash().put(key, field, value);
}
public Map<Object, Object> getHash(String key) {
return redisTemplate.opsForHash().entries(key);
}
Redisson 提供了丰富的分布式对象和服务，特别适合构建分布式系统。
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.24.2</version>
</dependency>
@Configuration
public class RedissonConfig {
@Bean
public RedissonClient redissonClient() {
Config config = new Config();
config.useSingleServer()
.setAddress("redis://127.0.0.1:6379")
.setConnectionPoolSize(10)
.setConnectionMinimumIdleSize(5)
.setConnectTimeout(3000)
.setTimeout(3000);
return Redisson.create(config);
}
}
下面通过三个典型业务场景，展示 Redis 在 Java 项目中的实际应用。
场景：电商系统需要缓存商品信息，减少数据库压力。
@Service
public class ProductService {
@Autowired
private StringRedisTemplate redisTemplate;
@Autowired
private ProductMapper productMapper; // MyBatis 数据库操作
private static final String CACHE_KEY_PREFIX = "product:";
/**
* 根据商品 ID 获取商品详情（先查缓存，再查数据库）
*/
public Product getProductById(Long id) {
String key = CACHE_KEY_PREFIX + id;
// 1. 尝试从缓存获取
Map<Object, Object> cachedMap = redisTemplate.opsForHash().entries(key);
if (!cachedMap.isEmpty()) {
// 将 Map 转换为 Product 对象
return convertMapToProduct(cachedMap);
}
// 2. 缓存未命中，查询数据库
Product product = productMapper.selectById(id);
if (product != null) {
// 3. 写入缓存（使用 Hash 结构存储对象字段）
Map<String, Object> productMap = convertProductToMap(product);
redisTemplate.opsForHash().putAll(key, productMap);
// 设置缓存过期时间（例如 1 小时）
redisTemplate.expire(key, 1, TimeUnit.HOURS);
}
return product;
}
/**
* 更新商品信息（更新数据库同时更新缓存）
*/
@Transactional
public void updateProduct(Product product) {
// 1. 更新数据库
productMapper.updateById(product);
// 2. 更新缓存
String key = CACHE_KEY_PREFIX + product.getId();
Map<String, Object> productMap = convertProductToMap(product);
redisTemplate.opsForHash().putAll(key, productMap);
}
}
场景：高并发下扣减库存，需要保证同一时间只有一个线程处理同一商品的库存。
@Service
public class InventoryService {
@Autowired
private RedissonClient redissonClient;
/**
* 扣减库存
* @param productId 商品 ID
* @param quantity 扣减数量
* @return 是否成功
*/
public boolean decreaseStock(Long productId, Integer quantity) {
String lockKey = "lock:product:" + productId;
RLock lock = redissonClient.getLock(lockKey);
try {
// 尝试加锁，最多等待 5 秒，锁自动释放时间 10 秒
boolean isLocked = lock.tryLock(5, 10, TimeUnit.SECONDS);
if (!isLocked) {
return false; // 获取锁失败
}
// 执行业务逻辑：查询库存并扣减（需配合数据库操作）
Integer stock = getStockFromDB(productId);
if (stock >= quantity) {
updateStockInDB(productId, stock - quantity);
return true;
}
return false;
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return false;
} finally {
// 确保锁释放
if (lock.isLocked() && lock.isHeldByCurrentThread()) {
lock.unlock();
}
}
}
// 模拟数据库操作
private Integer getStockFromDB(Long productId) {
return 100;
}
private void updateStockInDB(Long productId, int newStock) {
// 实际业务逻辑
}
}
场景：API 接口需要限制每个用户的访问频率，防止刷接口。
@Service
public class RateLimitService {
@Autowired
private RedissonClient redissonClient;
/**
* 判断请求是否允许通过
* @param userId 用户 ID
* @return true 允许，false 拒绝
*/
public boolean tryAcquire(String userId) {
// 每个用户独立的限流器
String key = "rate:limiter:user:" + userId;
RRateLimiter limiter = redissonClient.getRateLimiter(key);
// 初始化：每秒 5 个请求，共享配额（只需初始化一次）
limiter.trySetRate(RateType.OVERALL, 5, 1, TimeUnit.SECONDS);
// 设置限流器自动过期（避免 Redis 内存泄漏）
limiter.expire(30, TimeUnit.MINUTES);
// 尝试获取一个令牌
return limiter.tryAcquire();
}
}
// 在 Controller 中使用
@RestController
public class ApiController {
@Autowired
private RateLimitService rateLimitService;
@GetMapping("/api/data")
public String getData(@RequestParam String userId) {
if (!rateLimitService.tryAcquire(userId)) {
throw new RuntimeException("请求过于频繁，请稍后再试");
}
return "请求成功，数据返回";
}
}
mget/mset 或管道（Pipeline）减少网络往返。Config config = new Config();
config.useClusterServers()
.addNodeAddress("redis://192.168.1.1:7000", "redis://192.168.1.2:7001")
.setMasterConnectionPoolSize(20)
.setSlaveConnectionPoolSize(10);
INFO 查看状态，SLOWLOG 分析慢操作，MONITOR 调试（生产慎用）。SAVE 或 BGSAVE 生成 RDB 文件，并备份到异地存储。Redis 作为内存数据存储的标杆，以其高性能、丰富的数据结构和强大的分布式能力，成为现代应用架构的核心组件。本文从核心概念、数据类型、高级特性到 Java 项目实践，全面解析了 Redis 的知识体系。
在实际开发中，开发者应根据业务场景选择合适的数据结构和客户端：
掌握 Redis 不仅需要理解其原理，更需要通过实战项目积累经验，合理设计数据模型和缓存策略，才能充分发挥其性能优势。
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online