Lettuce与Springboot集成使用

news2025/4/6 2:13:32

一、Lettuce核心优势与Spring Boot集成背景

Lettuce特性
- 基于Netty的非阻塞I/O模型，支持同步/异步/响应式编程
- 线程安全：共享单连接实现多线程并发操作，性能衰减低
- 原生支持Redis集群、哨兵、主从架构，自动重连机制保障高可用
- Spring Boot 2.x默认Redis客户端，替代Jedis

适用场景对比

场景	Lettuce适用性	Jedis适用性
高并发低延迟	✅ 异步非阻塞，性能更优	❌ 同步阻塞，连接池压力大
分布式锁/数据结构	需结合Redisson	原生不支持
简单CRUD操作	✅ 内置序列化支持	✅ 轻量易用

二、Spring Boot集成Lettuce全流程

1. 依赖配置

<!-- Spring Boot默认集成Lettuce -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 连接池支持（可选） -->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>

2. 基础配置（application.yml）

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: yourpassword
    lettuce:
      pool:
        max-active: 20    # 最大连接数（高并发场景建议50+）
        max-idle: 10      # 最大空闲连接
        min-idle: 5       # 最小空闲连接（防突发流量）
        max-wait: 100ms   # 获取连接最大等待时间

3. 序列化定制（核心配置类）

@Configuration
public class RedisConfig {
    
    @Bean
    public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        
        // Key序列化
        template.setKeySerializer(new StringRedisSerializer());  
        // Value序列化为JSON
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());  
        return template;
    }
}

序列化方案对比：

StringRedisSerializer：纯字符串操作
Jackson2JsonRedisSerializer：对象序列化（需无参构造）
JdkSerializationRedisSerializer：二进制存储（兼容性差）

三、高级功能实现

1. 哨兵/集群模式

# 哨兵模式配置
spring:
  redis:
    sentinel:
      master: mymaster     # 主节点名称
      nodes: 192.168.1.1:26379,192.168.1.2:26379
    lettuce:
      pool: 
        max-active: 30    # 集群需增大连接池

2. 读写分离（主从架构）

通过自定义LettuceClientConfigurationBuilder实现：

@Bean
public LettuceConnectionFactory redisConnectionFactory() {
    RedisStandaloneConfiguration config = new RedisStandaloneConfiguration("master-host", 6379);
    LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
        .readFrom(ReadFrom.REPLICA_PREFERRED)  // 优先从副本读取
        .build();
    return new LettuceConnectionFactory(config, clientConfig);
}

3. 响应式编程（WebFlux集成）

@Bean
public ReactiveRedisTemplate<String, String> reactiveRedisTemplate(
    ReactiveRedisConnectionFactory factory) {
    return new ReactiveRedisTemplate<>(factory, RedisSerializationContext.string());
}

响应式操作示例：

reactiveTemplate.opsForValue().set("key", "value").subscribe();  // 非阻塞写入

四、性能优化策略

连接池调优
- max-active：根据QPS计算（公式：QPS * avg_time）
- min-idle：保持预热连接，应对突发流量
- 禁用连接池：短连接场景可设置spring.redis.lettuce.pool.enabled=false
序列化优化
- 避免JDK序列化（体积大且跨语言差），优先使用JSON或Protobuf
- 大Value场景启用压缩：
```
template.setValueSerializer(new CompressionRedisSerializer(new Jackson2JsonRedisSerializer<>(Object.class)));
```

批处理与Pipeline

List<Object> results = redisTemplate.executePipelined((RedisCallback<Object>) connection -> {
    for (int i =0; i <1000; i++) {
        connection.stringCommands().set(("key"+i).getBytes(), value.getBytes());
    }
    return null;
});

五、常见问题排查

连接泄漏
- 现象：RedisConnectionFailureException: Cannot get Jedis connection
- 解决：检查finally块是否关闭连接，或使用execute(SessionCallback)自动释放
序列化异常
- 现象：SerializationException: Could not read JSON
- 解决：确保实体类有无参构造器，或切换为GenericJackson2JsonRedisSerializer

高延迟

启用慢查询日志：

redis-cli config set slowlog-log-slower-than 5000  # 记录>5ms操作
redis-cli slowlog get                              # 查看日志

六、扩展场景实践

分布式锁（Redisson整合）

@Bean
public RedissonClient redissonClient() {
    Config config = new Config();
    config.useSingleServer().setAddress("redis://127.0.0.1:6379");
    return Redisson.create(config);
}
// 使用示例
RLock lock = redissonClient.getLock("myLock");
lock.lock();
try { /* 业务逻辑 */ } finally { lock.unlock(); }

多数据源配置
创建多个RedisTemplate实例并指定不同连接工厂：

@Bean(name = "secondaryTemplate")
public RedisTemplate<String, Object> secondaryTemplate(
    @Qualifier("secondaryFactory") RedisConnectionFactory factory) {
    RedisTemplate<String, Object> template = new RedisTemplate<>();
    template.setConnectionFactory(factory);
    return template;
}